blob

Sep 8, 2021

Changes in this version

+ const BlobType

+ const ChunkType

Mar 28, 2021

Changes in this version

type Blob

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

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

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

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

type Chunk

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

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

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

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

Jan 23, 2021

Changes in this version

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

type Reader

+ func NewReader(chunks []*Chunk) Reader

Nov 23, 2020

Changes in this version

+ func WithImportWorkers(n int) func(*manager)

type Blob

+ func (e Blob) ToObjectMap() map[string]interface{}

type Chunk

+ func (e Chunk) ToObjectMap() map[string]interface{}

Nov 20, 2020

Changes in this version

+ func WithChunkSize(bytes int) func(*manager)

+ type Manager interface

+ ImportFromFile func(ctx context.Context, inputPath string) (*BlobUnloaded, error)

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

Oct 31, 2020

Changes in this version

+ type BlobUnloaded struct

+ ChunksUnloaded []object.Hash

+ Metadata object.Metadata

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

+ func (e *BlobUnloaded) Type() string

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

Oct 25, 2020

Changes in this version

type Blob

+ func (e *Blob) Type() string

type Chunk

+ func (e *Chunk) Type() string

Oct 24, 2020

Changes in this version

+ func WithObjectManager(x objectmanager.ObjectManager) func(*requester)

+ func WithResolver(res resolver.Resolver) func(*requester)

+ func WithStore(st *sqlobjectstore.Store) func(*requester)

+ type Option func(*requester)

+ type Requester interface

+ Request func(ctx context.Context, hash object.Hash) (*Blob, error)

+ func NewRequester(ctx context.Context, opts ...Option) Requester

+ type RequestsMap struct

+ func NewRequestsMap() *RequestsMap

+ func (m *RequestsMap) Delete(k string)

+ func (m *RequestsMap) Get(k string) (*request, bool)

+ func (m *RequestsMap) GetOrPut(k string, v *request) (*request, bool)

+ func (m *RequestsMap) ListKeys() []string

+ func (m *RequestsMap) ListValues() []*request

+ func (m *RequestsMap) Put(k string, v *request)

+ func (m *RequestsMap) Range(i func(k string, v *request) bool)

Sep 14, 2020

Changes in this version

+ type Blob struct

+ Chunks []*Chunk

+ Metadata object.Metadata

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

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

+ func (e Blob) GetSchema() *object.SchemaObject

+ func (e Blob) GetType() string

+ func (e Blob) IsStreamRoot() bool

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

+ type Chunk struct

+ Data []byte

+ Metadata object.Metadata

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

+ func (e Chunk) GetSchema() *object.SchemaObject

+ func (e Chunk) GetType() string

+ func (e Chunk) IsStreamRoot() bool

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

+ type Reader interface

+ Read func(p []byte) (n int, err error)

+ func FromBlob(bl *Blob) Reader