Documentation ¶
Index ¶
Constants ¶
View Source
const ProcessorPoolSize = 1
ProcessorPoolSize limits pool size for audit Processor. Processor manages audit tasks and fills queue for next epoch. This process must not be interrupted by new audit epoch, so we limit pool size for processor to one.
Variables ¶
View Source
var ErrInvalidIRNode = errors.New("node is not in the inner ring list")
Functions ¶
Types ¶
type NeoFSClientCache ¶
type NeoFSClientCache interface {
Get(network.AddressGroup) (SDKClient.Client, error)
}
NeoFSClientCache is an interface for cache of neofs RPC clients
type Params ¶
type Params struct { Log *zap.Logger NetmapClient *wrapNetmap.Wrapper ContainerClient *wrapContainer.Wrapper IRList Indexer ClientCache NeoFSClientCache RPCSearchTimeout time.Duration TaskManager TaskManager Reporter audit.Reporter Key *ecdsa.PrivateKey }
Params of the processor constructor.
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
Processor of events related with 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 a event to start new round of data audit.
func NewAuditStartEvent ¶
Click to show internal directories.
Click to hide internal directories.