db

type MessageType int32

type MetaConfig struct {
	MetaRootPrefix     string            `json:"meta_root_prefix"`
	SupportInline      bool              `json:"support_inline"`
	TinyFileThresholdB int               `json:"tinyfile_threshold_B"`
	Sync               bool              `json:"sync"`
	BatchProcessCount  int64             `json:"batch_process_count"`
	WritePriRatio      float64           `json:"write_pri_ratio"`
	MetaQos            qos.LevelConfig   `json:"meta_qos"`
	RocksdbOption      rdb.RocksDBOption `json:"rocksdb_option"`
}

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

type MetaHandler interface {
	Get(ctx context.Context, key []byte) ([]byte, error)
	Put(ctx context.Context, kv rdb.KV) error
	Delete(ctx context.Context, key []byte) error
	DeleteRange(ctx context.Context, start, end []byte) error
	Flush(ctx context.Context) error
	NewIterator(ctx context.Context, opts ...rdb.OpOption) rdb.Iterator
	SetIOStat(stat *flow.IOFlowStat)
	SetHandleIOError(handler func(err error))
	Close(ctx context.Context) error
}

type Request struct {
	Type MessageType
	Data interface{}
	// contains filtered or unexported fields
}

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