clusterpb

Sep 4, 2020

Changes in this version

+ type GetTopologyRequest struct

+ ClusterID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTopologyRequest) Descriptor() ([]byte, []int)

+ func (*GetTopologyRequest) ProtoMessage()

+ func (m *GetTopologyRequest) GetClusterID() string

+ func (m *GetTopologyRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetTopologyRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetTopologyRequest) Reset()

+ func (m *GetTopologyRequest) Size() (n int)

+ func (m *GetTopologyRequest) String() string

+ func (m *GetTopologyRequest) Unmarshal(dAtA []byte) error

+ func (m *GetTopologyRequest) XXX_DiscardUnknown()

+ func (m *GetTopologyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTopologyRequest) XXX_Merge(src proto.Message)

+ func (m *GetTopologyRequest) XXX_Size() int

+ func (m *GetTopologyRequest) XXX_Unmarshal(b []byte) error

+ type GetTopologyResponse struct

+ ClusterID string

+ Committed uint64

+ Members []*TopologyMemberStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTopologyResponse) Descriptor() ([]byte, []int)

+ func (*GetTopologyResponse) ProtoMessage()

+ func (m *GetTopologyResponse) GetClusterID() string

+ func (m *GetTopologyResponse) GetCommitted() uint64

+ func (m *GetTopologyResponse) GetMembers() []*TopologyMemberStatus

+ func (m *GetTopologyResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetTopologyResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetTopologyResponse) Reset()

+ func (m *GetTopologyResponse) Size() (n int)

+ func (m *GetTopologyResponse) String() string

+ func (m *GetTopologyResponse) Unmarshal(dAtA []byte) error

+ func (m *GetTopologyResponse) XXX_DiscardUnknown()

+ func (m *GetTopologyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetTopologyResponse) XXX_Merge(src proto.Message)

+ func (m *GetTopologyResponse) XXX_Size() int

+ func (m *GetTopologyResponse) XXX_Unmarshal(b []byte) error

type MultiRaftClient

+ GetTopology func(ctx context.Context, in *GetTopologyRequest, opts ...grpc.CallOption) (*GetTopologyResponse, error)

+ PromoteMember func(ctx context.Context, in *PromoteMemberRequest, opts ...grpc.CallOption) (*PromoteMemberResponse, error)

type MultiRaftServer

+ GetTopology func(context.Context, *GetTopologyRequest) (*GetTopologyResponse, error)

+ PromoteMember func(context.Context, *PromoteMemberRequest) (*PromoteMemberResponse, error)

+ type PromoteMemberRequest struct

+ ClusterID string

+ Context *RaftContext

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PromoteMemberRequest) Descriptor() ([]byte, []int)

+ func (*PromoteMemberRequest) ProtoMessage()

+ func (m *PromoteMemberRequest) GetClusterID() string

+ func (m *PromoteMemberRequest) GetContext() *RaftContext

+ func (m *PromoteMemberRequest) Marshal() (dAtA []byte, err error)

+ func (m *PromoteMemberRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PromoteMemberRequest) Reset()

+ func (m *PromoteMemberRequest) Size() (n int)

+ func (m *PromoteMemberRequest) String() string

+ func (m *PromoteMemberRequest) Unmarshal(dAtA []byte) error

+ func (m *PromoteMemberRequest) XXX_DiscardUnknown()

+ func (m *PromoteMemberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PromoteMemberRequest) XXX_Merge(src proto.Message)

+ func (m *PromoteMemberRequest) XXX_Size() int

+ func (m *PromoteMemberRequest) XXX_Unmarshal(b []byte) error

+ type PromoteMemberResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PromoteMemberResponse) Descriptor() ([]byte, []int)

+ func (*PromoteMemberResponse) ProtoMessage()

+ func (m *PromoteMemberResponse) Marshal() (dAtA []byte, err error)

+ func (m *PromoteMemberResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PromoteMemberResponse) Reset()

+ func (m *PromoteMemberResponse) Size() (n int)

+ func (m *PromoteMemberResponse) String() string

+ func (m *PromoteMemberResponse) Unmarshal(dAtA []byte) error

