db

type Block struct {
	Height      int64  `json:"height"`
	Ts          int64  `json:"ts"`
	BlockHash   string `json:"block_hash"`
	Index       int64  `json:"index"`
	Send        string `json:"send"`
	TxHash      string `json:"tx_hash"`
	HeightIndex int64  `json:"height_index"`
}

type Convert interface {
	ConvertTx(env *TxEnv, op int) ([]Record, error)
}

type DBCreator interface {
	Exists(name string) (bool, error)
	Create(name string, table, definition string) (bool, error)
	Delete(name string) (bool, error)
	GetVersion() int32
}

type DBSaver interface {
	InitDB(DBCreator) error
}

type ExecConvert interface {
	Convert
	DBSaver
}

type IKey struct {
	// contains filtered or unexported fields
}

type Key interface {
	Index() string
	Type() string
	ID() string
	Key() string
}

type ListKV struct {
	Key   string
	Value interface{}
}

type NeedWrapDB interface {
	SetDB(w WrapDB) error
}

type Op struct {
	// contains filtered or unexported fields
}

type Operator interface {
	OpType() int
}

type Record interface {
	Key
	Operator
	Value() []byte
}

type SourceAbleRecord interface {
	Record
	Source() interface{}
}

type TxEnv struct {
	Block     *types.BlockDetail
	TxIndex   int64
	BlockHash string
}

type WrapDB interface {
	Get(k1, k2, id string) (*json.RawMessage, error)
	List(k1, k2 string, keyValue []*ListKV) ([]*json.RawMessage, error)
	Set(k1, k2, id string, r Record) error
	Search(idx, typ string, query *querypara.Query, decode func(x *json.RawMessage) (interface{}, error)) ([]interface{}, error)
}