util

package
v0.13.0-rc.1 Latest Latest
Warning

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

Go to latest
Published: Dec 11, 2020 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LogServiceError added in v0.12.1

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

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

func LogWorkerPoolError added in v0.12.1

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

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

func NewRemotePlacementBuilder added in v0.13.0

func NewRemotePlacementBuilder(b placement.Builder, s network.LocalAddressSource) placement.Builder

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

Types

type CommonPrm

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

func CommonPrmFromV2

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

func (*CommonPrm) BearerToken

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

func (*CommonPrm) LocalOnly

func (p *CommonPrm) LocalOnly() bool

func (*CommonPrm) PrivateKey added in v0.13.0

func (p *CommonPrm) PrivateKey() *ecdsa.PrivateKey

PrivateKey returns private key to use during execution.

func (*CommonPrm) RemoteCallOptions added in v0.13.0

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

RemoteCallOptions return call options for remote client calls.

func (*CommonPrm) SessionToken

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

func (*CommonPrm) WithBearerToken

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

func (*CommonPrm) WithLocalOnly

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

func (*CommonPrm) WithPrivateKey added in v0.13.0

func (p *CommonPrm) WithPrivateKey(key *ecdsa.PrivateKey) *CommonPrm

WithPrivateKey sets private key to use during execution.

func (*CommonPrm) WithRemoteCallOptions added in v0.13.0

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

WithRemoteCallOptions sets call options remote remote client calls.

func (*CommonPrm) WithSessionToken

func (p *CommonPrm) WithSessionToken(token *token.SessionToken) *CommonPrm

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) *KeyStorage

NewKeyStorage creates, initializes and returns new KeyStorage instance.

func (*KeyStorage) GetKey

func (s *KeyStorage) GetKey(token *token.SessionToken) (*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 RangeTraverser

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

func NewRangeTraverser

func NewRangeTraverser(originSize uint64, rightElement *object.Object, rngSeek *objectSDK.Range) *RangeTraverser

func (*RangeTraverser) Next

func (c *RangeTraverser) Next() (id *objectSDK.ID, rng *objectSDK.Range)

func (*RangeTraverser) PushHeader

func (c *RangeTraverser) PushHeader(obj *object.Object)

func (*RangeTraverser) PushSuccessSize

func (c *RangeTraverser) PushSuccessSize(sz uint64)

func (*RangeTraverser) SetSeekRange

func (c *RangeTraverser) SetSeekRange(r *objectSDK.Range)

SetSeekRange moves the chain to the specified range. The range is expected to be within the filled chain.

type TraverserGenerator added in v0.13.0

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

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

func NewTraverserGenerator added in v0.13.0

func NewTraverserGenerator(nmSrc netmap.Source, cnrSrc container.Source, localAddrSrc network.LocalAddressSource) *TraverserGenerator

NewTraverserGenerator creates, initializes and returns new TraverserGenerator instance.

func (*TraverserGenerator) GenerateTraverser added in v0.13.0

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

GenerateTraverser generates placement Traverser for provided object address.

func (*TraverserGenerator) WithTraverseOptions added in v0.13.0

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

WithTraverseOptions returns TraverseGenerator that additionally applies provided options.

Jump to

Keyboard shortcuts

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