putsvc

Documentation

Index

• type ClientConstructor
• type MaxSizeSource
• type Option
  • func WithClientConstructor(v ClientConstructor) Option
  • func WithContainerSource(v container.Source) Option
  • func WithFormatValidatorOpts(v ...object.FormatValidatorOption) Option
  • func WithKeyStorage(v *objutil.KeyStorage) Option
  • func WithLocalAddressSource(v network.LocalAddressSource) Option
  • func WithLocalStorage(v *engine.StorageEngine) Option
  • func WithLogger(l *logger.Logger) Option
  • func WithMaxSizeSource(v MaxSizeSource) Option
  • func WithNetworkMapSource(v netmap.Source) Option
  • func WithNetworkState(v netmap.State) Option
  • func WithWorkerPool(v util.WorkerPool) Option
• type PutChunkPrm
  • func (p *PutChunkPrm) WithChunk(v []byte) *PutChunkPrm
• type PutInitPrm
  • func (p *PutInitPrm) WithCommonPrm(v *util.CommonPrm) *PutInitPrm
  • func (p *PutInitPrm) WithObject(v *object.RawObject) *PutInitPrm
  • func (p *PutInitPrm) WithRelay(f func(network.AddressGroup, client.Client) error) *PutInitPrm
  • func (p *PutInitPrm) WithTraverseOption(opt placement.Option) *PutInitPrm
• type PutResponse
  • func (r *PutResponse) ObjectID() *object.ID
• type RemotePutPrm
  • func (p *RemotePutPrm) WithNodeAddress(v network.AddressGroup) *RemotePutPrm
  • func (p *RemotePutPrm) WithObject(v *object.Object) *RemotePutPrm
• type RemoteSender
  • func NewRemoteSender(keyStorage *util.KeyStorage, cons ClientConstructor) *RemoteSender
  • func (s *RemoteSender) PutObject(ctx context.Context, p *RemotePutPrm) error
• type Service
  • func NewService(opts ...Option) *Service
  • func (p *Service) Put(ctx context.Context) (*Streamer, error)
• type Streamer
  • func (p *Streamer) Close() (*PutResponse, error)
  • func (p *Streamer) Init(prm *PutInitPrm) error
  • func (p *Streamer) MaxObjectSize() uint64
  • func (p *Streamer) SendChunk(prm *PutChunkPrm) error

Types

type ClientConstructor

type ClientConstructor interface {
	Get(network.AddressGroup) (client.Client, error)
}

type MaxSizeSource

type MaxSizeSource interface {
	// MaxObjectSize returns maximum payload size
	// of physically stored object in system.
	//
	// Must return 0 if value can not be obtained.
	MaxObjectSize() uint64
}

type Option

type Option func(*cfg)

func WithClientConstructor

func WithClientConstructor(v ClientConstructor) Option

func WithContainerSource

func WithContainerSource(v container.Source) Option

func WithFormatValidatorOpts

func WithFormatValidatorOpts(v ...object.FormatValidatorOption) Option

func WithKeyStorage

func WithKeyStorage(v *objutil.KeyStorage) Option

func WithLocalAddressSource

func WithLocalAddressSource(v network.LocalAddressSource) Option

func WithLocalStorage

func WithLocalStorage(v *engine.StorageEngine) Option

func WithLogger

func WithLogger(l *logger.Logger) Option

func WithMaxSizeSource

func WithMaxSizeSource(v MaxSizeSource) Option

func WithNetworkMapSource

func WithNetworkMapSource(v netmap.Source) Option

func WithNetworkState

func WithNetworkState(v netmap.State) Option

func WithWorkerPool

func WithWorkerPool(v util.WorkerPool) Option

type PutChunkPrm

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

func (*PutChunkPrm) WithChunk

func (p *PutChunkPrm) WithChunk(v []byte) *PutChunkPrm

type PutInitPrm

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

func (*PutInitPrm) WithCommonPrm

func (p *PutInitPrm) WithCommonPrm(v *util.CommonPrm) *PutInitPrm

func (*PutInitPrm) WithObject

func (p *PutInitPrm) WithObject(v *object.RawObject) *PutInitPrm

func (*PutInitPrm) WithRelay

func (p *PutInitPrm) WithRelay(f func(network.AddressGroup, client.Client) error) *PutInitPrm

func (*PutInitPrm) WithTraverseOption

func (p *PutInitPrm) WithTraverseOption(opt placement.Option) *PutInitPrm

type PutResponse

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

func (*PutResponse) ObjectID

func (r *PutResponse) ObjectID() *object.ID

type RemotePutPrm

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

RemotePutPrm groups remote put operation parameters.

func (*RemotePutPrm) WithNodeAddress

func (p *RemotePutPrm) WithNodeAddress(v network.AddressGroup) *RemotePutPrm

WithNodeAddress sets network address of the remote node.

func (*RemotePutPrm) WithObject

func (p *RemotePutPrm) WithObject(v *object.Object) *RemotePutPrm

WithObject sets transferred object.

type RemoteSender

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

RemoteSender represents utility for sending an object to a remote host.

func NewRemoteSender

func NewRemoteSender(keyStorage *util.KeyStorage, cons ClientConstructor) *RemoteSender

NewRemoteSender creates, initializes and returns new RemoteSender instance.

func (*RemoteSender) PutObject

func (s *RemoteSender) PutObject(ctx context.Context, p *RemotePutPrm) error

PutObject sends object to remote node.

type Service

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

func NewService

func NewService(opts ...Option) *Service

func (*Service) Put

func (p *Service) Put(ctx context.Context) (*Streamer, error)

type Streamer

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

func (*Streamer) Close

func (p *Streamer) Close() (*PutResponse, error)

func (*Streamer) Init

func (p *Streamer) Init(prm *PutInitPrm) error

func (*Streamer) MaxObjectSize

func (p *Streamer) MaxObjectSize() uint64

MaxObjectSize returns maximum payload size for the streaming session.

Must be called after the successful Init.

func (*Streamer) SendChunk

func (p *Streamer) SendChunk(prm *PutChunkPrm) error