+ func (m *PromoteMemberResponse) XXX_DiscardUnknown()

+ func (m *PromoteMemberResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PromoteMemberResponse) XXX_Merge(src proto.Message)

+ func (m *PromoteMemberResponse) XXX_Size() int

+ func (m *PromoteMemberResponse) XXX_Unmarshal(b []byte) error

type RaftClient

+ GetTopology func(ctx context.Context, in *GetTopologyRequest, opts ...grpc.CallOption) (*GetTopologyResponse, error)

+ PromoteMember func(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*PromoteMemberResponse, error)

type RaftServer

+ GetTopology func(context.Context, *GetTopologyRequest) (*GetTopologyResponse, error)

+ PromoteMember func(context.Context, *RaftContext) (*PromoteMemberResponse, error)

+ type TopologyMemberStatus struct

+ Address string

+ Applied uint64

+ ID uint64

+ IsAlive bool

+ IsLeader bool

+ IsVoter bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TopologyMemberStatus) Descriptor() ([]byte, []int)

+ func (*TopologyMemberStatus) ProtoMessage()

+ func (m *TopologyMemberStatus) GetAddress() string

+ func (m *TopologyMemberStatus) GetApplied() uint64

+ func (m *TopologyMemberStatus) GetID() uint64

+ func (m *TopologyMemberStatus) GetIsAlive() bool

+ func (m *TopologyMemberStatus) GetIsLeader() bool

+ func (m *TopologyMemberStatus) GetIsVoter() bool

+ func (m *TopologyMemberStatus) Marshal() (dAtA []byte, err error)

+ func (m *TopologyMemberStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *TopologyMemberStatus) Reset()

+ func (m *TopologyMemberStatus) Size() (n int)

+ func (m *TopologyMemberStatus) String() string

+ func (m *TopologyMemberStatus) Unmarshal(dAtA []byte) error

+ func (m *TopologyMemberStatus) XXX_DiscardUnknown()

+ func (m *TopologyMemberStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TopologyMemberStatus) XXX_Merge(src proto.Message)

+ func (m *TopologyMemberStatus) XXX_Size() int

+ func (m *TopologyMemberStatus) XXX_Unmarshal(b []byte) error

Aug 30, 2020

Changes in this version

type GetMembersResponse

+ CommittedIndex uint64

+ func (m *GetMembersResponse) GetCommittedIndex() uint64

Aug 27, 2020

Changes in this version

type MultiRaftClient

+ RemoveMember func(ctx context.Context, in *RemoveMultiRaftMemberRequest, opts ...grpc.CallOption) (*RemoveMultiRaftMemberResponse, error)

type MultiRaftServer

+ RemoveMember func(context.Context, *RemoveMultiRaftMemberRequest) (*RemoveMultiRaftMemberResponse, error)

type RaftClient

+ RemoveMember func(ctx context.Context, in *RemoveMemberRequest, opts ...grpc.CallOption) (*RemoveMemberResponse, error)

type RaftServer

+ RemoveMember func(context.Context, *RemoveMemberRequest) (*RemoveMemberResponse, error)

+ type RemoveMemberRequest struct

+ ID uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RemoveMemberRequest) Descriptor() ([]byte, []int)

+ func (*RemoveMemberRequest) ProtoMessage()

+ func (m *RemoveMemberRequest) GetID() uint64

+ func (m *RemoveMemberRequest) Marshal() (dAtA []byte, err error)

+ func (m *RemoveMemberRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RemoveMemberRequest) Reset()

+ func (m *RemoveMemberRequest) Size() (n int)

+ func (m *RemoveMemberRequest) String() string

+ func (m *RemoveMemberRequest) Unmarshal(dAtA []byte) error

+ func (m *RemoveMemberRequest) XXX_DiscardUnknown()

+ func (m *RemoveMemberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveMemberRequest) XXX_Merge(src proto.Message)

+ func (m *RemoveMemberRequest) XXX_Size() int

+ func (m *RemoveMemberRequest) XXX_Unmarshal(b []byte) error

+ type RemoveMemberResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RemoveMemberResponse) Descriptor() ([]byte, []int)

