Documentation
¶
Index ¶
Constants ¶
View Source
const ProcessorPoolSize = 1
ProcessorPoolSize limits pool size for audit Processor. Processor manages audit tasks and fills queue for the next epoch. This process must not be interrupted by a new audit epoch, so we limit the pool size for the processor to one.
Variables ¶
View Source
var ErrInvalidIRNode = errors.New("node is not in the inner ring list")
Functions ¶
Types ¶
type EpochSource ¶ added in v0.29.0
type EpochSource interface {
// EpochCounter must return current epoch number.
EpochCounter() uint64
}
EpochSource is an interface that provides actual epoch information.
type Params ¶
type Params struct {
Log *logger.Logger
NetmapClient *nmClient.Client
ContainerClient *cntClient.Client
IRList Indexer
SGSource storagegroup.SGSource
RPCSearchTimeout time.Duration
TaskManager TaskManager
Reporter audit.Reporter
Key *ecdsa.PrivateKey
EpochSource EpochSource
}
Params of the processor constructor.
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
Processor of events related to data audit.
func (*Processor) ListenerNotificationHandlers ¶ added in v0.25.0
func (ap *Processor) ListenerNotificationHandlers() []event.NotificationHandlerInfo
ListenerNotificationHandlers for the 'event.Listener' event producer.
func (*Processor) ListenerNotificationParsers ¶ added in v0.25.0
func (ap *Processor) ListenerNotificationParsers() []event.NotificationParserInfo
ListenerNotificationParsers for the 'event.Listener' event producer.
func (*Processor) StartAuditHandler ¶
StartAuditHandler for the internal event producer.
func (*Processor) TimersHandlers ¶
func (ap *Processor) TimersHandlers() []event.NotificationHandlerInfo
TimersHandlers for the 'Timers' event producer.
type Start ¶
type Start struct {
// contains filtered or unexported fields
}
Start is an event to start a new round of data audit.
func NewAuditStartEvent ¶
Click to show internal directories.
Click to hide internal directories.