column

package module

Go to main page

Versions in this module

v0

v0.4.1

Oct 13, 2023

Changes in this version

type Row

+ func (r Row) Index() uint32

type Txn

+ func (txn *Txn) Index() uint32

v0.4.0

Jul 3, 2023

v0.3.0

Dec 17, 2022

Changes in this version

type Collection

+ func (c *Collection) CreateSortIndex(indexName, columnName string) error

type Txn

+ func (txn *Txn) Ascend(sortIndexName string, fn func(idx uint32)) error

v0.2.3

Dec 3, 2022

Changes in this version

type Collection

+ func (c *Collection) CreateTrigger(triggerName, columnName string, fn func(r Reader)) error

+ func (c *Collection) DropTrigger(triggerName string) error

type Reader

+ IsDelete func() bool

+ IsUpsert func() bool

v0.2.2

Dec 1, 2022

Changes in this version

type Reader

+ Bytes func() []byte

v0.2.1

Nov 27, 2022

v0.2.0

Nov 26, 2022

Changes in this version

+ func WithMerge(fn func(value, delta T) T) func(*option[T])

type Column

+ func ForRecord(new func() T, merge func(value, delta T) T) Column

type Row

+ func (r Row) MergeFloat32(columnName string, value float32)

+ func (r Row) MergeFloat64(columnName string, value float64)

+ func (r Row) MergeInt(columnName string, value int)

+ func (r Row) MergeInt16(columnName string, value int16)

+ func (r Row) MergeInt32(columnName string, value int32)

+ func (r Row) MergeInt64(columnName string, value int64)

+ func (r Row) MergeRecord(columnName string, delta encoding.BinaryMarshaler) error

+ func (r Row) MergeString(columnName string, value string)

+ func (r Row) MergeUint(columnName string, value uint)

+ func (r Row) MergeUint16(columnName string, value uint16)

+ func (r Row) MergeUint32(columnName string, value uint32)

+ func (r Row) MergeUint64(columnName string, value uint64)

+ func (r Row) Record(columnName string) (any, bool)

+ func (r Row) SetMany(value map[string]any) error

+ func (r Row) SetRecord(columnName string, value encoding.BinaryMarshaler) error

type Txn

+ func (txn *Txn) Record(columnName string) rwRecord

+ func (txn *Txn) WithUnion(columns ...string) *Txn

v0.1.0

Jun 12, 2022

Changes in this version

+ var ForBool = makeBools

+ var ForEnum = makeEnum

+ var ForFloat32 = makeFloat32s

+ var ForFloat64 = makeFloat64s

+ var ForInt = makeInts

+ var ForInt16 = makeInt16s

+ var ForInt32 = makeInt32s

+ var ForInt64 = makeInt64s

+ var ForKey = makeKey

+ var ForString = makeStrings

+ var ForUint = makeUints

+ var ForUint16 = makeUint16s

+ var ForUint32 = makeUint32s

+ var ForUint64 = makeUint64s

+ type Collection struct

+ func NewCollection(opts ...Options) *Collection

+ func (c *Collection) Close() error

+ func (c *Collection) Count() (count int)

+ func (c *Collection) CreateColumn(columnName string, column Column) error

+ func (c *Collection) CreateColumnsOf(object Object) error

+ func (c *Collection) CreateIndex(indexName, columnName string, fn func(r Reader) bool) error

+ func (c *Collection) DeleteAt(idx uint32) (deleted bool)

+ func (c *Collection) DeleteKey(key string) error

+ func (c *Collection) DropColumn(columnName string)

+ func (c *Collection) DropIndex(indexName string) error

+ func (c *Collection) Insert(fn func(Row) error) (index uint32, err error)

+ func (c *Collection) InsertKey(key string, fn func(Row) error) error

+ func (c *Collection) InsertObject(obj Object) (index uint32)

+ func (c *Collection) InsertObjectWithTTL(obj Object, ttl time.Duration) (index uint32)

+ func (c *Collection) Query(fn func(txn *Txn) error) error

+ func (c *Collection) QueryAt(idx uint32, fn func(Row) error) error

+ func (c *Collection) QueryKey(key string, fn func(Row) error) error

+ func (c *Collection) Replay(change commit.Commit) error

+ func (c *Collection) Restore(snapshot io.Reader) error

+ func (c *Collection) Snapshot(dst io.Writer) error

+ func (c *Collection) UpsertKey(key string, fn func(Row) error) error

+ type Column interface

+ Apply func(commit.Chunk, *commit.Reader)

+ Contains func(idx uint32) bool

+ Grow func(idx uint32)

+ Index func(commit.Chunk) bitmap.Bitmap

+ Snapshot func(chunk commit.Chunk, dst *commit.Buffer)

+ Value func(idx uint32) (interface{}, bool)

+ func ForKind(kind reflect.Kind) (Column, error)

+ type Numeric interface

+ FilterFloat64 func(commit.Chunk, bitmap.Bitmap, func(v float64) bool)

+ FilterInt64 func(commit.Chunk, bitmap.Bitmap, func(v int64) bool)

+ FilterUint64 func(commit.Chunk, bitmap.Bitmap, func(v uint64) bool)

+ LoadFloat64 func(uint32) (float64, bool)

+ LoadInt64 func(uint32) (int64, bool)

+ LoadUint64 func(uint32) (uint64, bool)

+ type Object = map[string]interface

+ type Options struct

+ Capacity int

+ Vacuum time.Duration

+ Writer commit.Logger

