centralconnection

Documentation

Index

• func InitCentralConnectionController(mgr manager.Manager, appName string, minimalConnectionSyncPeriod time.Duration, ...) error
• type Client
  • func NewCentralConnectionClient(manager Manager) Client
• type Controller
  • func (c *Controller) Reconcile(request reconcile.Request) (reconcile.Result, error)
• type Manager
• type ResourceClient

Functions

func InitCentralConnectionController

func InitCentralConnectionController(
	mgr manager.Manager,
	appName string,
	minimalConnectionSyncPeriod time.Duration,
	certPreserver certificates.Preserver,
	certProvider certificates.Provider,
	connectionClientProvider connectorservice.EstablishedConnectionClientProvider) error

Types

type Client

type Client interface {
	Upsert(name string, spec v1alpha1.CentralConnectionSpec) (*v1alpha1.CentralConnection, error)
}

func NewCentralConnectionClient

func NewCentralConnectionClient(manager Manager) Client

type Controller

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

func (*Controller) Reconcile

func (c *Controller) Reconcile(request reconcile.Request) (reconcile.Result, error)

type Manager

type Manager interface {
	Create(*v1alpha1.CentralConnection) (*v1alpha1.CentralConnection, error)
	Update(*v1alpha1.CentralConnection) (*v1alpha1.CentralConnection, error)
	Get(name string, options v1.GetOptions) (*v1alpha1.CentralConnection, error)
}

type ResourceClient

type ResourceClient interface {
	Get(ctx context.Context, key client.ObjectKey, obj runtime.Object) error
	Update(ctx context.Context, obj runtime.Object) error
}