engine

type Attribute struct {
	Name    string      // name of attribute
	Alg     compress.T  // compression algorithm
	Type    types.Type  // type of attribute
	Default DefaultExpr // default value of this attribute.
	Primary bool        // if true, it is primary key
}

type AttributeDef struct {
	Attr Attribute
}

type CommentDef struct {
	Comment string
}

type Database interface {
	Relations(Snapshot) []string
	Relation(string, Snapshot) (Relation, error)

	Delete(uint64, string, Snapshot) error
	Create(uint64, string, []TableDef, Snapshot) error // Create Table - (name, table define)
}

type DefaultExpr struct {
	Exist  bool
	Value  interface{} // int64, float32, float64, string, types.Date, types.Datetime
	IsNull bool
}

type Engine interface {
	Delete(uint64, string, Snapshot) error
	Create(uint64, string, int, Snapshot) error // Create Database - (name, engine type)

	Databases(Snapshot) []string
	Database(string, Snapshot) (Database, error)

	Node(string, Snapshot) *NodeInfo
}

type Filter interface {
	Eq(string, interface{}) (*roaring.Bitmap, error)
	Ne(string, interface{}) (*roaring.Bitmap, error)
	Lt(string, interface{}) (*roaring.Bitmap, error)
	Le(string, interface{}) (*roaring.Bitmap, error)
	Gt(string, interface{}) (*roaring.Bitmap, error)
	Ge(string, interface{}) (*roaring.Bitmap, error)
	Btw(string, interface{}, interface{}) (*roaring.Bitmap, error)
}

type IndexT int

type IndexTableDef struct {
	Typ      IndexT
	ColNames []string
	Name     string
}

type Node struct {
	Id   string `json:"id"`
	Addr string `json:"address"`
	Data []byte `json:"payload"`
}

type NodeInfo struct {
	Mcpu int
}

type Nodes []Node

type PrimaryIndexDef struct {
	TableDef
	Names []string
}

type PropertiesDef struct {
	TableDef
	Properties []Property
}

type Property struct {
	Key   string
	Value string
}

type Reader interface {
	Read([]uint64, []string) (*batch.Batch, error)
}

type Relation interface {
	Statistics

	Close(Snapshot)

	ID(Snapshot) string

	Nodes(Snapshot) Nodes

	TableDefs(Snapshot) []TableDef

	GetPrimaryKeys(Snapshot) []*Attribute

	GetHideKey(Snapshot) *Attribute
	// true: primary key, false: hide key
	GetPriKeyOrHideKey(Snapshot) ([]Attribute, bool)

	Write(uint64, *batch.Batch, Snapshot) error

	Update(uint64, *batch.Batch, Snapshot) error

	Delete(uint64, *vector.Vector, string, Snapshot) error

	Truncate(Snapshot) (uint64, error)

	AddTableDef(uint64, TableDef, Snapshot) error
	DelTableDef(uint64, TableDef, Snapshot) error

	// first argument is the number of reader, second argument is the filter extend,  third parameter is the payload required by the engine
	NewReader(int, *plan.Expr, []byte, Snapshot) []Reader
}

type Snapshot []byte

type SparseFilter interface {
	Eq(string, interface{}) (Reader, error)
	Ne(string, interface{}) (Reader, error)
	Lt(string, interface{}) (Reader, error)
	Le(string, interface{}) (Reader, error)
	Gt(string, interface{}) (Reader, error)
	Ge(string, interface{}) (Reader, error)
	Btw(string, interface{}, interface{}) (Reader, error)
}

type Statistics interface {
	Rows() int64
	Size(string) int64
}

type Summarizer interface {
	Count(string, *roaring.Bitmap) (uint64, error)
	NullCount(string, *roaring.Bitmap) (uint64, error)
	Max(string, *roaring.Bitmap) (interface{}, error)
	Min(string, *roaring.Bitmap) (interface{}, error)
	Sum(string, *roaring.Bitmap) (int64, uint64, error)
}

type TableDef interface {
	// contains filtered or unexported methods
}