Documentation
¶
Index ¶
- type AlphabetState
- type NetworkState
- type Params
- type Processor
- func (cp *Processor) AddContainerStructs(ctx context.Context) error
- func (cp *Processor) ListenerNotaryHandlers() []event.NotaryHandlerInfo
- func (cp *Processor) ListenerNotaryParsers() []event.NotaryParserInfo
- func (cp *Processor) ListenerNotificationHandlers() []event.NotificationHandlerInfo
- func (cp *Processor) ListenerNotificationParsers() []event.NotificationParserInfo
- func (cp *Processor) TimersHandlers() []event.NotificationHandlerInfo
- type TimeProvider
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AlphabetState ¶ added in v0.18.0
type AlphabetState interface {
IsAlphabet() bool
}
AlphabetState is a callback interface for inner ring global state.
type NetworkState ¶ added in v0.21.1
type NetworkState interface {
// Epoch must return the number of the current epoch.
//
// Must return any error encountered
// which did not allow reading the value.
Epoch() (uint64, error)
// HomomorphicHashDisabled must return boolean that
// represents homomorphic network state:
// * true if hashing is disabled;
// * false if hashing is enabled.
//
// which did not allow reading the value.
HomomorphicHashDisabled() (bool, error)
// NetMap must return actual network map.
NetMap() (*netmap.NetMap, error)
// GetEpochBlock returns FS chain height when given NeoFS epoch was ticked.
GetEpochBlock(epoch uint64) (uint32, error)
// GetEpochBlockByTime returns FS chain height of block index when the latest epoch that
// started not later than the provided block time came.
GetEpochBlockByTime(t uint32) (uint32, error)
}
NetworkState is an interface of a component that provides access to network state.
type Params ¶
type Params struct {
Log *zap.Logger
PoolSize int
AlphabetState AlphabetState
ContainerClient *container.Client
NetworkState NetworkState
MetaEnabled bool
AllowEC bool
ChainTime TimeProvider
}
Params of the processor constructor.
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
Processor of events produced by container contract in FS chain.
func (*Processor) AddContainerStructs ¶ added in v0.51.0
AddContainerStructs iteratively calls the contract to add structured storage items for containers.
func (*Processor) ListenerNotaryHandlers ¶ added in v0.25.0
func (cp *Processor) ListenerNotaryHandlers() []event.NotaryHandlerInfo
ListenerNotaryHandlers for the 'event.Listener' notary event producer.
func (*Processor) ListenerNotaryParsers ¶ added in v0.25.0
func (cp *Processor) ListenerNotaryParsers() []event.NotaryParserInfo
ListenerNotaryParsers for the 'event.Listener' notary event producer.
func (*Processor) ListenerNotificationHandlers ¶ added in v0.25.0
func (cp *Processor) ListenerNotificationHandlers() []event.NotificationHandlerInfo
ListenerNotificationHandlers for the 'event.Listener' event producer.
func (*Processor) ListenerNotificationParsers ¶ added in v0.25.0
func (cp *Processor) ListenerNotificationParsers() []event.NotificationParserInfo
ListenerNotificationParsers for the 'event.Listener' event producer.
func (*Processor) TimersHandlers ¶
func (cp *Processor) TimersHandlers() []event.NotificationHandlerInfo
TimersHandlers for the 'Timers' event producer.
type TimeProvider ¶ added in v0.51.0
TimeProvider supplies current FS chain time without calling the chain. It should be updated from block header subscriptions and return time based on the latest observed header timestamp.