wrapper

Documentation

Index

• Variables
• type Client
• type Epoch
• type Wrapper
  • func New(c *Client) (*Wrapper, error)
  • func (w *Wrapper) AddPeer(nodeInfo *netmap.NodeInfo) error
  • func (w *Wrapper) Epoch() (uint64, error)
  • func (w Wrapper) GetNetMap(diff uint64) (*netmap.Netmap, error)
  • func (w Wrapper) GetNetMapByEpoch(epoch uint64) (*netmap.Netmap, error)
  • func (w *Wrapper) InnerRingKeys() ([][]byte, error)
  • func (w *Wrapper) MaxObjectSize() (uint64, error)
  • func (w *Wrapper) NewEpoch(e Epoch) error
  • func (w *Wrapper) UpdatePeerState(key []byte, state netmap.NodeState) error

Variables

var ErrNilWrapper = errors.New("netmap contract client wrapper is nil")

ErrNilWrapper is returned by functions that expect a non-nil Wrapper pointer, but received nil.

Types

type Client

type Client = netmap.Client

Client represents the Netmap contract client.

It is a type alias of github.com/nspcc-dev/neofs-node/pkg/morph/client/netmap.Client.

type Epoch

type Epoch struct{}

Epoch represents the NeoFS epoch. FIXME: correct the definition.

type Wrapper

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

Wrapper is a wrapper over netmap contract client which implements:

• network map storage;
• tool for peer state updating.

Working wrapper must be created via constructor New. Using the Wrapper that has been created with new(Wrapper) expression (or just declaring a Wrapper variable) is unsafe and can lead to panic.

func New

func New(c *Client) (*Wrapper, error)

New creates, initializes and returns the Wrapper instance.

If Client is nil, netmap.ErrNilClient is returned.

func (*Wrapper) AddPeer

func (w *Wrapper) AddPeer(nodeInfo *netmap.NodeInfo) error

AddPeer registers peer in NeoFS network through Netmap contract call.

func (*Wrapper) Epoch

func (w *Wrapper) Epoch() (uint64, error)

Epoch receives number of current NeoFS epoch through the Netmap contract call.

func (Wrapper) GetNetMap

func (w Wrapper) GetNetMap(diff uint64) (*netmap.Netmap, error)

GetNetMap receives information list about storage nodes through the Netmap contract call, composes network map from them and returns it. With diff == 0 returns current network map, else return snapshot of previous network map.

func (Wrapper) GetNetMapByEpoch

func (w Wrapper) GetNetMapByEpoch(epoch uint64) (*netmap.Netmap, error)

GetNetMapByEpoch receives information list about storage nodes through the Netmap contract call, composes network map from them and returns it. Returns snapshot of the specified epoch number.

func (*Wrapper) InnerRingKeys

func (w *Wrapper) InnerRingKeys() ([][]byte, error)

InnerRingKeys receives public key list of inner ring nodes through Netmap contract call and returns it.

func (*Wrapper) MaxObjectSize

func (w *Wrapper) MaxObjectSize() (uint64, error)

MaxObjectSize receives max object size configuration value through the Netmap contract call.

func (*Wrapper) NewEpoch

func (w *Wrapper) NewEpoch(e Epoch) error

NewEpoch updates NeoFS epoch number through Netmap contract call.

func (*Wrapper) UpdatePeerState

func (w *Wrapper) UpdatePeerState(key []byte, state netmap.NodeState) error

UpdatePeerState changes peer status through Netmap contract call.