db

type KV[K, V any] interface {
	Get(k K) (V, bool)
	Range(func(k K, v V) bool)
	Remove(k K) (V, bool)
	Set(k K, v V)
}

type KeyRange struct {
	Start []byte
	End   []byte
	Limit int
}

type KeyValue struct {
	Key   json.RawMessage `json:"key"`
	Value json.RawMessage `json:"value"`
}

type Query struct {
	Header   QueryHeader
	KeyRange KeyRange
	Key      []byte
	Value    []byte
	Values   []KeyValue
	// contains filtered or unexported fields
}

type QueryHeader struct {
	DataDir   []byte
	TableName []byte
	Opts      *TableOpts
	FileName  []byte
	Inst      QueryInstruction
}

type QueryInstruction int

type QueryResponse struct {
	Key         []byte
	Value       []byte
	RangeValues [][][]byte
	Stats       QueryStats
	Success     bool
}

type QueryStats struct {
	Count uint
}

type Table interface {
	Get(k []byte) ([]byte, bool)
	Set(k, v []byte) error
	Scan(s, e []byte) ([][][]byte, bool)
	ScanWithLimit(s, e []byte, l int) ([][][]byte, bool)
	Range(func(k, v []byte) bool)
	Print()
	Connect() error
	Count() uint64
	Close()
}

type TableOpts struct {
	TableName []byte
	DataDir   []byte
	InMemory  bool
	WalMode   bool
}