Versions in this module Expand all Collapse all v0 v0.0.3 Jan 30, 2020 v0.0.2 Dec 10, 2019 Changes in this version + 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.ClientConn) ClusterLeaderServiceClient + type ClusterLeaderServiceServer interface + ConfirmShardMap func(context.Context, *ConfirmShardMapRequest) (*ConfirmShardMapResponse, error) + type CommitShardMapMessage struct + Nodes []string + ShardMapLogIndex int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CommitShardMapMessage) Descriptor() ([]byte, []int) + func (*CommitShardMapMessage) ProtoMessage() + func (m *CommitShardMapMessage) GetNodes() []string + func (m *CommitShardMapMessage) GetShardMapLogIndex() int64 + func (m *CommitShardMapMessage) Reset() + func (m *CommitShardMapMessage) String() string + func (m *CommitShardMapMessage) XXX_DiscardUnknown() + func (m *CommitShardMapMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CommitShardMapMessage) XXX_Merge(src proto.Message) + func (m *CommitShardMapMessage) XXX_Size() int + func (m *CommitShardMapMessage) XXX_Unmarshal(b []byte) error + type ConfirmShardMapRequest struct + LogIndex int64 + NodeID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConfirmShardMapRequest) Descriptor() ([]byte, []int) + func (*ConfirmShardMapRequest) ProtoMessage() + func (m *ConfirmShardMapRequest) GetLogIndex() int64 + func (m *ConfirmShardMapRequest) GetNodeID() string + func (m *ConfirmShardMapRequest) Reset() + func (m *ConfirmShardMapRequest) String() string + func (m *ConfirmShardMapRequest) XXX_DiscardUnknown() + func (m *ConfirmShardMapRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConfirmShardMapRequest) XXX_Merge(src proto.Message) + func (m *ConfirmShardMapRequest) XXX_Size() int + func (m *ConfirmShardMapRequest) XXX_Unmarshal(b []byte) error + type ConfirmShardMapResponse struct + CurrentIndex int64 + Success bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConfirmShardMapResponse) Descriptor() ([]byte, []int) + func (*ConfirmShardMapResponse) ProtoMessage() + func (m *ConfirmShardMapResponse) GetCurrentIndex() int64 + func (m *ConfirmShardMapResponse) GetSuccess() bool + func (m *ConfirmShardMapResponse) Reset() + func (m *ConfirmShardMapResponse) String() string + func (m *ConfirmShardMapResponse) XXX_DiscardUnknown() + func (m *ConfirmShardMapResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConfirmShardMapResponse) XXX_Merge(src proto.Message) + func (m *ConfirmShardMapResponse) XXX_Size() int + func (m *ConfirmShardMapResponse) XXX_Unmarshal(b []byte) error
Go to main page