options

Documentation

Overview

Package options implements the options to configure the reflection.

Index

• type Keyer
• type NamespacedOpts
  • func NewNamespaced() *NamespacedOpts
  • func (ro *NamespacedOpts) WithEventBroadcaster(broadcaster record.EventBroadcaster) *NamespacedOpts
  • func (ro *NamespacedOpts) WithHandlerFactory(handler func(Keyer) cache.ResourceEventHandler) *NamespacedOpts
  • func (ro *NamespacedOpts) WithLiqoLocal(client liqoclient.Interface, factory liqoinformers.SharedInformerFactory) *NamespacedOpts
  • func (ro *NamespacedOpts) WithLiqoRemote(client liqoclient.Interface, factory liqoinformers.SharedInformerFactory) *NamespacedOpts
  • func (ro *NamespacedOpts) WithLocal(namespace string, client kubernetes.Interface, ...) *NamespacedOpts
  • func (ro *NamespacedOpts) WithReadinessFunc(ready func() bool) *NamespacedOpts
  • func (ro *NamespacedOpts) WithRemote(namespace string, client kubernetes.Interface, ...) *NamespacedOpts
• type ReflectorOpts
  • func New(client kubernetes.Interface, podInformer corev1informers.PodInformer) *ReflectorOpts
  • func (ro *ReflectorOpts) WithEventBroadcaster(broadcaster record.EventBroadcaster) *ReflectorOpts
  • func (ro *ReflectorOpts) WithHandlerFactory(handler func(Keyer) cache.ResourceEventHandler) *ReflectorOpts
  • func (ro *ReflectorOpts) WithReadinessFunc(ready func() bool) *ReflectorOpts

Types

type Keyer

type Keyer func(metadata metav1.Object) types.NamespacedName

Keyer retrieves a NamespacedName referring to the reconciliation target from the object metadata.

type NamespacedOpts

type NamespacedOpts struct {
	LocalNamespace  string
	RemoteNamespace string

	LocalClient      kubernetes.Interface
	RemoteClient     kubernetes.Interface
	LocalLiqoClient  liqoclient.Interface
	RemoteLiqoClient liqoclient.Interface

	LocalFactory      informers.SharedInformerFactory
	RemoteFactory     informers.SharedInformerFactory
	LocalLiqoFactory  liqoinformers.SharedInformerFactory
	RemoteLiqoFactory liqoinformers.SharedInformerFactory

	EventBroadcaster record.EventBroadcaster

	Ready          func() bool
	HandlerFactory func(Keyer) cache.ResourceEventHandler
}

NamespacedOpts is a structure grouping the parameters to start a NamespacedReflector.

func NewNamespaced

func NewNamespaced() *NamespacedOpts

NewNamespaced returns a new NamespacedOpts object.

func (*NamespacedOpts) WithEventBroadcaster

func (ro *NamespacedOpts) WithEventBroadcaster(broadcaster record.EventBroadcaster) *NamespacedOpts

WithEventBroadcaster configures the event broadcaster of the NamespacedOpts.

func (*NamespacedOpts) WithHandlerFactory

func (ro *NamespacedOpts) WithHandlerFactory(handler func(Keyer) cache.ResourceEventHandler) *NamespacedOpts

WithHandlerFactory configures the handler factory of the NamespacedOpts.

func (*NamespacedOpts) WithLiqoLocal

func (ro *NamespacedOpts) WithLiqoLocal(client liqoclient.Interface, factory liqoinformers.SharedInformerFactory) *NamespacedOpts

WithLiqoLocal configures the local liqo client and informer factory parameters of the NamespacedOpts.

func (*NamespacedOpts) WithLiqoRemote

func (ro *NamespacedOpts) WithLiqoRemote(client liqoclient.Interface, factory liqoinformers.SharedInformerFactory) *NamespacedOpts

WithLiqoRemote configures the remote liqo client and informer factory parameters of the NamespacedOpts.

func (*NamespacedOpts) WithLocal

func (ro *NamespacedOpts) WithLocal(namespace string, client kubernetes.Interface, factory informers.SharedInformerFactory) *NamespacedOpts

WithLocal configures the local parameters of the NamespacedOpts.

func (*NamespacedOpts) WithReadinessFunc

func (ro *NamespacedOpts) WithReadinessFunc(ready func() bool) *NamespacedOpts

WithReadinessFunc configures the readiness function of the NamespacedOpts.

func (*NamespacedOpts) WithRemote

func (ro *NamespacedOpts) WithRemote(namespace string, client kubernetes.Interface, factory informers.SharedInformerFactory) *NamespacedOpts

WithRemote configures the remote parameters of the NamespacedOpts.

type ReflectorOpts

type ReflectorOpts struct {
	LocalClient      kubernetes.Interface
	LocalPodInformer corev1informers.PodInformer
	EventBroadcaster record.EventBroadcaster

	HandlerFactory func(Keyer) cache.ResourceEventHandler

	Ready func() bool
}

ReflectorOpts is a structure grouping the parameters to start a Reflector.

func New

func New(client kubernetes.Interface, podInformer corev1informers.PodInformer) *ReflectorOpts

New returns a new ReflectorOpts object.

func (*ReflectorOpts) WithEventBroadcaster

func (ro *ReflectorOpts) WithEventBroadcaster(broadcaster record.EventBroadcaster) *ReflectorOpts

WithEventBroadcaster configures the event broadcaster of the NamespacedOpts.

func (*ReflectorOpts) WithHandlerFactory

func (ro *ReflectorOpts) WithHandlerFactory(handler func(Keyer) cache.ResourceEventHandler) *ReflectorOpts

WithHandlerFactory configures the handler factory of the ReflectorOpts.

func (*ReflectorOpts) WithReadinessFunc

func (ro *ReflectorOpts) WithReadinessFunc(ready func() bool) *ReflectorOpts

WithReadinessFunc configures the readiness function of the ReflectorOpts.