stream

Documentation

Index

• Variables
• type Download
  • func NewDownload(ctx context.Context, info metaclient.DownloadInfo, streams *streams.Store) *Download
  • func NewDownloadRange(ctx context.Context, info metaclient.DownloadInfo, streams *streams.Store, ...) *Download
  • func (download *Download) Close() error
  • func (download *Download) Read(data []byte) (n int, err error)
• type PartUpload
  • 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)
• type Upload
  • func NewUpload(ctx context.Context, stream *metaclient.MutableStream, ...) *Upload
  • func (upload *Upload) Abort() error
  • func (upload *Upload) Close() error
  • func (upload *Upload) Meta() *streams.Meta
  • func (upload *Upload) Write(data []byte) (n int, err error)

Variables

var Error = errs.Class("stream")

Error is the errs class of stream errors.

Types

type Download

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

Download implements Reader, Seeker and Closer for reading from stream.

func NewDownload

func NewDownload(ctx context.Context, info metaclient.DownloadInfo, streams *streams.Store) *Download

NewDownload creates new stream download.

func NewDownloadRange

func NewDownloadRange(ctx context.Context, info metaclient.DownloadInfo, streams *streams.Store, start, length int64) *Download

NewDownloadRange creates new stream range download with range from start to start+length.

func (*Download) Close

func (download *Download) Close() error

Close closes the stream and releases the underlying resources.

func (*Download) Read

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

Read reads up to len(data) bytes into data.

If this is the first call it will read from the beginning of the stream. Use Seek to change the current offset for the next Read call.

See io.Reader for more details.

type PartUpload

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

PartUpload implements Writer and Closer for writing to part.

func NewUploadPart

func NewUploadPart(ctx context.Context, bucket, key string, streamID storj.StreamID, partNumber uint32, etag streams.ETag, streamsStore *streams.Store) *PartUpload

NewUploadPart creates new part upload.

func (*PartUpload) Abort

func (upload *PartUpload) Abort() error

Abort closes the stream with an error so that it does not successfully commit and releases the underlying resources.

func (*PartUpload) Close

func (upload *PartUpload) Close() error

Close closes the stream and releases the underlying resources.

func (*PartUpload) Part

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

Part returns the part metadata.

Will return nil if the upload is still in progress.

func (*PartUpload) Write

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

Write writes len(data) bytes from data to the underlying data stream.

See io.Writer for more details.

type Upload

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

Upload implements Writer and Closer for writing to stream.

func NewUpload

func NewUpload(ctx context.Context, stream *metaclient.MutableStream, streamsStore *streams.Store) *Upload

NewUpload creates new stream upload.

func (*Upload) Abort

func (upload *Upload) Abort() error

Abort closes the stream with an error so that it does not successfully commit and releases the underlying resources.

func (*Upload) Close

func (upload *Upload) Close() error

Close closes the stream and releases the underlying resources.

func (*Upload) Meta

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

Meta returns the metadata of the uploaded object.

Will return nil if the upload is still in progress.

func (*Upload) Write

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

Write writes len(data) bytes from data to the underlying data stream.

See io.Writer for more details.