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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GenExpectationGenericKey ¶
GenExpectationGenericKey generates an expectation key for {Kind} of a cluster
func LoggerForGenericKind ¶
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) 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) 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
Source Files