dbi

type AppendCtx struct {
	ShardId   uint64
	OpIndex   uint64
	OpOffset  int
	OpSize    int
	DBName    string
	TableName string
	Data      *batch.Batch
}

type DropTableCtx struct {
	ShardId    uint64
	OpIndex    uint64
	OpOffset   int
	OpSize     int
	DBName     string
	TableName  string
	OnFinishCB OnTableDroppedCB
}

type GetSegmentsCtx struct {
	ShardId   uint64
	OpIndex   uint64
	TableName string
}

type GetSnapshotCtx struct {
	ShardId    uint64
	OpIndex    uint64
	TableName  string
	DBName     string
	SegmentIds []uint64
	ScanAll    bool
	Cols       []int
}

type IBatchReader interface {
	IsReadonly() bool
	Length() int
	GetAttrs() []int
	Close() error
	CloseVector(idx int) error
	IsVectorClosed(idx int) (bool, error)
	GetReaderByAttr(attr int) (IVectorReader, error)
}

type IBlock interface {
	GetID() uint64
	GetSegmentID() uint64
	GetTableID() uint64
	Prefetch() IBatchReader
}

type IBlockIt interface {
	Iterator
	GetHandle() IBlock
}

type IDS struct {
	Version uint64
	Ids     []uint64
}

type ISegment interface {
	NewIt() IBlockIt
	GetID() uint64
	GetTableID() uint64
	BlockIds() []uint64
	GetBlock(id uint64) IBlock
}

type ISegmentIt interface {
	Iterator
	GetHandle() ISegment
}

type ISnapshot interface {
	io.Closer
	SegmentIds() []uint64
	NewIt() ISegmentIt
	GetSegment(id uint64) ISegment
}

type IVectorReader interface {
	io.Closer
	GetType() VectorType
	GetValue(int) (interface{}, error)
	IsNull(int) (bool, error)
	HasNull() bool
	NullCnt() int
	Length() int
	Capacity() int
	GetMemorySize() uint64
	SliceReference(start, end int) (IVectorReader, error)
	CopyToVector() (*ro.Vector, error)
	CopyToVectorWithBuffer(*bytes.Buffer, *bytes.Buffer) (*ro.Vector, error)
}

type Iterator interface {
	io.Closer
	Next()
	Valid() bool
}

type MatchType uint8

type OnTableDroppedCB = func(error)

type StringMatcher struct {
	Type    MatchType
	Pattern string
}

type TableOpCtx struct {
	ShardId   uint64
	OpIndex   uint64
	OpOffset  int
	OpSize    int
	TableName string
}

type VectorType uint8