Documentation ¶
Index ¶
- Variables
- type RaftKV
- func (kv *RaftKV) Get(ctx context.Context, req *pb.GetReq) (*pb.GetRes, error)
- func (kv *RaftKV) Kill()
- func (kv *RaftKV) OpenSession(ctx context.Context, req *pb.OpenSessionReq) (*pb.OpenSessionRes, error)
- func (kv *RaftKV) Put(ctx context.Context, req *pb.PutReq) (*pb.PutRes, error)
- func (kv *RaftKV) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var ( OpTimeout time.Duration StoragePath string )
flags
Functions ¶
This section is empty.
Types ¶
type RaftKV ¶
type RaftKV struct {
// contains filtered or unexported fields
}
RaftKV consist of: KVStorage, Raft, SessionManager
func StartRaftKV ¶
func (*RaftKV) OpenSession ¶
func (kv *RaftKV) OpenSession(ctx context.Context, req *pb.OpenSessionReq) (*pb.OpenSessionRes, error)
OpenSession rpc interface
Click to show internal directories.
Click to hide internal directories.