Versions in this module Expand all Collapse all v0 v0.0.5 Jun 15, 2020 v0.0.4 Jun 10, 2020 Changes in this version + var File_cluster_proto protoreflect.FileDescriptor + func RegisterClusterLeaderServiceServer(s *grpc.Server, srv ClusterLeaderServiceServer) + type ClusterLeaderServiceClient interface + ConfirmShardMap func(ctx context.Context, in *ConfirmShardMapRequest, opts ...grpc.CallOption) (*ConfirmShardMapResponse, error) + func NewClusterLeaderServiceClient(cc grpc.ClientConnInterface) ClusterLeaderServiceClient + type ClusterLeaderServiceServer interface + ConfirmShardMap func(context.Context, *ConfirmShardMapRequest) (*ConfirmShardMapResponse, error) + type CommitShardMapMessage struct + Nodes []string + ShardMapLogIndex int64 + func (*CommitShardMapMessage) Descriptor() ([]byte, []int) + func (*CommitShardMapMessage) ProtoMessage() + func (x *CommitShardMapMessage) GetNodes() []string + func (x *CommitShardMapMessage) GetShardMapLogIndex() int64 + func (x *CommitShardMapMessage) ProtoReflect() protoreflect.Message + func (x *CommitShardMapMessage) Reset() + func (x *CommitShardMapMessage) String() string + type ConfirmShardMapRequest struct + LogIndex int64 + NodeID string + func (*ConfirmShardMapRequest) Descriptor() ([]byte, []int) + func (*ConfirmShardMapRequest) ProtoMessage() + func (x *ConfirmShardMapRequest) GetLogIndex() int64 + func (x *ConfirmShardMapRequest) GetNodeID() string + func (x *ConfirmShardMapRequest) ProtoReflect() protoreflect.Message + func (x *ConfirmShardMapRequest) Reset() + func (x *ConfirmShardMapRequest) String() string + type ConfirmShardMapResponse struct + CurrentIndex int64 + Success bool + func (*ConfirmShardMapResponse) Descriptor() ([]byte, []int) + func (*ConfirmShardMapResponse) ProtoMessage() + func (x *ConfirmShardMapResponse) GetCurrentIndex() int64 + func (x *ConfirmShardMapResponse) GetSuccess() bool + func (x *ConfirmShardMapResponse) ProtoReflect() protoreflect.Message + func (x *ConfirmShardMapResponse) Reset() + func (x *ConfirmShardMapResponse) String() string + type UnimplementedClusterLeaderServiceServer struct + func (*UnimplementedClusterLeaderServiceServer) ConfirmShardMap(context.Context, *ConfirmShardMapRequest) (*ConfirmShardMapResponse, error)
Go to main page