util

Documentation

Index

• func IterateAllSplitLeaves(r HeadReceiver, addr *objectSDK.Address, h func(*object.Object)) error
• func IterateSplitLeaves(r HeadReceiver, addr *objectSDK.Address, h func(*object.Object) bool) error
• func LogServiceError(l *logger.Logger, req string, node network.AddressGroup, err error)
• func LogWorkerPoolError(l *logger.Logger, req string, err error)
• func NewLocalPlacement(b placement.Builder, s netmap.AnnouncedKeys) placement.Builder
• func NewRemotePlacementBuilder(b placement.Builder, s netmap.AnnouncedKeys) placement.Builder
• func TraverseSplitChain(r HeadReceiver, addr *objectSDK.Address, h SplitMemberHandler) error
• type CommonPrm
  • func CommonPrmFromV2(req interface{ ... }) (*CommonPrm, error)
  • func (p *CommonPrm) BearerToken() *token.BearerToken
  • func (p *CommonPrm) LocalOnly() bool
  • func (p *CommonPrm) NetmapEpoch() uint64
  • func (p *CommonPrm) NetmapLookupDepth() uint64
  • func (p *CommonPrm) RemoteCallOptions(dynamic ...DynamicCallOption) []client.CallOption
  • func (p *CommonPrm) SessionToken() *sessionsdk.Token
  • func (p *CommonPrm) SetNetmapLookupDepth(v uint64)
  • func (p *CommonPrm) WithBearerToken(token *token.BearerToken) *CommonPrm
  • func (p *CommonPrm) WithLocalOnly(v bool) *CommonPrm
  • func (p *CommonPrm) WithRemoteCallOptions(opts ...client.CallOption) *CommonPrm
  • func (p *CommonPrm) WithSessionToken(token *sessionsdk.Token) *CommonPrm
• type DynamicCallOption
  • func WithKey(key *ecdsa.PrivateKey) DynamicCallOption
  • func WithNetmapEpoch(v uint64) DynamicCallOption
• type HeadReceiver
• type KeyStorage
  • func NewKeyStorage(localKey *ecdsa.PrivateKey, tokenStore *storage.TokenStore, net netmap.State) *KeyStorage
  • func (s *KeyStorage) GetKey(token *session.Token) (*ecdsa.PrivateKey, error)
• type SplitMemberHandler
• type TraverserGenerator
  • func NewTraverserGenerator(nmSrc netmap.Source, cnrSrc container.Source, netmapKeys netmap.AnnouncedKeys) *TraverserGenerator
  • func (g *TraverserGenerator) GenerateTraverser(addr *object.Address, epoch uint64) (*placement.Traverser, error)
  • func (g *TraverserGenerator) WithTraverseOptions(opts ...placement.Option) *TraverserGenerator

Functions

func IterateAllSplitLeaves

func IterateAllSplitLeaves(r HeadReceiver, addr *objectSDK.Address, h func(*object.Object)) error

IterateAllSplitLeaves is an iterator over all object split-tree leaves in direct order.

func IterateSplitLeaves

func IterateSplitLeaves(r HeadReceiver, addr *objectSDK.Address, h func(*object.Object) bool) error

IterateSplitLeaves is an iterator over object split-tree leaves in direct order.

If member handler returns true, then the iterator aborts without error.

func LogServiceError

func LogServiceError(l *logger.Logger, req string, node network.AddressGroup, err error)

LogServiceError writes debug error message of object service to provided logger.

func LogWorkerPoolError

func LogWorkerPoolError(l *logger.Logger, req string, err error)

LogWorkerPoolError writes debug error message of object worker pool to provided logger.

func NewLocalPlacement

func NewLocalPlacement(b placement.Builder, s netmap.AnnouncedKeys) placement.Builder

func NewRemotePlacementBuilder

func NewRemotePlacementBuilder(b placement.Builder, s netmap.AnnouncedKeys) placement.Builder

NewRemotePlacementBuilder creates, initializes and returns placement builder that excludes local node from any placement vector.

func TraverseSplitChain

func TraverseSplitChain(r HeadReceiver, addr *objectSDK.Address, h SplitMemberHandler) error

TraverseSplitChain is an iterator over object split-tree leaves.

