Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

moengine

package

Go to main page

Versions in this module

v0

v0.7.0

Feb 18, 2023

Changes in this version

+ func AttrFromColDef(col *catalog.ColDef) (attrs *engine.Attribute, err error)

type Engine

+ ForceCheckpoint func(ctx context.Context, ts types.TS, flushDuration time.Duration) error

type Relation

+ AddBlksWithMetaLoc func(ctx context.Context, pks []containers.Vector, file string, metaloc []string, ...) error

+ GetSchema func(ctx context.Context) *catalog.Schema

+ UpdateConstraintWithBin func(context.Context, []byte) error

v0.6.0

Nov 29, 2022

Changes in this version

+ func ColDefsToAttrs(colDefs []*catalog.ColDef) (attrs []*engine.Attribute, err error)

+ func EngineToTxnClient(engine TxnEngine) client.TxnClient

+ func HandleDefsToSchema(name string, defs []engine.TableDef) (schema *catalog.Schema, err error)

+ func TxnToTxnOperator(tx Txn) client.TxnOperator

+ type Database interface

+ CreateRelation func(context.Context, string, []engine.TableDef) error

+ CreateRelationWithID func(context.Context, string, uint64, []engine.TableDef) error

+ DropRelation func(context.Context, string) error

+ DropRelationByID func(context.Context, uint64) error

+ GetDatabaseID func(ctx context.Context) uint64

+ GetRelation func(context.Context, string) (Relation, error)

+ GetRelationByID func(context.Context, uint64) (Relation, error)

+ RelationNames func(context.Context) ([]string, error)

+ TruncateRelationByID func(context.Context, uint64, uint64) error

+ TruncateRelationWithID func(context.Context, string, uint64) error

+ type Engine interface

+ CreateDatabase func(ctx context.Context, databaseName string, txn Txn) error

+ CreateDatabaseWithID func(ctx context.Context, databaseName, createSql string, id uint64, txn Txn) error

+ DatabaseNames func(ctx context.Context, txn Txn) (databaseNames []string, err error)

+ DropDatabase func(ctx context.Context, databaseName string, txn Txn) error

+ DropDatabaseByID func(ctx context.Context, id uint64, txn Txn) error

+ FlushTable func(ctx context.Context, tenantID uint32, databaseId, tableId uint64, ts types.TS) error

+ GetDatabase func(ctx context.Context, databaseName string, txn Txn) (Database, error)

+ GetDatabaseByID func(ctx context.Context, id uint64, txn Txn) (Database, error)

+ GetTAE func(ctx context.Context) *db.DB

+ type Relation interface

+ Delete func(context.Context, *batch.Batch, string) error

+ DeleteByPhyAddrKeys func(context.Context, *vector.Vector) error

+ GetHideKeys func(context.Context) ([]*engine.Attribute, error)

+ GetPrimaryKeys func(context.Context) ([]*engine.Attribute, error)

+ GetRelationID func(context.Context) uint64

+ NewReader func(context.Context, int, *plan.Expr, [][]byte) ([]engine.Reader, error)

+ TableDefs func(context.Context) ([]engine.TableDef, error)

+ Write func(context.Context, *batch.Batch) error

type Txn

+ Committing func() error

+ Is2PC func() bool

+ Prepare func() (types.TS, error)

+ SetCommitTS func(cts types.TS) error

+ SetParticipants func(ids []uint64) error

type TxnEngine

+ Close func() error

+ Destroy func() error

+ GetOrCreateTxnWithMeta func(info []byte, id []byte, ts types.TS) (txn Txn, err error)

+ GetTxnByID func(id []byte) (txn Txn, err error)

v0.5.1

Aug 17, 2022

v0.5.0

Jul 14, 2022

Changes in this version

+ const ADDR

+ var ErrReadOnly = errors.New("tae moengine: read only")

+ func AppendFixedValue(vec *vector.Vector, v any)

+ func AppendValue(vec *vector.Vector, v any)

+ func ApplyDeleteToVector(vec *vector.Vector, deletes *roaring.Bitmap) *vector.Vector

+ func ApplyUpdateToVector(vec *vector.Vector, mask *roaring.Bitmap, vals map[uint32]any) *vector.Vector

+ func BatchWindow(bat *batch.Batch, start, end int) *batch.Batch

+ func CopyToMoVector(vec containers.Vector) *vector.Vector

+ func CopyToMoVectors(vecs []containers.Vector) []*vector.Vector

+ func DefsToSchema(name string, defs []engine.TableDef) (schema *catalog.Schema, err error)

+ func ForEachValue(col *vector.Vector, reversed bool, op func(v any, row uint32) error) (err error)

+ func GenericUpdateFixedValue(vec *vector.Vector, row uint32, v any)

+ func GetValue(col *vector.Vector, row uint32) any

+ func MOToVector(v *vector.Vector, nullable bool) containers.Vector

+ func MOToVectorTmp(v *vector.Vector, nullable bool) containers.Vector

+ func MOToVectors(movecs []*vector.Vector, nullables []bool) []containers.Vector

+ func MockVec(typ types.Type, rows int, offset int) *vector.Vector

+ func NewEngine(impl *db.DB) *txnEngine

+ func SchemaToDefs(schema *catalog.Schema) (defs []engine.TableDef, err error)

+ func SplitBatch(bat *batch.Batch, cnt int) []*batch.Batch

+ func UpdateOffsets(data *types.Bytes, start, end int)

+ func UpdateValue(col *vector.Vector, row uint32, val any)

+ func VectorsToMO(vec containers.Vector) *vector.Vector

+ type Txn interface

+ Commit func() error

+ GetCtx func() []byte

+ GetError func() error

+ GetID func() uint64

+ Repr func() string

+ Rollback func() error

+ String func() string

+ type TxnEngine interface

+ StartTxn func(info []byte) (txn Txn, err error)