Documentation
¶
Index ¶
Constants ¶
View Source
const ProcessorPoolSize = 1
AuditProcessor 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 ¶
NeoFSClientCache is an interface for cache of neofs RPC clients
type Params ¶
type Params struct {
Log *zap.Logger
NetmapContract util.Uint160
ContainerContract util.Uint160
AuditContract util.Uint160
MorphClient *client.Client
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) ListenerHandlers ¶
func (ap *Processor) ListenerHandlers() []event.HandlerInfo
ListenerHandlers for the 'event.Listener' event producer.
func (*Processor) ListenerParsers ¶
func (ap *Processor) ListenerParsers() []event.ParserInfo
ListenerParsers for the 'event.Listener' event producer.
func (*Processor) StartAuditHandler ¶
StartAuditHandler for the internal event producer.
func (*Processor) TimersHandlers ¶
func (ap *Processor) TimersHandlers() []event.HandlerInfo
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.