func NewDs3ObjectReadCloserDecorator(reader io.Reader) io.ReadCloser
func NewObjectReadChannelDecorator(reader io.Reader) models.ReadChannelBuilder
func NewPartialObjectChannelBuilder(name string, objRanges []ds3Models.Range) helperModels.WriteChannelBuilder
func NewReadChannelBuilder(name string) helperModels.ReadChannelBuilder
func NewWriteChannelBuilder(name string) helperModels.WriteChannelBuilder
type Ds3ObjectReadCloser struct {
io.Reader
}
func (Ds3ObjectReadCloser Ds3ObjectReadCloser) Close() error
Implements the ReadChannelBuilder interface and uses a file as the ReadCloser implementation. This channel functions as a random-access and can be used concurrently.
type ObjectReadChannelBuilder struct {
// contains filtered or unexported fields
}
func (builder *ObjectReadChannelBuilder) GetChannel(offset int64) (io.ReadCloser, error)
func (builder *ObjectReadChannelBuilder) IsChannelAvailable(offset int64) bool
func (ObjectReadChannelBuilder) OnDone(reader io.ReadCloser)
type ObjectReadChannelDecorator struct {
// contains filtered or unexported fields
}
func (readChannelDecorator *ObjectReadChannelDecorator) GetChannel(offset int64) (io.ReadCloser, error)
func (readChannelDecorator *ObjectReadChannelDecorator) IsChannelAvailable(offset int64) bool
func (readChannelDecorator *ObjectReadChannelDecorator) OnDone(reader io.ReadCloser)
Implements the WriteChannelBuilder interface and uses a file as the WriteCloser implementation. This channel functions as a random-access and can be used concurrently so long as two writers are not writing to the same location within the file.
type ObjectWriteChannelBuilder struct {
// contains filtered or unexported fields
}
func (builder *ObjectWriteChannelBuilder) GetChannel(offset int64) (io.WriteCloser, error)
func (builder *ObjectWriteChannelBuilder) IsChannelAvailable(offset int64) bool
func (builder *ObjectWriteChannelBuilder) OnDone(writer io.WriteCloser)
type PartialObjectWriteChannelBuilder struct {
// contains filtered or unexported fields
}
func (builder *PartialObjectWriteChannelBuilder) GetChannel(objectOffset int64) (io.WriteCloser, error)
func (builder *PartialObjectWriteChannelBuilder) IsChannelAvailable(objectOffset int64) bool
func (builder *PartialObjectWriteChannelBuilder) OnDone(writer io.WriteCloser)