models

Documentation

Index

• type BlobDescription
  • func NewBlobDescription(name string, offset int64, length int64) BlobDescription
  • func (d *BlobDescription) Length() int64
  • func (d *BlobDescription) Name() string
  • func (d *BlobDescription) Offset() int64
• type ChannelErrorHandler
• type GetObject
• type PutObject
  • func (putObject *PutObject) WithMetaData(key string, values ...string) interface{}
• type ReadChannelBuilder
• type WriteChannelBuilder

Types

type BlobDescription

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

Describes a blob

func NewBlobDescription

func NewBlobDescription(name string, offset int64, length int64) BlobDescription

func (*BlobDescription) Length

func (d *BlobDescription) Length() int64

func (*BlobDescription) Name

func (d *BlobDescription) Name() string

func (*BlobDescription) Offset

func (d *BlobDescription) Offset() int64

type ChannelErrorHandler

type ChannelErrorHandler interface {
	HasFatalError() bool     // Determines if a fatal error has happened while transferring a file, i.e. don't transfer more blobs for this file.
	SetFatalError(err error) // Sets a fatal error for the associated file. This will stop future blobs from being sent from this channel.
}

type GetObject

type GetObject struct {
	Name           string
	Ranges         []models.Range
	ChannelBuilder WriteChannelBuilder
}

type PutObject

type PutObject struct {
	PutObject      models.Ds3PutObject
	ChannelBuilder ReadChannelBuilder
	Metadata       map[string]string
}

func (*PutObject) WithMetaData

func (putObject *PutObject) WithMetaData(key string, values ...string) interface{}

type ReadChannelBuilder

type ReadChannelBuilder interface {
	IsChannelAvailable(offset int64) bool
	GetChannel(offset int64) (io.ReadCloser, error)
	OnDone(reader io.ReadCloser) // Determines what a given blob does when it finishes transferring
	ChannelErrorHandler
}

type WriteChannelBuilder

type WriteChannelBuilder interface {
	IsChannelAvailable(offset int64) bool
	GetChannel(offset int64) (io.WriteCloser, error)
	OnDone(writer io.WriteCloser) // Determines what a given blob does when it finishes transferring
	ChannelErrorHandler
}