alphabet

Documentation

Index

• type Contracts
• type Indexer
• type Params
• type Processor
  • func New(p *Params) (*Processor, error)
  • func (ap *Processor) HandleGasEmission(ctx context.Context, 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()

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(context.Context) 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 New

func New(p *Params) (*Processor, error)

New creates a frostfs mainnet contract processor instance.

func (*Processor) HandleGasEmission

func (ap *Processor) HandleGasEmission(ctx context.Context, ev event.Event)

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

func (ap *Processor) SetParsedWallets(parsedWallets []util.Uint160)

func (*Processor) WaitPoolRunning

func (ap *Processor) WaitPoolRunning()

WaitPoolRunning waits while pool has running tasks For use in test only.