Documentation ¶
Index ¶
- func MetadataByRelease(localIp string, releaseRaftConf *pb.RaftReleaseConfig) *raft.RaftMetadata
- type Engine
- type KVServer
- func (kv *KVServer) ChangeServing(serve int32)
- func (kv *KVServer) Del(ctx context.Context, in *pb.DelRequest) (*pb.DelResponse, error)
- func (kv *KVServer) Get(ctx context.Context, in *pb.GetRequest) (*pb.GetResponse, error)
- func (kv *KVServer) Put(ctx context.Context, in *pb.PutRequest) (*pb.PutResponse, error)
- type RaftControlServer
- func (rc *RaftControlServer) AddRaftObserverReplica(ctx context.Context, in *pb.RaftOp) (*pb.WEmpty, error)
- func (rc *RaftControlServer) AddRaftReplica(ctx context.Context, in *pb.RaftOp) (*pb.WEmpty, error)
- func (rc *RaftControlServer) ChangeServing(serve int32)
- func (rc *RaftControlServer) RaftShardInfo(ctx context.Context, in *pb.WEmpty) (*pb.RaftInfoResponse, error)
- func (rc *RaftControlServer) ReleaseRaftConf(ctx context.Context, in *pb.RaftReleaseConfig) (*pb.WEmpty, error)
- func (rc *RaftControlServer) ReleaseRaftShard(ctx context.Context, in *pb.RaftShard) (*pb.WEmpty, error)
- func (rc *RaftControlServer) RemoveRaftReplica(ctx context.Context, in *pb.RaftOp) (*pb.WEmpty, error)
- func (rc *RaftControlServer) StopRaftStatus()
- func (rc *RaftControlServer) UpdateRaftShardIds(ctx context.Context, in *pb.RaftShardIds) (*pb.WEmpty, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MetadataByRelease ¶
func MetadataByRelease(localIp string, releaseRaftConf *pb.RaftReleaseConfig) *raft.RaftMetadata
Types ¶
type KVServer ¶
type KVServer struct {
// contains filtered or unexported fields
}
func (*KVServer) ChangeServing ¶
func (*KVServer) Del ¶
func (kv *KVServer) Del(ctx context.Context, in *pb.DelRequest) (*pb.DelResponse, error)
func (*KVServer) Get ¶
func (kv *KVServer) Get(ctx context.Context, in *pb.GetRequest) (*pb.GetResponse, error)
func (*KVServer) Put ¶
func (kv *KVServer) Put(ctx context.Context, in *pb.PutRequest) (*pb.PutResponse, error)
type RaftControlServer ¶
type RaftControlServer struct {
// contains filtered or unexported fields
}
func NewRaftControlServer ¶
func NewRaftControlServer(cf, localIp, raftDir string, grpcPort uint16, raftStorage *raft.Storage, raftConfCh chan *pb.RaftReleaseConfig) *RaftControlServer
func (*RaftControlServer) AddRaftObserverReplica ¶
func (*RaftControlServer) AddRaftReplica ¶
func (*RaftControlServer) ChangeServing ¶
func (rc *RaftControlServer) ChangeServing(serve int32)
func (*RaftControlServer) RaftShardInfo ¶
func (rc *RaftControlServer) RaftShardInfo(ctx context.Context, in *pb.WEmpty) (*pb.RaftInfoResponse, error)
func (*RaftControlServer) ReleaseRaftConf ¶
func (rc *RaftControlServer) ReleaseRaftConf(ctx context.Context, in *pb.RaftReleaseConfig) (*pb.WEmpty, error)
ReleaseRaftConf 前端推送启动配置接口,不需要判断ready
func (*RaftControlServer) ReleaseRaftShard ¶
func (*RaftControlServer) RemoveRaftReplica ¶
func (*RaftControlServer) StopRaftStatus ¶
func (rc *RaftControlServer) StopRaftStatus()
func (*RaftControlServer) UpdateRaftShardIds ¶
func (rc *RaftControlServer) UpdateRaftShardIds(ctx context.Context, in *pb.RaftShardIds) (*pb.WEmpty, error)
Click to show internal directories.
Click to hide internal directories.