generic

Documentation

Index

• Constants
• func NewGenericStatusSyncController(mgr ctrl.Manager, logName string, producer producer.Producer, ...) error
• func NewHybridSyncManager(log logr.Logger, transportObj producer.Producer, ...) error
• type BundleCollectionEntry
  • func NewBundleCollectionEntry(transportBundleKey string, bundle bundle.Bundle, predicate func() bool) *BundleCollectionEntry
• type CreateObjectFunction

Constants

const REQUEUE_PERIOD = 5 * time.Second

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

type CreateObjectFunction func() bundle.Object

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