konnector

type CommitFunc = func(context.Context, *Resource, *Resource) error

type Config struct {
	ClientConfig        *rest.Config
	BindClient          *bindclient.Clientset
	KubeClient          *kubernetesclient.Clientset
	ApiextensionsClient *apiextensionsclient.Clientset

	KubeInformers          kubeinformers.SharedInformerFactory
	BindInformers          bindinformers.SharedInformerFactory
	ApiextensionsInformers apiextensionsinformers.SharedInformerFactory

	ServerAddr              string
	ProviderPollingInterval time.Duration
}

type Controller struct {
	ServiceBindingCtrl       GenericController
	ServiceBindingBundleCtrl GenericController
	// contains filtered or unexported fields
}

type GenericController interface {
	Start(ctx context.Context, numThreads int)
}

type Prepared struct {
	// contains filtered or unexported fields
}

type Resource = committer.Resource[*kubebindv1alpha2.APIServiceBindingSpec, *kubebindv1alpha2.APIServiceBindingStatus]

type Server struct {
	Config     *Config
	Controller *Controller
	// contains filtered or unexported fields
}