putsvc

Documentation

Index

• type PutChunkPrm
  • func (p *PutChunkPrm) WithChunk(v []byte) *PutChunkPrm
• type PutInitPrm
  • func (p *PutInitPrm) WithCommonPrm(v *util.CommonPrm) *PutInitPrm
  • func (p *PutInitPrm) WithCopyNumbers(v []uint32) *PutInitPrm
  • func (p *PutInitPrm) WithObject(v *objectSDK.Object) *PutInitPrm
  • func (p *PutInitPrm) WithRelay(f func(context.Context, client.NodeInfo, client.MultiAddressClient) error) *PutInitPrm
• type PutResponse
  • func (r *PutResponse) ObjectID() oid.ID
• type Service
  • func NewService(ks *objutil.KeyStorage, cc objectwriter.ClientConstructor, ...) *Service
  • func (p *Service) Put() (*Streamer, error)
  • func (s *Service) PutSingle(ctx context.Context, req *objectAPI.PutSingleRequest) (*objectAPI.PutSingleResponse, error)
• type Streamer
  • func (p *Streamer) Close(ctx context.Context) (*PutResponse, error)
  • func (p *Streamer) Init(ctx context.Context, prm *PutInitPrm) error
  • func (p *Streamer) SendChunk(ctx context.Context, prm *PutChunkPrm) error

Types

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) WithCopyNumbers

func (p *PutInitPrm) WithCopyNumbers(v []uint32) *PutInitPrm

func (*PutInitPrm) WithObject

func (p *PutInitPrm) WithObject(v *objectSDK.Object) *PutInitPrm

func (*PutInitPrm) WithRelay

func (p *PutInitPrm) WithRelay(f func(context.Context, client.NodeInfo, client.MultiAddressClient) error) *PutInitPrm

type PutResponse

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

func (*PutResponse) ObjectID

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

type Service

type Service struct {
	*objectwriter.Config
}

func NewService

func NewService(ks *objutil.KeyStorage,
	cc objectwriter.ClientConstructor,
	ms objectwriter.MaxSizeSource,
	os objectwriter.ObjectStorage,
	cs container.Source,
	ns netmap.Source,
	nk netmap.AnnouncedKeys,
	nst netmap.State,
	ir objectwriter.InnerRing,
	opts ...objectwriter.Option,
) *Service

func (*Service) Put

func (p *Service) Put() (*Streamer, error)

func (*Service) PutSingle

func (s *Service) PutSingle(ctx context.Context, req *objectAPI.PutSingleRequest) (*objectAPI.PutSingleResponse, error)

type Streamer

type Streamer struct {
	*objectwriter.Config
	// contains filtered or unexported fields
}

func (*Streamer) Close

func (p *Streamer) Close(ctx context.Context) (*PutResponse, error)

func (*Streamer) Init

func (p *Streamer) Init(ctx context.Context, prm *PutInitPrm) error

func (*Streamer) SendChunk

func (p *Streamer) SendChunk(ctx context.Context, prm *PutChunkPrm) error