Documentation
¶
Index ¶
- Constants
- Variables
- func GetContextValueDatabase(ctx context.Context, key interface{}) database.Database
- func GetMsgFromDB(db database.Database, key []byte, msg proto.Message) error
- func GetMsgFromParam(params graphql.ResolveParams, paramName string, msg proto.Message) error
- func GetResultError(result *graphql.Result) error
- func MakeGraphQLErrorResult(err error) *graphql.Result
- func MakeMsgFromResult(result *graphql.Result, msg proto.Message) error
- func MakeObjFromResult(result *graphql.Result, obj interface{}) error
- func MakeParamsFromMsg(params map[string]interface{}, paramName string, msg proto.Message) error
- func PutMsg2DB(db database.Database, key []byte, msg proto.Message) error
- type AnkaDB
- type Config
- type DBConfig
- type DBLogic
- type DBMgr
- type FuncAnkaDBEvent
- type FuncOnQueryStream
- type SnapshotMgr
Constants ¶
View Source
const AnkaDBCoreVersion = "0.3.13"
AnkaDBCoreVersion - ankadb core version
Variables ¶
View Source
var ( // ErrGRPCListen - grpc service listen err ErrGRPCListen = errors.New("grpc service listen err") // ErrHTTPListen - http service listen err ErrHTTPListen = errors.New("http service listen err") // ErrLoadFileReadSize - loadfile invalid file read size ErrLoadFileReadSize = errors.New("loadfile invalid file read size") // ErrHTTPNoQuery - HTTP no query ErrHTTPNoQuery = errors.New("HTTP no query") // ErrCtxAnkaDB - context has not ankadb ErrCtxAnkaDB = errors.New("context has not ankadb") // ErrCtxCurDB - context has not currentdb ErrCtxCurDB = errors.New("context has not currentdb") // ErrQuertParams - query params err ErrQuertParams = errors.New("query params err") // ErrQuertResultDecode - query result decode err ErrQuertResultDecode = errors.New("query result decode err") // ErrCtxSnapshotMgr - query get snapshotMgr from err ErrCtxSnapshotMgr = errors.New("query get snapshotMgr from err") // ErrNotFoundDB - not found db ErrNotFoundDB = errors.New("not found db") // ErrNotFoundKey - not found key ErrNotFoundKey = errors.New("not found key") // ErrInvalidEvent - invalid event ErrInvalidEvent = errors.New("invalid event") )
View Source
var (
// EventOnStarted - onStarted
EventOnStarted = "onstarted"
)
Functions ¶
func GetContextValueDatabase ¶
GetContextValueDatabase -
func GetMsgFromDB ¶
GetMsgFromDB - get protobuf message from database
func GetMsgFromParam ¶
GetMsgFromParam - get protobuf message from param
func GetResultError ¶ added in v0.2.8
GetResultError - get result error
func MakeGraphQLErrorResult ¶
MakeGraphQLErrorResult -
func MakeMsgFromResult ¶
MakeMsgFromResult - make protobuf object from graphql.Result
func MakeObjFromResult ¶
MakeObjFromResult - make object from graphql.Result
func MakeParamsFromMsg ¶
MakeParamsFromMsg - change protobuf message to param
Types ¶
type AnkaDB ¶
type AnkaDB interface {
// Start - start service
Start(ctx context.Context) error
// LocalQuery - local query
LocalQuery(ctx context.Context, request string, values map[string]interface{}) (*graphql.Result, 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
// 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
}
AnkaDB - AnkaDB interface
func GetContextValueAnkaDB ¶
GetContextValueAnkaDB -
type Config ¶
type Config struct {
AddrGRPC string `yaml:"addrgrpc"`
PathDBRoot string `yaml:"pathdbroot"`
AddrHTTP string `yaml:"addrhttp"`
ListDB []DBConfig `yaml:"listdb"`
}
Config -
type DBConfig ¶
type DBConfig struct {
Name string `yaml:"name"`
Engine string `yaml:"engine"`
PathDB string `yaml:"pathdb"`
}
DBConfig -
type DBLogic ¶
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
}
DBLogic -
type DBMgr ¶
type DBMgr interface {
AddDB(cfg DBConfig) error
GetDB(name string) database.Database
GetMgrSnapshot(name string) *SnapshotMgr
}
DBMgr -
type FuncAnkaDBEvent ¶ added in v0.3.13
FuncAnkaDBEvent - func event
type FuncOnQueryStream ¶
type FuncOnQueryStream func(*pb.ReplyQuery)
FuncOnQueryStream - use in DBLogic.OnQueryStream
type SnapshotMgr ¶
type SnapshotMgr struct {
// contains filtered or unexported fields
}
SnapshotMgr - key list snapshot
func (*SnapshotMgr) Add ¶
func (mgr *SnapshotMgr) Add(pSnapshot *pb.Snapshot) (int64, error)
Add - add snapshot
func (*SnapshotMgr) Get ¶
func (mgr *SnapshotMgr) Get(snapshotid int64) *pb.Snapshot
Get - get snapshot
func (*SnapshotMgr) NewSnapshot ¶
func (mgr *SnapshotMgr) NewSnapshot(prefix []byte) (*pb.Snapshot, error)
NewSnapshot - new snapshot
Source Files
¶
Click to show internal directories.
Click to hide internal directories.