+ type Reader interface

+ Bool func() bool

+ Float func() float64

+ Index func() uint32

+ Int func() int

+ String func() string

+ Uint func() uint

+ type Row struct

+ func (r Row) AddFloat32(columnName string, value float32)

+ func (r Row) AddFloat64(columnName string, value float64)

+ func (r Row) AddInt(columnName string, value int)

+ func (r Row) AddInt16(columnName string, value int16)

+ func (r Row) AddInt32(columnName string, value int32)

+ func (r Row) AddInt64(columnName string, value int64)

+ func (r Row) AddUint(columnName string, value uint)

+ func (r Row) AddUint16(columnName string, value uint16)

+ func (r Row) AddUint32(columnName string, value uint32)

+ func (r Row) AddUint64(columnName string, value uint64)

+ func (r Row) Any(columnName string) (any, bool)

+ func (r Row) Bool(columnName string) bool

+ func (r Row) Enum(columnName string) (v string, ok bool)

+ func (r Row) Float32(columnName string) (v float32, ok bool)

+ func (r Row) Float64(columnName string) (float64, bool)

+ func (r Row) Int(columnName string) (v int, ok bool)

+ func (r Row) Int16(columnName string) (v int16, ok bool)

+ func (r Row) Int32(columnName string) (v int32, ok bool)

+ func (r Row) Int64(columnName string) (v int64, ok bool)

+ func (r Row) Key() (v string, ok bool)

+ func (r Row) SetAny(columnName string, value interface{})

+ func (r Row) SetBool(columnName string, value bool)

+ func (r Row) SetEnum(columnName string, value string)

+ func (r Row) SetFloat32(columnName string, value float32)

+ func (r Row) SetFloat64(columnName string, value float64)

+ func (r Row) SetInt(columnName string, value int)

+ func (r Row) SetInt16(columnName string, value int16)

+ func (r Row) SetInt32(columnName string, value int32)

+ func (r Row) SetInt64(columnName string, value int64)

+ func (r Row) SetKey(key string)

+ func (r Row) SetString(columnName string, value string)

+ func (r Row) SetTTL(ttl time.Duration)

+ func (r Row) SetUint(columnName string, value uint)

+ func (r Row) SetUint16(columnName string, value uint16)

+ func (r Row) SetUint32(columnName string, value uint32)

+ func (r Row) SetUint64(columnName string, value uint64)

+ func (r Row) String(columnName string) (v string, ok bool)

+ func (r Row) TTL() (time.Duration, bool)

+ func (r Row) Uint(columnName string) (v uint, ok bool)

+ func (r Row) Uint16(columnName string) (v uint16, ok bool)

+ func (r Row) Uint32(columnName string) (v uint32, ok bool)

+ func (r Row) Uint64(columnName string) (v uint64, ok bool)

+ type Textual interface

+ FilterString func(commit.Chunk, bitmap.Bitmap, func(v string) bool)

+ LoadString func(uint32) (string, bool)

+ type Txn struct

+ func (txn *Txn) Any(columnName string) anyWriter

+ func (txn *Txn) Bool(columnName string) boolWriter

+ func (txn *Txn) Count() int

+ func (txn *Txn) DeleteAll()

+ func (txn *Txn) DeleteAt(index uint32) bool

+ func (txn *Txn) DeleteKey(key string) error

+ func (txn *Txn) Enum(columnName string) enumSlice

+ func (txn *Txn) Float32(columnName string) float32Writer

+ func (txn *Txn) Float64(columnName string) float64Writer

+ func (txn *Txn) Insert(fn func(Row) error) (uint32, error)

+ func (txn *Txn) InsertKey(key string, fn func(Row) error) error

+ func (txn *Txn) InsertObject(object Object) (uint32, error)

+ func (txn *Txn) InsertObjectWithTTL(object Object, ttl time.Duration) (uint32, error)

+ func (txn *Txn) Int(columnName string) intWriter

+ func (txn *Txn) Int16(columnName string) int16Writer

+ func (txn *Txn) Int32(columnName string) int32Writer

+ func (txn *Txn) Int64(columnName string) int64Writer

+ func (txn *Txn) Key() keySlice

+ func (txn *Txn) QueryAt(index uint32, f func(Row) error) (err error)

+ func (txn *Txn) QueryKey(key string, fn func(Row) error) error

+ func (txn *Txn) Range(fn func(idx uint32)) error

+ func (txn *Txn) String(columnName string) stringWriter

+ func (txn *Txn) TTL() ttlWriter

+ func (txn *Txn) Uint(columnName string) uintWriter

+ func (txn *Txn) Uint16(columnName string) uint16Writer

+ func (txn *Txn) Uint32(columnName string) uint32Writer

+ func (txn *Txn) Uint64(columnName string) uint64Writer

+ func (txn *Txn) Union(columns ...string) *Txn

+ func (txn *Txn) UpsertKey(key string, fn func(Row) error) error

+ func (txn *Txn) With(columns ...string) *Txn

+ func (txn *Txn) WithFloat(column string, predicate func(v float64) bool) *Txn

+ func (txn *Txn) WithInt(column string, predicate func(v int64) bool) *Txn

+ func (txn *Txn) WithString(column string, predicate func(v string) bool) *Txn

+ func (txn *Txn) WithUint(column string, predicate func(v uint64) bool) *Txn

+ func (txn *Txn) WithValue(column string, predicate func(v interface{}) bool) *Txn

+ func (txn *Txn) Without(columns ...string) *Txn

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL