konnector

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 29, 2022 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CommitFunc

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

type Config added in v0.0.11

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

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

func NewConfig added in v0.0.11

func NewConfig(options *options.CompletedOptions) (*Config, error)

type Controller added in v0.0.11

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

Controller is the top-level Controller watching ServiceBindings and service provider credentials, and then starts APIServiceBinding controllers dynamically.

func New

func New(
	consumerConfig *rest.Config,
	serviceBindingInformer bindinformers.APIServiceBindingInformer,
	secretInformer coreinformers.SecretInformer,
	namespaceInformer coreinformers.NamespaceInformer,
	crdInformer crdinformers.CustomResourceDefinitionInformer,
) (*Controller, error)

New returns a konnector controller.

func (*Controller) Start added in v0.0.11

func (k *Controller) Start(ctx context.Context, numThreads int)

Start starts the konnector. It does block.

type GenericController

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

type Prepared added in v0.0.16

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

func (*Prepared) OptionallyStartInformers added in v0.0.16

func (s *Prepared) OptionallyStartInformers(ctx context.Context)

func (Prepared) Run added in v0.0.16

func (s Prepared) Run(ctx context.Context) error

type Server added in v0.0.11

type Server struct {
	Config     *Config
	Controller *Controller
}

func NewServer added in v0.0.11

func NewServer(config *Config) (*Server, error)

func (*Server) PrepareRun added in v0.0.16

func (s *Server) PrepareRun(ctx context.Context) (Prepared, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL