syncers

Documentation

Index

• Constants
• func NewGenericDispatcher(consumer transport.Consumer, config config.AgentConfig) *genericDispatcher
• func NewGenericSyncer(workerPool *workers.WorkerPool, config *config.AgentConfig) *genericBundleSyncer
• func NewManagedClusterLabelSyncer(workers *workers.WorkerPool) *managedClusterLabelsBundleSyncer
• type Dispatcher
• type Syncer

Constants

const GenericMessageKey = "Generic"

Functions

func NewGenericDispatcher

func NewGenericDispatcher(consumer transport.Consumer, config config.AgentConfig) *genericDispatcher

func NewGenericSyncer

func NewGenericSyncer(workerPool *workers.WorkerPool, config *config.AgentConfig) *genericBundleSyncer

func NewManagedClusterLabelSyncer

func NewManagedClusterLabelSyncer(workers *workers.WorkerPool) *managedClusterLabelsBundleSyncer

Types

type Dispatcher

type Dispatcher interface {
	Start(ctx context.Context) error
	RegisterSyncer(messageID string, syncer Syncer)
}

type Syncer

type Syncer interface {
	Sync(payload []byte) error
}