ankadb

type AnkaDB interface {
	// Start - start service
	Start(ctx context.Context) error

	// Query - query
	Query(ctx context.Context, request string, values map[string]interface{}) (*graphql.Result, error)

	// SetQueryTemplate - set query template
	SetQueryTemplate(templateName string, request string) error

	// Get - get value
	Get(ctx context.Context, dbname string, key string) ([]byte, error)
	// Set - set value
	Set(ctx context.Context, dbname string, key string, value []byte) error
	// Delete - deletes the key from database
	Delete(ctx context.Context, dbname string, key string) error

	// GetEx - get value
	GetEx(ctx context.Context, dbname string, key []byte) ([]byte, error)
	// SetEx - set value
	SetEx(ctx context.Context, dbname string, key []byte, value []byte) error
	// Delete - deletes the key from database
	DeleteEx(ctx context.Context, dbname string, key []byte) error

	// ForEachWithPrefix - for each with prefix
	ForEachWithPrefix(ctx context.Context, dbname string, prefix string, foreach FuncAnkaDBForEach) error

	// RegEventFunc - register a function for event
	RegEventFunc(event string, eventfunc FuncAnkaDBEvent) error

	// GetConfig - get config
	GetConfig() *Config
	// GetLogic - get DBLogic
	GetLogic() DBLogic
	// GetDBMgr - get DBMgr
	GetDBMgr() DBMgr

	// GetDatabase - get databse with dbname
	GetDatabase(dbname string) database.Database
	// AddDatabase - add database
	AddDatabase(dbcfg DBConfig) error
}

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

type Config struct {
	AddrGRPC   string     `yaml:"addrgrpc"`
	PathDBRoot string     `yaml:"pathdbroot"`
	AddrHTTP   string     `yaml:"addrhttp"`
	ListDB     []DBConfig `yaml:"listdb"`
}

type DBConfig struct {
	Name   string `yaml:"name"`
	Engine string `yaml:"engine"`
	PathDB string `yaml:"pathdb"`
}

type DBLogic interface {
	// GetScheme - get GraphQL scheme
	GetScheme() *graphql.Schema

	// Query - query graphql request string
	Query(ctx context.Context, request string, values map[string]interface{}) (*graphql.Result, error)
	// QueryTemplate - query graphql with template
	QueryTemplate(ctx context.Context, templateName string, values map[string]interface{}) (*graphql.Result, error)

	// SetQueryTemplate - set query template
	SetQueryTemplate(templateName string, request string) error
}

type DBMgr interface {
	AddDB(cfg DBConfig) error
	GetDB(name string) database.Database
	GetMgrSnapshot(name string) *SnapshotMgr
}

type FuncAnkaDBEvent func(ctx context.Context, anka AnkaDB) error

type FuncAnkaDBForEach func(key string, value []byte) error

type FuncOnQueryStream func(*pb.ReplyQuery)

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