Documentation
¶
Index ¶
Constants ¶
View Source
const REQUEUE_PERIOD = 5 * time.Second
Variables ¶
This section is empty.
Functions ¶
func NewGenericStatusSyncController ¶
func NewGenericStatusSyncController(mgr ctrl.Manager, logName string, producer producer.Producer, orderedBundleCollection []*BundleCollectionEntry, createObjFunc CreateObjectFunction, predicate predicate.Predicate, resolveSyncIntervalFunc syncintervals.ResolveSyncIntervalFunc, ) error
NewGenericStatusSyncController creates a new instance of genericStatusSyncController and adds it to the manager.
func NewHybridSyncManager ¶
func NewHybridSyncManager(log logr.Logger, transportObj producer.Producer, completeStateBundleCollectionEntry *BundleCollectionEntry, deltaStateBundleCollectionEntry *BundleCollectionEntry, sentDeltaCountSwitchFactor int, ) error
NewHybridSyncManager creates a manager that manages two BundleCollectionEntry instances that wrap a complete-state bundle and a delta-state bundle.
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 bundle.Bundle, predicate func() bool, ) *BundleCollectionEntry
NewBundleCollectionEntry creates a new instance of BundleCollectionEntry.
type CreateObjectFunction ¶
CreateObjectFunction is a function for how to create an object that is stored inside the bundle.
Source Files
Click to show internal directories.
Click to hide internal directories.