register

Documentation

Index

• func NewWorker(agentIDProvide id.Provide, client identityapi.RegisterClient, ...) *worker
• type WorkerConfig

Functions

func NewWorker

func NewWorker(
	agentIDProvide id.Provide,
	client identityapi.RegisterClient,
	retryBo *backoff.Backoff,
	reqsToRegisterQueue <-chan fwrequest.EntityFwRequest,
	reqsRegisteredQueue chan<- fwrequest.EntityFwRequest,
	config WorkerConfig,
	measureFn instrumentation.Measure,
) *worker

Types

type WorkerConfig

type WorkerConfig struct {
	MaxBatchSize      int
	MaxBatchSizeBytes int
	MaxBatchDuration  time.Duration
	MaxRetryBo        time.Duration
	VerboseLogLevel   int
}

WorkerConfig will provide all configuration parameters for a register worker.