putsvc

package

v0.12.0-rc1 Latest Latest Go to latest Published: Oct 2, 2020 License: GPL-3.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type MaxSizeSource interface {
	MaxObjectSize() uint64
}

type Option func(*cfg)

func WithContainerSource(v container.Source) Option

func WithKeyStorage(v *objutil.KeyStorage) Option

func WithLocalAddressSource(v network.LocalAddressSource) Option

func WithLocalStorage(v *localstore.Storage) Option

func WithMaxSizeSource(v MaxSizeSource) Option

func WithNetworkMapSource(v netmap.Source) Option

func WithWorkerPool(v util.WorkerPool) Option

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

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

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

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

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

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

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

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

func NewService(opts ...Option) *Service

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

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

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

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

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

Path	Synopsis
v2