+ func (*RemoveMemberResponse) ProtoMessage()

+ func (m *RemoveMemberResponse) Marshal() (dAtA []byte, err error)

+ func (m *RemoveMemberResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RemoveMemberResponse) Reset()

+ func (m *RemoveMemberResponse) Size() (n int)

+ func (m *RemoveMemberResponse) String() string

+ func (m *RemoveMemberResponse) Unmarshal(dAtA []byte) error

+ func (m *RemoveMemberResponse) XXX_DiscardUnknown()

+ func (m *RemoveMemberResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveMemberResponse) XXX_Merge(src proto.Message)

+ func (m *RemoveMemberResponse) XXX_Size() int

+ func (m *RemoveMemberResponse) XXX_Unmarshal(b []byte) error

+ type RemoveMultiRaftMemberRequest struct

+ ClusterID string

+ ID uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RemoveMultiRaftMemberRequest) Descriptor() ([]byte, []int)

+ func (*RemoveMultiRaftMemberRequest) ProtoMessage()

+ func (m *RemoveMultiRaftMemberRequest) GetClusterID() string

+ func (m *RemoveMultiRaftMemberRequest) GetID() uint64

+ func (m *RemoveMultiRaftMemberRequest) Marshal() (dAtA []byte, err error)

+ func (m *RemoveMultiRaftMemberRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RemoveMultiRaftMemberRequest) Reset()

+ func (m *RemoveMultiRaftMemberRequest) Size() (n int)

+ func (m *RemoveMultiRaftMemberRequest) String() string

+ func (m *RemoveMultiRaftMemberRequest) Unmarshal(dAtA []byte) error

+ func (m *RemoveMultiRaftMemberRequest) XXX_DiscardUnknown()

+ func (m *RemoveMultiRaftMemberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveMultiRaftMemberRequest) XXX_Merge(src proto.Message)

+ func (m *RemoveMultiRaftMemberRequest) XXX_Size() int

+ func (m *RemoveMultiRaftMemberRequest) XXX_Unmarshal(b []byte) error

+ type RemoveMultiRaftMemberResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RemoveMultiRaftMemberResponse) Descriptor() ([]byte, []int)

+ func (*RemoveMultiRaftMemberResponse) ProtoMessage()

+ func (m *RemoveMultiRaftMemberResponse) Marshal() (dAtA []byte, err error)

+ func (m *RemoveMultiRaftMemberResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RemoveMultiRaftMemberResponse) Reset()

+ func (m *RemoveMultiRaftMemberResponse) Size() (n int)

+ func (m *RemoveMultiRaftMemberResponse) String() string

+ func (m *RemoveMultiRaftMemberResponse) Unmarshal(dAtA []byte) error

+ func (m *RemoveMultiRaftMemberResponse) XXX_DiscardUnknown()

+ func (m *RemoveMultiRaftMemberResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveMultiRaftMemberResponse) XXX_Merge(src proto.Message)

+ func (m *RemoveMultiRaftMemberResponse) XXX_Size() int

+ func (m *RemoveMultiRaftMemberResponse) XXX_Unmarshal(b []byte) error

Aug 26, 2020

Changes in this version

type JoinClusterResponse

+ Commit uint64

+ func (m *JoinClusterResponse) GetCommit() uint64

Jun 18, 2020

Changes in this version

+ var ErrIntOverflowCluster = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthCluster = fmt.Errorf("proto: negative length found during unmarshaling")

+ func RegisterMultiRaftServer(s *grpc.Server, srv MultiRaftServer)

type GetMembersRequest

+ ClusterID string

+ func (m *GetMembersRequest) GetClusterID() string

+ func (m *GetMembersRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetMembersRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetMembersRequest) Size() (n int)

+ func (m *GetMembersRequest) Unmarshal(dAtA []byte) error

type GetMembersResponse

+ func (m *GetMembersResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetMembersResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetMembersResponse) Size() (n int)

+ func (m *GetMembersResponse) Unmarshal(dAtA []byte) error

type GetStatusRequest

+ ClusterID string

+ func (m *GetStatusRequest) GetClusterID() string

