Documentation ¶
Index ¶
- type Manager
- type Option
- func WithContainerCommunicator(cnrCom auditor.ContainerCommunicator) Option
- func WithLogger(l *logger.Logger) Option
- func WithMaxPDPSleepInterval(dur time.Duration) Option
- func WithPDPWorkerPoolGenerator(f func() (util.WorkerPool, error)) Option
- func WithPoRWorkerPoolGenerator(f func() (util.WorkerPool, error)) Option
- func WithQueueCapacity(cap uint32) Option
- func WithWorkerPool(p util.WorkerPool) Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager represents an entity performing data audit tasks.
func (*Manager) Listen ¶
Listen starts the process of processing tasks from the queue.
The listener is terminated by context.
type Option ¶
type Option func(*cfg)
Option is a Manager's constructor option.
func WithContainerCommunicator ¶
func WithContainerCommunicator(cnrCom auditor.ContainerCommunicator) Option
WithContainerCommunicator returns option to set component of communication with container nodes.
func WithLogger ¶
WithLogger returns option to specify Manager's logger.
func WithMaxPDPSleepInterval ¶
WithMaxPDPSleepInterval returns option to set maximum sleep interval between range hash requests as part of PDP check.
func WithPDPWorkerPoolGenerator ¶
func WithPDPWorkerPoolGenerator(f func() (util.WorkerPool, error)) Option
WithPDPWorkerPoolGenerator returns option to set worker pool for PDP pairs processing.
func WithPoRWorkerPoolGenerator ¶
func WithPoRWorkerPoolGenerator(f func() (util.WorkerPool, error)) Option
WithPoRWorkerPoolGenerator returns option to set worker pool for PoR SG processing.
func WithQueueCapacity ¶
WithQueueCapacity returns option to set task queue capacity.
func WithWorkerPool ¶
func WithWorkerPool(p util.WorkerPool) Option
WithWorkerPool returns option to set worker pool for task execution.