mirror

Documentation

Index

• type Informer
  • func SetupWithManager(ctx context.Context, mgr ctrl.Manager, namespace string, lbs labels.Selector) (*Informer, error)
  • func (i *Informer) Start(ctx context.Context) error
• type MirrorHandler
  • func (h *MirrorHandler) OnAdd(obj interface{}, init bool)
  • func (h *MirrorHandler) OnDelete(obj interface{})
  • func (h *MirrorHandler) OnUpdate(oldObj, newObj interface{})
• type PodHandler
  • func (ph *PodHandler) OnAdd(obj interface{}, isInInitialList bool)
  • func (ph *PodHandler) OnDelete(obj interface{})
  • func (ph *PodHandler) OnUpdate(oldObj, newObj interface{})
• type SecretHandler
  • func (h *SecretHandler) OnAdd(obj interface{}, init bool)
  • func (h *SecretHandler) OnDelete(obj interface{})
  • func (h *SecretHandler) OnUpdate(oldObj, newObj interface{})

Types

type Informer

type Informer struct {
	ServerRing *hashring.Ring
	Keyring    *credentials.Keyring
	Client     client.Client
	Mirrors    map[client.ObjectKey]*stvziov1.Mirror
	Namespace  string
	Labels     labels.Selector
	cache.Cache
}

func SetupWithManager

func SetupWithManager(ctx context.Context, mgr ctrl.Manager, namespace string, lbs labels.Selector) (*Informer, error)

func (*Informer) Start

func (i *Informer) Start(ctx context.Context) error

type MirrorHandler

type MirrorHandler struct {
	Keyring *credentials.Keyring
	Mirrors map[client.ObjectKey]*stvziov1.Mirror
}

func (*MirrorHandler) OnAdd

func (h *MirrorHandler) OnAdd(obj interface{}, init bool)

func (*MirrorHandler) OnDelete

func (h *MirrorHandler) OnDelete(obj interface{})

func (*MirrorHandler) OnUpdate

func (h *MirrorHandler) OnUpdate(oldObj, newObj interface{})

type PodHandler

type PodHandler struct {
	Log        logr.Logger
	ServerRing *hashring.Ring
	Namespace  string
	Labels     labels.Selector
}

func (*PodHandler) OnAdd

func (ph *PodHandler) OnAdd(obj interface{}, isInInitialList bool)

func (*PodHandler) OnDelete

func (ph *PodHandler) OnDelete(obj interface{})

func (*PodHandler) OnUpdate

func (ph *PodHandler) OnUpdate(oldObj, newObj interface{})

type SecretHandler

type SecretHandler struct {
	ManagedSecrets map[types.NamespacedName]bool
	Keyring        *credentials.Keyring
}

func (*SecretHandler) OnAdd

func (h *SecretHandler) OnAdd(obj interface{}, init bool)

func (*SecretHandler) OnDelete

func (h *SecretHandler) OnDelete(obj interface{})

func (*SecretHandler) OnUpdate

func (h *SecretHandler) OnUpdate(oldObj, newObj interface{})