vcache

type Array ¶

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

func NewArray(array *vector.Array, r io.ReaderAt) (*Array, error)

func (a *Array) NewIter(reader io.ReaderAt) (iterator, error)

type Cache ¶

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

func NewCache(engine storage.Engine) *Cache

func (c *Cache) Fetch(ctx context.Context, uri *storage.URI, id ksuid.KSUID) (*Object, error)

type Map ¶

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

func NewMap(m *vector.Map, r io.ReaderAt) (*Map, error)

func (m *Map) NewIter(reader io.ReaderAt) (iterator, error)

type Nulls ¶

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

func NewNulls(nulls *vector.Nulls, values Vector, r io.ReaderAt) (*Nulls, error)

func (n *Nulls) NewIter(reader io.ReaderAt) (iterator, error)

type Object ¶

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

Object represents the collection of vectors that are loaded into memory for a given data object as referenced by its ID. An Object structure mirrors the metadata structures used in VNG but here we support dynamic loading of vectors as they are needed and data and metadata are all cached in memory.

func NewObject(ctx context.Context, engine storage.Engine, uri *storage.URI, id ksuid.KSUID) (*Object, error)

func (o *Object) Close() error

func (o *Object) NewProjection(fields []string) (*Projection, error)

func (o *Object) NewReader() *Reader

type Primitive ¶

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

func NewPrimitive(meta *vector.Primitive) (*Primitive, error)

func (p *Primitive) NewIter(r io.ReaderAt) (iterator, error)

type Projection ¶

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

func NewProjection(o *Object, names []string) (*Projection, error)

func (p *Projection) Read() (*zed.Value, error)

type Reader ¶

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

func (r *Reader) Read() (*zed.Value, error)

type Record ¶

type Record []Vector

func NewRecord(fields []vector.Field, r io.ReaderAt) (Record, error)

func (r Record) NewIter(reader io.ReaderAt) (iterator, error)

type Union ¶

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

func NewUnion(union *vector.Union, r io.ReaderAt) (*Union, error)

func (u *Union) NewIter(reader io.ReaderAt) (iterator, error)

type Vector ¶

type Vector interface {
	NewIter(io.ReaderAt) (iterator, error)
}

Vector is the primary interface to in-memory sequences of Zed values representing the VNG vector format. As we implement additional optimizations and various forms of pushdown, we will enhance this interface with corresponding methods.

func NewVector(meta vector.Metadata, r io.ReaderAt) (Vector, error)

func Under(v Vector) Vector