stream

Jul 20, 2023

Changes in this version

type PartUpload

+ func (upload *PartUpload) Commit() error

+ func (upload *PartUpload) Meta() *streams.Meta

type Upload

+ func (upload *Upload) Commit() error

Sep 20, 2021

Changes in this version

+ type PartUpload struct

+ func NewUploadPart(ctx context.Context, bucket, key string, streamID storj.StreamID, ...) *PartUpload

+ func (upload *PartUpload) Abort() error

+ func (upload *PartUpload) Close() error

+ func (upload *PartUpload) Part() *streams.Part

+ func (upload *PartUpload) Write(data []byte) (n int, err error)

Aug 3, 2020

Changes in this version

type Upload

+ func (upload *Upload) Abort() error

Mar 19, 2020

Changes in this version

+ var Error = errs.Class("stream error")

+ type Download struct

+ func NewDownload(ctx context.Context, stream kvmetainfo.ReadOnlyStream, streams streams.Store) *Download

+ func NewDownloadRange(ctx context.Context, stream kvmetainfo.ReadOnlyStream, streams streams.Store, ...) *Download

+ func (download *Download) Close() error

+ func (download *Download) Read(data []byte) (n int, err error)

+ type Upload struct

+ func NewUpload(ctx context.Context, stream kvmetainfo.MutableStream, streams streams.Store) *Upload

+ func (upload *Upload) Close() error

+ func (upload *Upload) Meta() *streams.Meta

+ func (upload *Upload) Write(data []byte) (n int, err error)