blob

Documentation

Index

• func WithChunkSize(bytes int) func(*manager)
• func WithObjectManager(x objectmanager.ObjectManager) func(*manager)
• func WithResolver(res resolver.Resolver) func(*manager)
• type Blob
  • func ToBlob(r io.Reader) (*Blob, error)
  • func (e *Blob) FromObject(o *object.Object) error
  • func (e Blob) ToObject() *object.Object
  • func (e *Blob) Type() string
• type BlobUnloaded
  • func (e *BlobUnloaded) FromObject(o *object.Object) error
  • func (e BlobUnloaded) ToObject() *object.Object
  • func (e *BlobUnloaded) Type() string
• type Chunk
  • func (e *Chunk) FromObject(o *object.Object) error
  • func (e Chunk) ToObject() *object.Object
  • func (e *Chunk) Type() string
• type Manager
  • func NewManager(ctx context.Context, opts ...Option) Manager
• type Option
• type Reader
  • func FromBlob(bl *Blob) Reader
• type Requester

Functions

func WithChunkSize

func WithChunkSize(bytes int) func(*manager)

func WithObjectManager

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

func WithResolver

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

Types

type Blob

type Blob struct {
	Metadata object.Metadata `nimona:"metadata:m,omitempty"`
	Chunks   []*Chunk        `nimona:"chunks:ao,omitempty"`
}

func ToBlob

func ToBlob(r io.Reader) (*Blob, error)

func (*Blob) FromObject

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

func (Blob) ToObject

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

func (*Blob) Type

func (e *Blob) Type() string

type BlobUnloaded

type BlobUnloaded struct {
	Metadata       object.Metadata `nimona:"metadata:m,omitempty"`
	ChunksUnloaded []object.Hash   `nimona:"chunks:ar,omitempty"`
}

nolint: golint // stuttering is fine for this one

func (*BlobUnloaded) FromObject

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

func (BlobUnloaded) ToObject

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

func (*BlobUnloaded) Type

func (e *BlobUnloaded) Type() string

type Chunk

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

func (*Chunk) FromObject

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

func (Chunk) ToObject

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

func (*Chunk) Type

func (e *Chunk) Type() string

type Manager

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

func NewManager

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

type Option

type Option func(*manager)

type Reader

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

func FromBlob

func FromBlob(bl *Blob) Reader

type Requester

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