+ func (m *GetStatusRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetStatusRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetStatusRequest) Size() (n int)

+ func (m *GetStatusRequest) Unmarshal(dAtA []byte) error

type GetStatusResponse

+ func (m *GetStatusResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetStatusResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetStatusResponse) Size() (n int)

+ func (m *GetStatusResponse) Unmarshal(dAtA []byte) error

+ type JoinClusterRequest struct

+ ClusterID string

+ Context *RaftContext

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*JoinClusterRequest) Descriptor() ([]byte, []int)

+ func (*JoinClusterRequest) ProtoMessage()

+ func (m *JoinClusterRequest) GetClusterID() string

+ func (m *JoinClusterRequest) GetContext() *RaftContext

+ func (m *JoinClusterRequest) Marshal() (dAtA []byte, err error)

+ func (m *JoinClusterRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *JoinClusterRequest) Reset()

+ func (m *JoinClusterRequest) Size() (n int)

+ func (m *JoinClusterRequest) String() string

+ func (m *JoinClusterRequest) Unmarshal(dAtA []byte) error

+ func (m *JoinClusterRequest) XXX_DiscardUnknown()

+ func (m *JoinClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *JoinClusterRequest) XXX_Merge(src proto.Message)

+ func (m *JoinClusterRequest) XXX_Size() int

+ func (m *JoinClusterRequest) XXX_Unmarshal(b []byte) error

type JoinClusterResponse

+ func (m *JoinClusterResponse) Marshal() (dAtA []byte, err error)

+ func (m *JoinClusterResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *JoinClusterResponse) Size() (n int)

+ func (m *JoinClusterResponse) Unmarshal(dAtA []byte) error

type Member

+ func (m *Member) Marshal() (dAtA []byte, err error)

+ func (m *Member) MarshalTo(dAtA []byte) (int, error)

+ func (m *Member) Size() (n int)

+ func (m *Member) Unmarshal(dAtA []byte) error

+ type MultiRaftClient interface

+ GetMembers func(ctx context.Context, in *GetMembersRequest, opts ...grpc.CallOption) (*GetMembersResponse, error)

+ GetStatus func(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)

+ JoinCluster func(ctx context.Context, in *JoinClusterRequest, opts ...grpc.CallOption) (*JoinClusterResponse, error)

+ ProcessMessage func(ctx context.Context, in *ProcessMessageRequest, opts ...grpc.CallOption) (*Payload, error)

+ func NewMultiRaftClient(cc *grpc.ClientConn) MultiRaftClient

+ type MultiRaftServer interface

+ GetMembers func(context.Context, *GetMembersRequest) (*GetMembersResponse, error)

+ GetStatus func(context.Context, *GetStatusRequest) (*GetStatusResponse, error)

+ JoinCluster func(context.Context, *JoinClusterRequest) (*JoinClusterResponse, error)

+ ProcessMessage func(context.Context, *ProcessMessageRequest) (*Payload, error)

type Payload

+ func (m *Payload) Marshal() (dAtA []byte, err error)

+ func (m *Payload) MarshalTo(dAtA []byte) (int, error)

+ func (m *Payload) Size() (n int)

+ func (m *Payload) Unmarshal(dAtA []byte) error

type PeerResponse

+ func (m *PeerResponse) Marshal() (dAtA []byte, err error)

+ func (m *PeerResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PeerResponse) Size() (n int)

+ func (m *PeerResponse) Unmarshal(dAtA []byte) error

+ type ProcessMessageRequest struct

+ ClusterID string

+ Message *raftpb.Message

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ProcessMessageRequest) Descriptor() ([]byte, []int)

+ func (*ProcessMessageRequest) ProtoMessage()

+ func (m *ProcessMessageRequest) GetClusterID() string

+ func (m *ProcessMessageRequest) GetMessage() *raftpb.Message

+ func (m *ProcessMessageRequest) Marshal() (dAtA []byte, err error)

+ func (m *ProcessMessageRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProcessMessageRequest) Reset()

+ func (m *ProcessMessageRequest) Size() (n int)

