container

Documentation

Index

• type AlphabetState
• type NetworkState
• type Params
• type Processor
  • func New(p *Params) (*Processor, 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

Types

type AlphabetState

type AlphabetState interface {
	IsAlphabet() bool
}

AlphabetState is a callback interface for inner ring global state.

type NetworkState

type NetworkState interface {
	// Epoch must return number of the current epoch.
	//
	// Must return any error encountered
	// which did not allow reading the value.
	Epoch() (uint64, 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 *wrapper.Wrapper
	NeoFSIDClient   *neofsid.ClientWrapper
	SubnetClient    *morphsubnet.Client
	NetworkState    NetworkState
	NotaryDisabled  bool
}

Params of the processor constructor.

type Processor

type Processor struct {
	// contains filtered or unexported fields
}

Processor of events produced by container contract in morph chain.

func New

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

New creates container contract processor instance.

func (*Processor) ListenerNotaryHandlers

func (cp *Processor) ListenerNotaryHandlers() []event.NotaryHandlerInfo

ListenerNotaryHandlers for the 'event.Listener' notary event producer.

func (*Processor) ListenerNotaryParsers

func (cp *Processor) ListenerNotaryParsers() []event.NotaryParserInfo

ListenerNotaryParsers for the 'event.Listener' notary event producer.

func (*Processor) ListenerNotificationHandlers

func (cp *Processor) ListenerNotificationHandlers() []event.NotificationHandlerInfo

ListenerNotificationHandlers for the 'event.Listener' event producer.

func (*Processor) ListenerNotificationParsers

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.