ankadb

type AnkaDB struct {
	MgrDB DBMgr
	// 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 {
	OnQuery(ctx context.Context, request string, values map[string]interface{}) (*graphql.Result, error)
	OnQueryStream(ctx context.Context, request string, values map[string]interface{}, funcOnQueryStream FuncOnQueryStream) error
}

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

type FuncOnQueryStream func(*pb.ReplyQuery)

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