registry

Documentation

Index

• type Builder
• type Descriptor
• type DescriptorList
  • func (dl DescriptorList) AllQueuesEmpty() bool
• type ForInput
• type ForOption
• type ReconcilerFactory
• type SkrRegistry
  • func New(scheme *runtime.Scheme) SkrRegistry
• type Watch
• type WatchesInput
• type WatchesOption

Types

type Builder

type Builder interface {
	WithFactory(f ReconcilerFactory) Builder

	Named(name string) Builder
	For(object client.Object, opts ...ForOption) Builder
	Watches(object client.Object, eventHandler handler.EventHandler, opts ...WatchesOption) Builder
	Complete() error
}

type Descriptor

type Descriptor struct {
	Name              string
	GVK               schema.GroupVersionKind
	Watches           []Watch
	ReconcilerFactory ReconcilerFactory
}

type DescriptorList

type DescriptorList []Descriptor

func (DescriptorList) AllQueuesEmpty

func (dl DescriptorList) AllQueuesEmpty() bool

type ForInput

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

type ForOption

type ForOption interface {
	// ApplyToFor applies this configuration to the given for input.
	ApplyToFor(*ForInput)
}

type ReconcilerFactory

type ReconcilerFactory interface {
	New(kymaRef klog.ObjectRef, kcpCluster cluster.Cluster, skrCluster cluster.Cluster) reconcile.Reconciler
}

type SkrRegistry

type SkrRegistry interface {
	GetDescriptors(mngr manager.SkrManager) DescriptorList
	Register() Builder
}

func New

func New(scheme *runtime.Scheme) SkrRegistry

type Watch

type Watch struct {
	Name         string
	Src          source.Source
	EventHandler handler.EventHandler
	Predicates   []predicate.Predicate
}

type WatchesInput

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

type WatchesOption

type WatchesOption interface {
	// ApplyToWatches applies this configuration to the given watches options.
	ApplyToWatches(*WatchesInput)
}