Documentation
¶
Index ¶
Constants ¶
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 ¶
var ErrInvalidIRNode = errors.New("node is not in the inner ring list")
Functions ¶
Types ¶
type Params ¶
type Params struct {
Log *zap.Logger
NetmapClient *nmClient.Client
ContainerClient *cntClient.Client
IRList Indexer
SGSource SGSource
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 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 SGSource ¶ added in v0.26.1
type SGSource interface {
// Lists storage group objects in the container. Formed list must be written to destination.
//
// Must return any error encountered which did not allow to form the list.
ListSG(*SearchSGDst, SearchSGPrm) error
}
SGSource is a storage group information source interface.
type SearchSGDst ¶ added in v0.26.1
type SearchSGDst struct {
// contains filtered or unexported fields
}
SearchSGDst groups the target values which Processor expects from SG searching to process.
func (*SearchSGDst) WriteIDList ¶ added in v0.26.1
func (x *SearchSGDst) WriteIDList(ids []oid.ID)
WriteIDList writes a list of identifiers of storage group objects stored in the container.
type SearchSGPrm ¶ added in v0.26.1
type SearchSGPrm struct {
// contains filtered or unexported fields
}
SearchSGPrm groups the parameters which are formed by Processor to search the storage group objects.
func (SearchSGPrm) CID ¶ added in v0.26.1
func (x SearchSGPrm) CID() cid.ID
CID returns the identifier of the container to search SG in.
func (SearchSGPrm) Context ¶ added in v0.26.1
func (x SearchSGPrm) Context() context.Context
Context returns context to use for network communication.
func (SearchSGPrm) NodeInfo ¶ added in v0.26.1
func (x SearchSGPrm) NodeInfo() client.NodeInfo
NodeInfo returns information about a storage node to communicate with.
type Start ¶
type Start struct {
// contains filtered or unexported fields
}
Start is an event to start a new round of data audit.
Source Files