util

Documentation

Index

• func GenExpectationGenericKey(clusterKey string, replicaType string, pl string) string
• func LoggerForGenericKind(obj metav1.Object, kind string) *log.Entry
• func OnDependentCreateFunc(...) func(event.CreateEvent) bool
• func OnDependentCreateFuncGeneric(...) func(event.CreateEvent) bool
• func OnDependentDeleteFunc(...) func(event.DeleteEvent) bool
• func OnDependentDeleteFuncGeneric(...) func(event.DeleteEvent) bool
• func OnDependentUpdateFunc(cc *ctrlcommon.ClusterController) func(updateEvent event.UpdateEvent) bool
• func OnDependentUpdateFuncGeneric(jc *ctrlcommon.ClusterController) func(updateEvent event.UpdateEvent) bool
• func SatisfiedExpectations(exp expectation.ControllerExpectationsInterface, clusterKey string, ...) bool
• type FakeWorkQueue
  • func (f *FakeWorkQueue) Add(item interface{})
  • func (f *FakeWorkQueue) AddAfter(item interface{}, duration time.Duration)
  • func (f *FakeWorkQueue) AddRateLimited(item interface{})
  • func (f *FakeWorkQueue) Done(item interface{})
  • func (f *FakeWorkQueue) Forget(item interface{})
  • func (f *FakeWorkQueue) Get() (item interface{}, shutdown bool)
  • func (f *FakeWorkQueue) Len() int
  • func (f *FakeWorkQueue) NumRequeues(item interface{}) int
  • func (f *FakeWorkQueue) ShutDown()
  • func (f *FakeWorkQueue) ShutDownWithDrain()
  • func (f *FakeWorkQueue) ShuttingDown() bool

Functions

func GenExpectationGenericKey

func GenExpectationGenericKey(clusterKey string, replicaType string, pl string) string

GenExpectationGenericKey generates an expectation key for {Kind} of a cluster

func LoggerForGenericKind

func LoggerForGenericKind(obj metav1.Object, kind string) *log.Entry

LoggerForGenericKind generates log entry for generic Kubernetes resource Kind

func OnDependentCreateFunc

func OnDependentCreateFunc(schemaReconcilers map[cluster_schema.ClusterSchema]common.ClusterSchemaReconciler) func(event.CreateEvent) bool

OnDependentCreateFunc modify expectations when dependent (pod/service) creation observed.

func OnDependentCreateFuncGeneric

func OnDependentCreateFuncGeneric(schemaReconcilers map[cluster_schema.ClusterSchema]common.ClusterSchemaReconciler) func(event.CreateEvent) bool

OnDependentCreateFuncGeneric modify expectations when dependent (pod/service) creation observed.

func OnDependentDeleteFunc

func OnDependentDeleteFunc(schemaReconcilers map[cluster_schema.ClusterSchema]common.ClusterSchemaReconciler) func(event.DeleteEvent) bool

OnDependentDeleteFunc modify expectations when dependent (pod/service) deletion observed.

func OnDependentDeleteFuncGeneric

func OnDependentDeleteFuncGeneric(schemaReconcilers map[cluster_schema.ClusterSchema]common.ClusterSchemaReconciler) func(event.DeleteEvent) bool

OnDependentDeleteFuncGeneric modify expectations when dependent (pod/service) deletion observed.

func OnDependentUpdateFunc

func OnDependentUpdateFunc(cc *ctrlcommon.ClusterController) func(updateEvent event.UpdateEvent) bool

OnDependentUpdateFunc modify expectations when dependent (pod/service) update observed.

func OnDependentUpdateFuncGeneric

func OnDependentUpdateFuncGeneric(jc *ctrlcommon.ClusterController) func(updateEvent event.UpdateEvent) bool

OnDependentUpdateFuncGeneric modify expectations when dependent (pod/service) update observed.

func SatisfiedExpectations

func SatisfiedExpectations(exp expectation.ControllerExpectationsInterface,
	clusterKey string,
	replicaTypes []kubeclusterorgv1alpha1.ReplicaType) bool

SatisfiedExpectations returns true if the required adds/dels for the given mxcluster have been observed. Add/del counts are established by the controller at sync time, and updated as controllees are observed by the controller manager.

Types

type FakeWorkQueue

type FakeWorkQueue struct{}

FakeWorkQueue implements RateLimitingInterface but actually does nothing.

func (*FakeWorkQueue) Add

func (f *FakeWorkQueue) Add(item interface{})

Add WorkQueue Add method

func (*FakeWorkQueue) AddAfter

func (f *FakeWorkQueue) AddAfter(item interface{}, duration time.Duration)

AddAfter WorkQueue AddAfter method

func (*FakeWorkQueue) AddRateLimited

func (f *FakeWorkQueue) AddRateLimited(item interface{})

AddRateLimited WorkQueue AddRateLimited method

func (*FakeWorkQueue) Done

func (f *FakeWorkQueue) Done(item interface{})

Done WorkQueue Done method

func (*FakeWorkQueue) Forget

func (f *FakeWorkQueue) Forget(item interface{})

Forget WorkQueue Forget method

func (*FakeWorkQueue) Get

func (f *FakeWorkQueue) Get() (item interface{}, shutdown bool)

Get WorkQueue Get method

func (*FakeWorkQueue) Len

func (f *FakeWorkQueue) Len() int

Len WorkQueue Len method

func (*FakeWorkQueue) NumRequeues

func (f *FakeWorkQueue) NumRequeues(item interface{}) int

NumRequeues WorkQueue NumRequeues method

func (*FakeWorkQueue) ShutDown

func (f *FakeWorkQueue) ShutDown()

ShutDown WorkQueue ShutDown method

func (*FakeWorkQueue) ShutDownWithDrain

func (f *FakeWorkQueue) ShutDownWithDrain()

ShutDown WorkQueue ShutDownWithDrain method

func (*FakeWorkQueue) ShuttingDown

func (f *FakeWorkQueue) ShuttingDown() bool

ShuttingDown WorkQueue ShuttingDown method