putsvc

package
v0.46.6 Latest Latest
Warning

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

 Go to latest Published: Aug 19, 2025 License: GPL-3.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func SufficientCopiesFromV2 added in v0.46.0 

func SufficientCopiesFromV2(v []objectAPI.CopiesVector) (res [][]uint32)

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 added in v0.37.0 

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

func (*PutInitPrm) WithSufficientCopies added in v0.46.0 

func (p *PutInitPrm) WithSufficientCopies(v [][]uint32) *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,
	ncs netmap.ConfigSource,
	nk netmap.AnnouncedKeys,
	nst netmap.State,
	ir objectwriter.InnerRing,
	opts ...objectwriter.Option,
) *Service

func (*Service) Put 

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

func (*Service) PutSingle added in v0.37.0 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.