+ func (m *ProcessMessageRequest) String() string

+ func (m *ProcessMessageRequest) Unmarshal(dAtA []byte) error

+ func (m *ProcessMessageRequest) XXX_DiscardUnknown()

+ func (m *ProcessMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProcessMessageRequest) XXX_Merge(src proto.Message)

+ func (m *ProcessMessageRequest) XXX_Size() int

+ func (m *ProcessMessageRequest) XXX_Unmarshal(b []byte) error

type RaftContext

+ Clusters []string

+ func (m *RaftContext) GetClusters() []string

+ func (m *RaftContext) Marshal() (dAtA []byte, err error)

+ func (m *RaftContext) MarshalTo(dAtA []byte) (int, error)

+ func (m *RaftContext) Size() (n int)

+ func (m *RaftContext) Unmarshal(dAtA []byte) error

Jun 1, 2020

Changes in this version

+ func RegisterNodeServer(s *grpc.Server, srv NodeServer)

+ func RegisterRaftServer(s *grpc.Server, srv RaftServer)

+ type GetMembersRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetMembersRequest) Descriptor() ([]byte, []int)

+ func (*GetMembersRequest) ProtoMessage()

+ func (m *GetMembersRequest) Reset()

+ func (m *GetMembersRequest) String() string

+ func (m *GetMembersRequest) XXX_DiscardUnknown()

+ func (m *GetMembersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetMembersRequest) XXX_Merge(src proto.Message)

+ func (m *GetMembersRequest) XXX_Size() int

+ func (m *GetMembersRequest) XXX_Unmarshal(b []byte) error

+ type GetMembersResponse struct

+ Members []*Member

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetMembersResponse) Descriptor() ([]byte, []int)

+ func (*GetMembersResponse) ProtoMessage()

+ func (m *GetMembersResponse) GetMembers() []*Member

+ func (m *GetMembersResponse) Reset()

+ func (m *GetMembersResponse) String() string

+ func (m *GetMembersResponse) XXX_DiscardUnknown()

+ func (m *GetMembersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetMembersResponse) XXX_Merge(src proto.Message)

+ func (m *GetMembersResponse) XXX_Size() int

+ func (m *GetMembersResponse) XXX_Unmarshal(b []byte) error

+ type GetStatusRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetStatusRequest) Descriptor() ([]byte, []int)

+ func (*GetStatusRequest) ProtoMessage()

+ func (m *GetStatusRequest) Reset()

+ func (m *GetStatusRequest) String() string

+ func (m *GetStatusRequest) XXX_DiscardUnknown()

+ func (m *GetStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetStatusRequest) XXX_Merge(src proto.Message)

+ func (m *GetStatusRequest) XXX_Size() int

+ func (m *GetStatusRequest) XXX_Unmarshal(b []byte) error

+ type GetStatusResponse struct

+ HasBeenBootstrapped bool

+ IsInCluster bool

+ IsLeader bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetStatusResponse) Descriptor() ([]byte, []int)

+ func (*GetStatusResponse) ProtoMessage()

+ func (m *GetStatusResponse) GetHasBeenBootstrapped() bool

+ func (m *GetStatusResponse) GetIsInCluster() bool

+ func (m *GetStatusResponse) GetIsLeader() bool

+ func (m *GetStatusResponse) Reset()

+ func (m *GetStatusResponse) String() string

+ func (m *GetStatusResponse) XXX_DiscardUnknown()

+ func (m *GetStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetStatusResponse) XXX_Merge(src proto.Message)

+ func (m *GetStatusResponse) XXX_Size() int

+ func (m *GetStatusResponse) XXX_Unmarshal(b []byte) error

+ type JoinClusterResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*JoinClusterResponse) Descriptor() ([]byte, []int)

+ func (*JoinClusterResponse) ProtoMessage()

+ func (m *JoinClusterResponse) Reset()

+ func (m *JoinClusterResponse) String() string

+ func (m *JoinClusterResponse) XXX_DiscardUnknown()

+ func (m *JoinClusterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *JoinClusterResponse) XXX_Merge(src proto.Message)

+ func (m *JoinClusterResponse) XXX_Size() int

