blob

package

v0.16.1 Latest Latest Go to latest Published: Feb 14, 2021 License: MIT Imports: 12 Imported by: 1

Details

This section is empty.

This section is empty.

func NewBlob(r io.Reader) (*Blob, []*Chunk, error)

func WithChunkSize(bytes int) func(*manager)

func WithImportWorkers(n int) func(*manager)

func WithObjectManager(x objectmanager.ObjectManager) func(*manager)

func WithResolver(res resolver.Resolver) func(*manager)

type Blob struct {
	Metadata object.Metadata `nimona:"metadata:m,omitempty"`
	Chunks   []object.Hash
}

func (e *Blob) FromObject(o *object.Object) error

func (e Blob) ToObject() *object.Object

func (e *Blob) Type() string

type Chunk struct {
	Metadata object.Metadata `nimona:"metadata:m,omitempty"`
	Data     []byte
}

func (e *Chunk) FromObject(o *object.Object) error

func (e Chunk) ToObject() *object.Object

func (e *Chunk) Type() string

type Manager interface {
	Requester
	ImportFromFile(
		ctx context.Context,
		inputPath string,
	) (*Blob, error)
}

func NewManager(
	ctx context.Context,
	opts ...Option,
) Manager

type Option func(*manager)

type Reader interface {
	Read(p []byte) (n int, err error)
}

func NewReader(chunks []*Chunk) Reader

type Requester interface {
	Request(
		ctx context.Context,
		hash object.Hash,
	) (*Blob, []*Chunk, error)
}