Documentation
¶
Index ¶
- type Contracts
- type Indexer
- type Params
- type Processor
- func (ap *Processor) HandleGasEmission(ev event.Event)
- func (ap *Processor) ListenerNotaryHandlers() []event.NotaryHandlerInfo
- func (ap *Processor) ListenerNotaryParsers() []event.NotaryParserInfo
- func (ap *Processor) ListenerNotificationHandlers() []event.NotificationHandlerInfo
- func (ap *Processor) ListenerNotificationParsers() []event.NotificationParserInfo
- func (ap *Processor) SetParsedWallets(parsedWallets []util.Uint160)
- func (ap *Processor) WaitPoolRunning()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Contracts ¶
type Contracts interface {
// GetByIndex must return the address of the
// alphabet contract by index of the glagolitic
// letter (e.g 0 for Az, 40 for Izhitsa).
//
// Must return false if the index does not
// match any alphabet contract.
GetByIndex(int) (util.Uint160, bool)
}
Contracts is an interface of the storage of the alphabet contract addresses.
type Indexer ¶
type Indexer interface {
AlphabetIndex() int
}
Indexer is a callback interface for inner ring global state.
type Params ¶
type Params struct {
ParsedWallets []util.Uint160
Log *logger.Logger
Metrics metrics.Register
PoolSize int
AlphabetContracts Contracts
NetmapClient netmapClient
MorphClient morphClient
IRList Indexer
StorageEmission uint64
}
Params of the processor constructor.
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
Processor of events produced for alphabet contracts in the sidechain.
func (*Processor) HandleGasEmission ¶
func (*Processor) ListenerNotaryHandlers ¶
func (ap *Processor) ListenerNotaryHandlers() []event.NotaryHandlerInfo
ListenerNotaryHandlers for the 'event.Listener' event producer.
func (*Processor) ListenerNotaryParsers ¶
func (ap *Processor) ListenerNotaryParsers() []event.NotaryParserInfo
ListenerNotaryParsers for the 'event.Listener' event producer.
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) SetParsedWallets ¶ added in v0.37.0
func (*Processor) WaitPoolRunning ¶ added in v0.37.0
func (ap *Processor) WaitPoolRunning()
WaitPoolRunning waits while pool has running tasks For use in test only.
Source Files
Click to show internal directories.
Click to hide internal directories.