Documentation ¶
Index ¶
- Constants
- type KvMgr
- func (t *KvMgr) Apply(ctx context.Context, operTypes []int32, datas [][]byte, ...) (err error)
- func (t *KvMgr) Delete(key string) (err error)
- func (t *KvMgr) Flush(ctx context.Context) error
- func (t *KvMgr) Get(key string) (val []byte, err error)
- func (t *KvMgr) GetModuleName() string
- func (t *KvMgr) List(opts *clustermgr.ListKvOpts) (ret *clustermgr.ListKvRet, err error)
- func (t *KvMgr) LoadData(ctx context.Context) error
- func (t *KvMgr) NotifyLeaderChange(ctx context.Context, leader uint64, host string)
- func (t *KvMgr) Set(key string, value []byte) (err error)
- func (t *KvMgr) SetModuleName(module string)
- type KvMgrAPI
Constants ¶
View Source
const ( OperTypeSetKv = iota + 1 OperTypeDeleteKv )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KvMgr ¶
type KvMgr struct {
// contains filtered or unexported fields
}
func (*KvMgr) GetModuleName ¶
func (*KvMgr) List ¶
func (t *KvMgr) List(opts *clustermgr.ListKvOpts) (ret *clustermgr.ListKvRet, err error)
func (*KvMgr) NotifyLeaderChange ¶
Switch manager work when leader change
func (*KvMgr) SetModuleName ¶
type KvMgrAPI ¶
type KvMgrAPI interface { Get(key string) (val []byte, err error) Set(key string, value []byte) (err error) List(opt *clustermgr.ListKvOpts) (ret *clustermgr.ListKvRet, err error) Delete(key string) (err error) }
Click to show internal directories.
Click to hide internal directories.