Skip to content

Commit

Permalink
Run go import
Browse files Browse the repository at this point in the history
  • Loading branch information
Leo6Leo committed Oct 6, 2023
1 parent 52197ba commit f95bc93
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 10 deletions.
8 changes: 4 additions & 4 deletions pkg/apis/sources/v1/apiserver_lifecycle.go
Original file line number Diff line number Diff line change
Expand Up @@ -132,17 +132,17 @@ func (s *ApiServerSourceStatus) IsReady() bool {
}

func (s *ApiServerSourceStatus) MarkOIDCIdentityCreatedSucceeded() {
apiserverCondSet.Manage(s).MarkTrue(ApiServerConditionOIDCIdentityCreated)
apiserverCondSet.Manage(s).MarkTrue(ApiServerConditionOIDCIdentityCreated)
}

func (s *ApiServerSourceStatus) MarkOIDCIdentityCreatedSucceededWithReason(reason, messageFormat string, messageA ...interface{}) {
apiserverCondSet.Manage(s).MarkTrueWithReason(ApiServerConditionOIDCIdentityCreated, reason, messageFormat, messageA...)
apiserverCondSet.Manage(s).MarkTrueWithReason(ApiServerConditionOIDCIdentityCreated, reason, messageFormat, messageA...)
}

func (s *ApiServerSourceStatus) MarkOIDCIdentityCreatedFailed(reason, messageFormat string, messageA ...interface{}) {
apiserverCondSet.Manage(s).MarkFalse(ApiServerConditionOIDCIdentityCreated, reason, messageFormat, messageA...)
apiserverCondSet.Manage(s).MarkFalse(ApiServerConditionOIDCIdentityCreated, reason, messageFormat, messageA...)
}

func (s *ApiServerSourceStatus) MarkOIDCIdentityCreatedUnknown(reason, messageFormat string, messageA ...interface{}) {
apiserverCondSet.Manage(s).MarkUnknown(ApiServerConditionOIDCIdentityCreated, reason, messageFormat, messageA...)
apiserverCondSet.Manage(s).MarkUnknown(ApiServerConditionOIDCIdentityCreated, reason, messageFormat, messageA...)
}
8 changes: 4 additions & 4 deletions pkg/reconciler/apiserversource/controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -58,10 +58,10 @@ func NewController(
serviceaccountInformer := serviceaccountinformer.Get(ctx)

r := &Reconciler{
kubeClientSet: kubeclient.Get(ctx),
ceSource: GetCfgHost(ctx),
configs: reconcilersource.WatchConfigurations(ctx, component, cmw),
namespaceLister: namespaceInformer.Lister(),
kubeClientSet: kubeclient.Get(ctx),
ceSource: GetCfgHost(ctx),
configs: reconcilersource.WatchConfigurations(ctx, component, cmw),
namespaceLister: namespaceInformer.Lister(),
serviceAccountLister: serviceaccountInformer.Lister(),
}

Expand Down
3 changes: 1 addition & 2 deletions pkg/reconciler/testing/v1/apiserversouce.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,10 +27,10 @@ import (
duckv1 "knative.dev/pkg/apis/duck/v1"
"knative.dev/pkg/kmeta"

"knative.dev/eventing/pkg/apis/feature"
apisources "knative.dev/eventing/pkg/apis/sources"
v1 "knative.dev/eventing/pkg/apis/sources/v1"
"knative.dev/eventing/pkg/reconciler/testing"
"knative.dev/eventing/pkg/apis/feature"
)

// ApiServerSourceOption enables further configuration of a v1 ApiServer.
Expand Down Expand Up @@ -151,7 +151,6 @@ func WithApiServerSourceStatusNamespaces(namespaces []string) ApiServerSourceOpt
}
}


func WithApiServerSourceOIDCIdentityCreatedSucceeded() ApiServerSourceOption {
return func(c *v1.ApiServerSource) {
c.Status.MarkOIDCIdentityCreatedSucceeded()
Expand Down

0 comments on commit f95bc93

Please sign in to comment.