rangesvc

Nov 25, 2020

Changes in this version

type Option

+ func WithClientCache(v *cache.ClientCache) Option

+ func WithClientOptions(opts ...client.Option) Option

+ func WithLogger(l *logger.Logger) Option

Nov 17, 2020

Changes in this version

+ type Option func(*cfg)

+ func WithContainerSource(v container.Source) Option

+ func WithHeadService(v *headsvc.Service) Option

+ func WithKeyStorage(v *objutil.KeyStorage) Option

+ func WithLocalAddressSource(v network.LocalAddressSource) Option

+ func WithLocalStorage(v *localstore.Storage) Option

+ func WithNetworkMapSource(v netmap.Source) Option

+ func WithWorkerPool(v util.WorkerPool) Option

+ type Prm struct

+ func (p *Prm) FullRange() *Prm

+ func (p *Prm) WithAddress(v *object.Address) *Prm

+ func (p *Prm) WithCommonPrm(v *util.CommonPrm) *Prm

+ func (p *Prm) WithRange(v *object.Range) *Prm

+ type Response struct

+ func (r *Response) PayloadChunk() []byte

+ type Result struct

+ func (r *Result) Head() *object.Object

+ func (r *Result) Stream() Streamer

+ type Service struct

+ func NewService(opts ...Option) *Service

+ func (s *Service) GetRange(ctx context.Context, prm *Prm) (*Result, error)

+ type Streamer interface

+ Recv func() (*Response, error)