container

package
v0.51.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 4, 2026 License: GPL-3.0 Imports: 31 Imported by: 0

Documentation

Index

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 New

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

New creates a container contract processor instance.

func (*Processor) AddContainerStructs added in v0.51.0

func (cp *Processor) AddContainerStructs(ctx context.Context) error

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

type TimeProvider interface {
	Now() time.Time
}

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL