Versions in this module Expand all Collapse all v0 v0.3.1 Jan 24, 2022 Changes in this version + const ClustersPerPolicyPriority + const CompleteComplianceStatusPriority + const ControlInfoPriority + const DeltaComplianceStatusPriority + const LocalClustersPerPolicyPriority + const LocalCompleteComplianceStatusPriority + const LocalPlacementRulesSpecPriority + const LocalPolicySpecPriority + const ManagedClustersPriority + const MinimalComplianceStatusPriority + type BundleHandlerFunc func(context.Context, bundle.Bundle, db.StatusTransportBridgeDB) error + type BundleMetadata struct + type ConflationManager struct + func NewConflationManager(log logr.Logger, conflationUnitsReadyQueue *ConflationReadyQueue, ...) *ConflationManager + func (cm *ConflationManager) GetBundlesMetadata() []transport.BundleMetadata + func (cm *ConflationManager) Insert(bundle bundle.Bundle, metadata transport.BundleMetadata) + func (cm *ConflationManager) Register(registration *ConflationRegistration) + type ConflationReadyQueue struct + func NewConflationReadyQueue(statistics *statistics.Statistics) *ConflationReadyQueue + func (rq *ConflationReadyQueue) BlockingDequeue() *ConflationUnit + func (rq *ConflationReadyQueue) Enqueue(cu *ConflationUnit) + type ConflationRegistration struct + func NewConflationRegistration(priority conflationPriority, syncMode status.BundleSyncMode, bundleType string, ...) *ConflationRegistration + func (registration *ConflationRegistration) WithDependency(dependency *dependency.Dependency) *ConflationRegistration + type ConflationUnit struct + func (cu *ConflationUnit) GetNext() (bundle.Bundle, *BundleMetadata, BundleHandlerFunc, error) + func (cu *ConflationUnit) ReportResult(metadata *BundleMetadata, err error) + type ResultReporter interface + ReportResult func(metadata *BundleMetadata, err error)
Go to main page