Traversal occurs in one of two directions, which depends on what pslit info was received: * in direct order for link part; * in reverse order for last part.

Types

type CommonPrm

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

func CommonPrmFromV2

func CommonPrmFromV2(req interface {
	GetMetaHeader() *session.RequestMetaHeader
}) (*CommonPrm, error)

func (*CommonPrm) BearerToken

func (p *CommonPrm) BearerToken() *token.BearerToken

func (*CommonPrm) LocalOnly

func (p *CommonPrm) LocalOnly() bool

func (*CommonPrm) NetmapEpoch

func (p *CommonPrm) NetmapEpoch() uint64

func (*CommonPrm) NetmapLookupDepth

func (p *CommonPrm) NetmapLookupDepth() uint64

func (*CommonPrm) RemoteCallOptions

func (p *CommonPrm) RemoteCallOptions(dynamic ...DynamicCallOption) []client.CallOption

RemoteCallOptions return call options for remote client calls.

func (*CommonPrm) SessionToken

func (p *CommonPrm) SessionToken() *sessionsdk.Token

func (*CommonPrm) SetNetmapLookupDepth

func (p *CommonPrm) SetNetmapLookupDepth(v uint64)

func (*CommonPrm) WithBearerToken

func (p *CommonPrm) WithBearerToken(token *token.BearerToken) *CommonPrm

func (*CommonPrm) WithLocalOnly

func (p *CommonPrm) WithLocalOnly(v bool) *CommonPrm

func (*CommonPrm) WithRemoteCallOptions

func (p *CommonPrm) WithRemoteCallOptions(opts ...client.CallOption) *CommonPrm

WithRemoteCallOptions sets call options remote remote client calls.

func (*CommonPrm) WithSessionToken

func (p *CommonPrm) WithSessionToken(token *sessionsdk.Token) *CommonPrm

type DynamicCallOption

type DynamicCallOption func(*remoteCallOpts)

func WithKey

func WithKey(key *ecdsa.PrivateKey) DynamicCallOption

WithKey sets key to use for the request.

func WithNetmapEpoch

func WithNetmapEpoch(v uint64) DynamicCallOption

type HeadReceiver

type HeadReceiver interface {
	// Head must return one of:
	// * object header (*object.Object);
	// * structured information about split-chain (*objectSDK.SplitInfo).
	Head(*objectSDK.Address) (interface{}, error)
}

HeadReceiver is an interface of entity that can receive object header or the information about the object relations.

type KeyStorage

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

KeyStorage represents private key storage of the local node.

func NewKeyStorage

func NewKeyStorage(localKey *ecdsa.PrivateKey, tokenStore *storage.TokenStore, net netmap.State) *KeyStorage

NewKeyStorage creates, initializes and returns new KeyStorage instance.

func (*KeyStorage) GetKey

func (s *KeyStorage) GetKey(token *session.Token) (*ecdsa.PrivateKey, error)

GetKey returns private key of the node.

If token is not nil, session private key is returned. Otherwise, node private key is returned.

type SplitMemberHandler

type SplitMemberHandler func(member *object.Object, reverseDirection bool) (stop bool)

SplitMemberHandler is a handler of next split-chain element.

If reverseDirection arg is true, then the traversal is done in reverse order. Stop boolean result provides the ability to interrupt the traversal.

type TraverserGenerator

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

TraverserGenerator represents tool that generates container traverser for the particular need.

func NewTraverserGenerator

func NewTraverserGenerator(nmSrc netmap.Source, cnrSrc container.Source, netmapKeys netmap.AnnouncedKeys) *TraverserGenerator

NewTraverserGenerator creates, initializes and returns new TraverserGenerator instance.

func (*TraverserGenerator) GenerateTraverser

func (g *TraverserGenerator) GenerateTraverser(addr *object.Address, epoch uint64) (*placement.Traverser, error)

GenerateTraverser generates placement Traverser for provided object address using epoch-th network map.

func (*TraverserGenerator) WithTraverseOptions

func (g *TraverserGenerator) WithTraverseOptions(opts ...placement.Option) *TraverserGenerator

WithTraverseOptions returns TraverseGenerator that additionally applies provided options.