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 ¶
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 *zap.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 ¶
func (ap *Processor) ListenerNotificationHandlers() []event.NotificationHandlerInfo
ListenerNotificationHandlers for the 'event.Listener' event producer.
func (*Processor) ListenerNotificationParsers ¶
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.