blob

package

v0.18.0-rc1 Latest Latest Go to latest Published: Mar 26, 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
	Chunks   []object.CID
}

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

func (e *Blob) MarshalMap() (object.Map, error)

func (e *Blob) MarshalObject() (*object.Object, error)

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

func (e *Blob) Type() string

func (e *Blob) UnmarshalMap(m object.Map) error

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

type Chunk struct {
	Metadata object.Metadata
	Data     []byte
}

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

func (e *Chunk) MarshalMap() (object.Map, error)

func (e *Chunk) MarshalObject() (*object.Object, error)

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

func (e *Chunk) Type() string

func (e *Chunk) UnmarshalMap(m object.Map) error

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

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,
		cid object.CID,
	) (*Blob, []*Chunk, error)
}