+ func (m *JoinClusterResponse) XXX_Unmarshal(b []byte) error

+ type Member struct

+ Address string

+ ID uint64

+ IsAlive bool

+ IsLeader bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Member) Descriptor() ([]byte, []int)

+ func (*Member) ProtoMessage()

+ func (m *Member) GetAddress() string

+ func (m *Member) GetID() uint64

+ func (m *Member) GetIsAlive() bool

+ func (m *Member) GetIsLeader() bool

+ func (m *Member) Reset()

+ func (m *Member) String() string

+ func (m *Member) XXX_DiscardUnknown()

+ func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Member) XXX_Merge(src proto.Message)

+ func (m *Member) XXX_Size() int

+ func (m *Member) XXX_Unmarshal(b []byte) error

+ type NodeClient interface

+ func NewNodeClient(cc *grpc.ClientConn) NodeClient

+ type NodeServer interface

+ type Payload struct

+ Data []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Payload) Descriptor() ([]byte, []int)

+ func (*Payload) ProtoMessage()

+ func (m *Payload) GetData() []byte

+ func (m *Payload) Reset()

+ func (m *Payload) String() string

+ func (m *Payload) XXX_DiscardUnknown()

+ func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Payload) XXX_Merge(src proto.Message)

+ func (m *Payload) XXX_Size() int

+ func (m *Payload) XXX_Unmarshal(b []byte) error

+ type PeerResponse struct

+ Status bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PeerResponse) Descriptor() ([]byte, []int)

+ func (*PeerResponse) ProtoMessage()

+ func (m *PeerResponse) GetStatus() bool

+ func (m *PeerResponse) Reset()

+ func (m *PeerResponse) String() string

+ func (m *PeerResponse) XXX_DiscardUnknown()

+ func (m *PeerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PeerResponse) XXX_Merge(src proto.Message)

+ func (m *PeerResponse) XXX_Size() int

+ func (m *PeerResponse) XXX_Unmarshal(b []byte) error

+ type RaftClient interface

+ GetMembers func(ctx context.Context, in *GetMembersRequest, opts ...grpc.CallOption) (*GetMembersResponse, error)

+ GetStatus func(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)

+ JoinCluster func(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*JoinClusterResponse, error)

+ ProcessMessage func(ctx context.Context, in *raftpb.Message, opts ...grpc.CallOption) (*Payload, error)

+ func NewRaftClient(cc *grpc.ClientConn) RaftClient

+ type RaftContext struct

+ Address string

+ ID uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RaftContext) Descriptor() ([]byte, []int)

+ func (*RaftContext) ProtoMessage()

+ func (m *RaftContext) GetAddress() string

+ func (m *RaftContext) GetID() uint64

+ func (m *RaftContext) Reset()

+ func (m *RaftContext) String() string

+ func (m *RaftContext) XXX_DiscardUnknown()

+ func (m *RaftContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RaftContext) XXX_Merge(src proto.Message)

+ func (m *RaftContext) XXX_Size() int

+ func (m *RaftContext) XXX_Unmarshal(b []byte) error

+ type RaftServer interface

+ GetMembers func(context.Context, *GetMembersRequest) (*GetMembersResponse, error)

+ GetStatus func(context.Context, *GetStatusRequest) (*GetStatusResponse, error)

+ JoinCluster func(context.Context, *RaftContext) (*JoinClusterResponse, error)

+ ProcessMessage func(context.Context, *raftpb.Message) (*Payload, error)

+ type UnimplementedNodeServer struct

+ type UnimplementedRaftServer struct

+ func (*UnimplementedRaftServer) GetMembers(ctx context.Context, req *GetMembersRequest) (*GetMembersResponse, error)

+ func (*UnimplementedRaftServer) GetStatus(ctx context.Context, req *GetStatusRequest) (*GetStatusResponse, error)

+ func (*UnimplementedRaftServer) JoinCluster(ctx context.Context, req *RaftContext) (*JoinClusterResponse, error)

+ func (*UnimplementedRaftServer) ProcessMessage(ctx context.Context, req *raftpb.Message) (*Payload, error)