generic

Documentation

Index

• Constants
• func NewGenericStatusSyncController(mgr ctrl.Manager, logName string, producer transport.Producer, ...) error
• type BundleCollectionEntry
  • func NewBundleCollectionEntry(transportBundleKey string, bundle statusbundle.Bundle, predicate func() bool) *BundleCollectionEntry
• type CreateObjectFunction
• type HybridSyncManager
  • func NewHybridSyncManager(log logr.Logger, completeStateBundleCollectionEntry *BundleCollectionEntry, ...) (*HybridSyncManager, error)
  • func (manager *HybridSyncManager) GetBundleCollectionEntry(syncMode bundle.BundleSyncMode) *BundleCollectionEntry
  • func (manager *HybridSyncManager) SetHybridModeCallBack(deltaCountSwitchFactor int, transportObj producer.Producer)

Constants

const REQUEUE_PERIOD = 5 * time.Second

Functions

func NewGenericStatusSyncController

func NewGenericStatusSyncController(mgr ctrl.Manager, logName string, producer transport.Producer,
	orderedBundleCollection []*BundleCollectionEntry, createObjFunc CreateObjectFunction, predicate predicate.Predicate,
	resolveSyncIntervalFunc config.ResolveSyncIntervalFunc,
) error

NewGenericStatusSyncController creates a new instance of genericStatusSyncController and adds it to the manager.

Types

type BundleCollectionEntry

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

BundleCollectionEntry holds information about a specific bundle.

func NewBundleCollectionEntry

func NewBundleCollectionEntry(transportBundleKey string, bundle statusbundle.Bundle,
	predicate func() bool,
) *BundleCollectionEntry

NewBundleCollectionEntry creates a new instance of BundleCollectionEntry.

type CreateObjectFunction

type CreateObjectFunction func() bundle.Object

CreateObjectFunction is a function for how to create an object that is stored inside the bundle.

type HybridSyncManager

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

hybridSyncManager manages two BundleCollectionEntry instances in application of hybrid-sync mode. won't get collected by the GC since callbacks are used.

func NewHybridSyncManager

func NewHybridSyncManager(log logr.Logger, completeStateBundleCollectionEntry *BundleCollectionEntry,
	deltaStateBundleCollectionEntry *BundleCollectionEntry,
) (*HybridSyncManager, error)

NewHybridSyncManager creates a manager that manages two BundleCollectionEntry instances that wrap a complete-state bundle and a delta-state bundle.

func (*HybridSyncManager) GetBundleCollectionEntry

func (manager *HybridSyncManager) GetBundleCollectionEntry(syncMode bundle.BundleSyncMode) *BundleCollectionEntry

func (*HybridSyncManager) SetHybridModeCallBack

func (manager *HybridSyncManager) SetHybridModeCallBack(deltaCountSwitchFactor int, transportObj producer.Producer)