meta

Documentation

Index

• type ContainerLister
• type Meta
  • func New(p Parameters) (*Meta, error)
  • func (m *Meta) Reload(p Parameters) error
  • func (m *Meta) Run(ctx context.Context) error
• type Parameters

Types

type ContainerLister

type ContainerLister interface {
	// List returns node's containers that support chain-based meta data and
	// any error that does not allow listing.
	List() (map[cid.ID]struct{}, error)
	// IsMineWithMeta checks if the given CID has meta enabled and current
	// node belongs to it.
	IsMineWithMeta(cid.ID) (bool, error)
}

ContainerLister is a source of actual containers current node belongs to.

type Meta

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

Meta handles object meta information received from FS chain and object storages. Chain information is stored in Merkle-Patricia Tries. Full objects index is built and stored as a simple KV storage.

func New

func New(p Parameters) (*Meta, error)

New makes Meta.

func (*Meta) Reload

func (m *Meta) Reload(p Parameters) error

Reload updates service in runtime. Currently supported fields:

• endpoints

func (*Meta) Run

func (m *Meta) Run(ctx context.Context) error

Run starts notification handling. Must be called only on instances created with New. Blocked until context is done.

type Parameters

type Parameters struct {
	Logger          *zap.Logger
	ContainerLister ContainerLister
	Timeout         time.Duration
	ContainerHash   util.Uint160
	NetmapHash      util.Uint160
	RootPath        string

	// fields that support runtime reload
	NeoEnpoints []string
}

Parameters groups arguments for New call.