Versions in this module Expand all Collapse all v1 v1.9.0 Jun 13, 2019 Changes in this version + const AverageBits + const MB + const WindowSize + var ErrIntOverflowChunk = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthChunk = fmt.Errorf("proto: negative length found during unmarshaling") + func Cleanup(objC obj.Client, chunks *Storage) + func CopyN(w *Writer, r *Reader, n int64) error + func RandSeq(n int) []byte + type Chunk struct + Hash string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Chunk) Descriptor() ([]byte, []int) + func (*Chunk) ProtoMessage() + func (m *Chunk) GetHash() string + func (m *Chunk) Marshal() (dAtA []byte, err error) + func (m *Chunk) MarshalTo(dAtA []byte) (int, error) + func (m *Chunk) Reset() + func (m *Chunk) Size() (n int) + func (m *Chunk) String() string + func (m *Chunk) Unmarshal(dAtA []byte) error + func (m *Chunk) XXX_DiscardUnknown() + func (m *Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Chunk) XXX_Merge(src proto.Message) + func (m *Chunk) XXX_Size() int + func (m *Chunk) XXX_Unmarshal(b []byte) error + type DataRef struct + Chunk *Chunk + Hash string + OffsetBytes int64 + SizeBytes int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DataRef) Descriptor() ([]byte, []int) + func (*DataRef) ProtoMessage() + func (m *DataRef) GetChunk() *Chunk + func (m *DataRef) GetHash() string + func (m *DataRef) GetOffsetBytes() int64 + func (m *DataRef) GetSizeBytes() int64 + func (m *DataRef) Marshal() (dAtA []byte, err error) + func (m *DataRef) MarshalTo(dAtA []byte) (int, error) + func (m *DataRef) Reset() + func (m *DataRef) Size() (n int) + func (m *DataRef) String() string + func (m *DataRef) Unmarshal(dAtA []byte) error + func (m *DataRef) XXX_DiscardUnknown() + func (m *DataRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataRef) XXX_Merge(src proto.Message) + func (m *DataRef) XXX_Size() int + func (m *DataRef) XXX_Unmarshal(b []byte) error + type Reader struct + func (r *Reader) Close() error + func (r *Reader) Len() int64 + func (r *Reader) NextRange(dataRefs []*DataRef) + func (r *Reader) Read(data []byte) (int, error) + type Storage struct + func LocalStorage(tb testing.TB) (obj.Client, *Storage) + func NewStorage(objC obj.Client) *Storage + func (s *Storage) DeleteAll(ctx context.Context) error + func (s *Storage) List(ctx context.Context, f func(string) error) error + func (s *Storage) NewReader(ctx context.Context, dataRefs ...*DataRef) *Reader + func (s *Storage) NewWriter(ctx context.Context) *Writer + type Writer struct + func (w *Writer) Close() error + func (w *Writer) RangeCount() int64 + func (w *Writer) RangeSize() int64 + func (w *Writer) StartRange(cb func([]*DataRef) error) + func (w *Writer) Write(data []byte) (int, error) v1.9.0-1ff617394086e2ac29d786b2c19a63288572383a Jun 6, 2019