blobs

Documentation

Index

• type SortKey
• type Store
  • func NewStore(backend backends.Backend, blobSize int64, maxUnflushed int) *Store
  • func (s *Store) Close() error
  • func (s *Store) Flush(ctx context.Context) (err error)
  • func (s *Store) Put(ctx context.Context, data io.ReadCloser, size int64, sortKey SortKey, ...) error

Types

type SortKey

type SortKey interface {
	Less(b SortKey) bool
}

type Store

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

func NewStore

func NewStore(backend backends.Backend, blobSize int64, maxUnflushed int) *Store

func (*Store) Close

func (s *Store) Close() error

func (*Store) Flush

func (s *Store) Flush(ctx context.Context) (err error)

func (*Store) Put

func (s *Store) Put(ctx context.Context, data io.ReadCloser, size int64, sortKey SortKey, cb func(ctx context.Context, stream *manifest.Stream, lastOfBlob bool) error) error