clusterpb

package
v1.9.24 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 6, 2020 License: MPL-2.0 Imports: 7 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCluster = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCluster   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterMultiRaftServer added in v1.3.0 

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

func RegisterNodeServer 

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

func RegisterRaftServer 

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

Types

type GetMembersRequest 

type GetMembersRequest struct {
	ClusterID            string   `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetMembersRequest) Descriptor 

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

func (*GetMembersRequest) GetClusterID added in v1.3.0 

func (m *GetMembersRequest) GetClusterID() string

func (*GetMembersRequest) Marshal added in v1.3.0 

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

func (*GetMembersRequest) MarshalTo added in v1.3.0 

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

func (*GetMembersRequest) ProtoMessage 

func (*GetMembersRequest) ProtoMessage()

func (*GetMembersRequest) Reset 

func (m *GetMembersRequest) Reset()

func (*GetMembersRequest) Size added in v1.3.0 

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

func (*GetMembersRequest) String 

func (m *GetMembersRequest) String() string

func (*GetMembersRequest) Unmarshal added in v1.3.0 

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

func (*GetMembersRequest) XXX_DiscardUnknown 

func (m *GetMembersRequest) XXX_DiscardUnknown()

func (*GetMembersRequest) XXX_Marshal 

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

func (*GetMembersRequest) XXX_Merge 

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

func (*GetMembersRequest) XXX_Size 

func (m *GetMembersRequest) XXX_Size() int

func (*GetMembersRequest) XXX_Unmarshal 

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

type GetMembersResponse 

type GetMembersResponse struct {
	Members              []*Member `protobuf:"bytes,1,rep,name=Members,proto3" json:"Members,omitempty"`
	CommittedIndex       uint64    `protobuf:"varint,2,opt,name=CommittedIndex,proto3" json:"CommittedIndex,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetMembersResponse) Descriptor 

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

func (*GetMembersResponse) GetCommittedIndex added in v1.8.30 

func (m *GetMembersResponse) GetCommittedIndex() uint64

func (*GetMembersResponse) GetMembers 

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

func (*GetMembersResponse) Marshal added in v1.3.0 

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

func (*GetMembersResponse) MarshalTo added in v1.3.0 

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

func (*GetMembersResponse) ProtoMessage 

func (*GetMembersResponse) ProtoMessage()

func (*GetMembersResponse) Reset 

func (m *GetMembersResponse) Reset()

func (*GetMembersResponse) Size added in v1.3.0 

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

func (*GetMembersResponse) String 

func (m *GetMembersResponse) String() string

func (*GetMembersResponse) Unmarshal added in v1.3.0 

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

func (*GetMembersResponse) XXX_DiscardUnknown 

func (m *GetMembersResponse) XXX_DiscardUnknown()

func (*GetMembersResponse) XXX_Marshal 

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

func (*GetMembersResponse) XXX_Merge 

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

func (*GetMembersResponse) XXX_Size 

func (m *GetMembersResponse) XXX_Size() int

func (*GetMembersResponse) XXX_Unmarshal 

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

type GetStatusRequest 

type GetStatusRequest struct {
	ClusterID            string   `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStatusRequest) Descriptor 

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

func (*GetStatusRequest) GetClusterID added in v1.3.0 

func (m *GetStatusRequest) GetClusterID() string

func (*GetStatusRequest) Marshal added in v1.3.0 

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

func (*GetStatusRequest) MarshalTo added in v1.3.0 

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

func (*GetStatusRequest) ProtoMessage 

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) Reset 

func (m *GetStatusRequest) Reset()

func (*GetStatusRequest) Size added in v1.3.0 

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

func (*GetStatusRequest) String 

func (m *GetStatusRequest) String() string

func (*GetStatusRequest) Unmarshal added in v1.3.0 

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

func (*GetStatusRequest) XXX_DiscardUnknown 

func (m *GetStatusRequest) XXX_DiscardUnknown()

func (*GetStatusRequest) XXX_Marshal 

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

func (*GetStatusRequest) XXX_Merge 

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

func (*GetStatusRequest) XXX_Size 

func (m *GetStatusRequest) XXX_Size() int

func (*GetStatusRequest) XXX_Unmarshal 

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

type GetStatusResponse 

type GetStatusResponse struct {
	IsLeader             bool     `protobuf:"varint,1,opt,name=IsLeader,proto3" json:"IsLeader,omitempty"`
	HasBeenBootstrapped  bool     `protobuf:"varint,2,opt,name=HasBeenBootstrapped,proto3" json:"HasBeenBootstrapped,omitempty"`
	IsInCluster          bool     `protobuf:"varint,3,opt,name=IsInCluster,proto3" json:"IsInCluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStatusResponse) Descriptor 

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

func (*GetStatusResponse) GetHasBeenBootstrapped 

func (m *GetStatusResponse) GetHasBeenBootstrapped() bool

func (*GetStatusResponse) GetIsInCluster 

func (m *GetStatusResponse) GetIsInCluster() bool

func (*GetStatusResponse) GetIsLeader 

func (m *GetStatusResponse) GetIsLeader() bool

func (*GetStatusResponse) Marshal added in v1.3.0 

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

func (*GetStatusResponse) MarshalTo added in v1.3.0 

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

func (*GetStatusResponse) ProtoMessage 

func (*GetStatusResponse) ProtoMessage()

func (*GetStatusResponse) Reset 

func (m *GetStatusResponse) Reset()

func (*GetStatusResponse) Size added in v1.3.0 

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

func (*GetStatusResponse) String 

func (m *GetStatusResponse) String() string

func (*GetStatusResponse) Unmarshal added in v1.3.0 

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

func (*GetStatusResponse) XXX_DiscardUnknown 

func (m *GetStatusResponse) XXX_DiscardUnknown()

func (*GetStatusResponse) XXX_Marshal 

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

func (*GetStatusResponse) XXX_Merge 

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

func (*GetStatusResponse) XXX_Size 

func (m *GetStatusResponse) XXX_Size() int

func (*GetStatusResponse) XXX_Unmarshal 

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

type GetTopologyRequest added in v1.9.0 

type GetTopologyRequest struct {
	ClusterID            string   `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTopologyRequest) Descriptor added in v1.9.0 

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

func (*GetTopologyRequest) GetClusterID added in v1.9.0 

func (m *GetTopologyRequest) GetClusterID() string

func (*GetTopologyRequest) Marshal added in v1.9.0 

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

func (*GetTopologyRequest) MarshalTo added in v1.9.0 

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

func (*GetTopologyRequest) ProtoMessage added in v1.9.0 

func (*GetTopologyRequest) ProtoMessage()

func (*GetTopologyRequest) Reset added in v1.9.0 

func (m *GetTopologyRequest) Reset()

func (*GetTopologyRequest) Size added in v1.9.0 

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

func (*GetTopologyRequest) String added in v1.9.0 

func (m *GetTopologyRequest) String() string

func (*GetTopologyRequest) Unmarshal added in v1.9.0 

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

func (*GetTopologyRequest) XXX_DiscardUnknown added in v1.9.0 

func (m *GetTopologyRequest) XXX_DiscardUnknown()

func (*GetTopologyRequest) XXX_Marshal added in v1.9.0 

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

func (*GetTopologyRequest) XXX_Merge added in v1.9.0 

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

func (*GetTopologyRequest) XXX_Size added in v1.9.0 

func (m *GetTopologyRequest) XXX_Size() int

func (*GetTopologyRequest) XXX_Unmarshal added in v1.9.0 

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

type GetTopologyResponse added in v1.9.0 

type GetTopologyResponse struct {
	ClusterID            string                  `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"`
	Committed            uint64                  `protobuf:"varint,2,opt,name=Committed,proto3" json:"Committed,omitempty"`
	Members              []*TopologyMemberStatus `protobuf:"bytes,3,rep,name=Members,proto3" json:"Members,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*GetTopologyResponse) Descriptor added in v1.9.0 

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

func (*GetTopologyResponse) GetClusterID added in v1.9.0 

func (m *GetTopologyResponse) GetClusterID() string

func (*GetTopologyResponse) GetCommitted added in v1.9.0 

func (m *GetTopologyResponse) GetCommitted() uint64

func (*GetTopologyResponse) GetMembers added in v1.9.0 

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

func (*GetTopologyResponse) Marshal added in v1.9.0 

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

func (*GetTopologyResponse) MarshalTo added in v1.9.0 

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

func (*GetTopologyResponse) ProtoMessage added in v1.9.0 

func (*GetTopologyResponse) ProtoMessage()

func (*GetTopologyResponse) Reset added in v1.9.0 

func (m *GetTopologyResponse) Reset()

func (*GetTopologyResponse) Size added in v1.9.0 

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

func (*GetTopologyResponse) String added in v1.9.0 

func (m *GetTopologyResponse) String() string

func (*GetTopologyResponse) Unmarshal added in v1.9.0 

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

func (*GetTopologyResponse) XXX_DiscardUnknown added in v1.9.0 

func (m *GetTopologyResponse) XXX_DiscardUnknown()

func (*GetTopologyResponse) XXX_Marshal added in v1.9.0 

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

func (*GetTopologyResponse) XXX_Merge added in v1.9.0 

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

func (*GetTopologyResponse) XXX_Size added in v1.9.0 

func (m *GetTopologyResponse) XXX_Size() int

func (*GetTopologyResponse) XXX_Unmarshal added in v1.9.0 

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

type JoinClusterRequest added in v1.3.0 

type JoinClusterRequest struct {
	ClusterID            string       `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"`
	Context              *RaftContext `protobuf:"bytes,2,opt,name=Context,proto3" json:"Context,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*JoinClusterRequest) Descriptor added in v1.3.0 

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

func (*JoinClusterRequest) GetClusterID added in v1.3.0 

func (m *JoinClusterRequest) GetClusterID() string

func (*JoinClusterRequest) GetContext added in v1.3.0 

func (m *JoinClusterRequest) GetContext() *RaftContext

func (*JoinClusterRequest) Marshal added in v1.3.0 

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

func (*JoinClusterRequest) MarshalTo added in v1.3.0 

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

func (*JoinClusterRequest) ProtoMessage added in v1.3.0 

func (*JoinClusterRequest) ProtoMessage()

func (*JoinClusterRequest) Reset added in v1.3.0 

func (m *JoinClusterRequest) Reset()

func (*JoinClusterRequest) Size added in v1.3.0 

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

func (*JoinClusterRequest) String added in v1.3.0 

func (m *JoinClusterRequest) String() string

func (*JoinClusterRequest) Unmarshal added in v1.3.0 

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

func (*JoinClusterRequest) XXX_DiscardUnknown added in v1.3.0 

func (m *JoinClusterRequest) XXX_DiscardUnknown()

func (*JoinClusterRequest) XXX_Marshal added in v1.3.0 

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

func (*JoinClusterRequest) XXX_Merge added in v1.3.0 

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

func (*JoinClusterRequest) XXX_Size added in v1.3.0 

func (m *JoinClusterRequest) XXX_Size() int

func (*JoinClusterRequest) XXX_Unmarshal added in v1.3.0 

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

type JoinClusterResponse 

type JoinClusterResponse struct {
	Commit               uint64   `protobuf:"varint,1,opt,name=Commit,proto3" json:"Commit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JoinClusterResponse) Descriptor 

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

func (*JoinClusterResponse) GetCommit added in v1.8.4 

func (m *JoinClusterResponse) GetCommit() uint64

func (*JoinClusterResponse) Marshal added in v1.3.0 

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

func (*JoinClusterResponse) MarshalTo added in v1.3.0 

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

func (*JoinClusterResponse) ProtoMessage 

func (*JoinClusterResponse) ProtoMessage()

func (*JoinClusterResponse) Reset 

func (m *JoinClusterResponse) Reset()

func (*JoinClusterResponse) Size added in v1.3.0 

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

func (*JoinClusterResponse) String 

func (m *JoinClusterResponse) String() string

func (*JoinClusterResponse) Unmarshal added in v1.3.0 

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

func (*JoinClusterResponse) XXX_DiscardUnknown 

func (m *JoinClusterResponse) XXX_DiscardUnknown()

func (*JoinClusterResponse) XXX_Marshal 

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

func (*JoinClusterResponse) XXX_Merge 

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

func (*JoinClusterResponse) XXX_Size 

func (m *JoinClusterResponse) XXX_Size() int

func (*JoinClusterResponse) XXX_Unmarshal 

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

type Member 

type Member struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Address              string   `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"`
	IsLeader             bool     `protobuf:"varint,3,opt,name=IsLeader,proto3" json:"IsLeader,omitempty"`
	IsAlive              bool     `protobuf:"varint,4,opt,name=IsAlive,proto3" json:"IsAlive,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Member) Descriptor 

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

func (*Member) GetAddress 

func (m *Member) GetAddress() string

func (*Member) GetID 

func (m *Member) GetID() uint64

func (*Member) GetIsAlive 

func (m *Member) GetIsAlive() bool

func (*Member) GetIsLeader 

func (m *Member) GetIsLeader() bool

func (*Member) Marshal added in v1.3.0 

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

func (*Member) MarshalTo added in v1.3.0 

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

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) Reset 

func (m *Member) Reset()

func (*Member) Size added in v1.3.0 

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

func (*Member) String 

func (m *Member) String() string

func (*Member) Unmarshal added in v1.3.0 

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

func (*Member) XXX_DiscardUnknown 

func (m *Member) XXX_DiscardUnknown()

func (*Member) XXX_Marshal 

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

func (*Member) XXX_Merge 

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

func (*Member) XXX_Size 

func (m *Member) XXX_Size() int

func (*Member) XXX_Unmarshal 

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

type MultiRaftClient added in v1.3.0 

type MultiRaftClient interface {
	ProcessMessage(ctx context.Context, in *ProcessMessageRequest, opts ...grpc.CallOption) (*Payload, error)
	JoinCluster(ctx context.Context, in *JoinClusterRequest, opts ...grpc.CallOption) (*JoinClusterResponse, error)
	PromoteMember(ctx context.Context, in *PromoteMemberRequest, opts ...grpc.CallOption) (*PromoteMemberResponse, error)
	GetMembers(ctx context.Context, in *GetMembersRequest, opts ...grpc.CallOption) (*GetMembersResponse, error)
	GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)
	RemoveMember(ctx context.Context, in *RemoveMultiRaftMemberRequest, opts ...grpc.CallOption) (*RemoveMultiRaftMemberResponse, error)
	GetTopology(ctx context.Context, in *GetTopologyRequest, opts ...grpc.CallOption) (*GetTopologyResponse, error)
}

MultiRaftClient is the client API for MultiRaft service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMultiRaftClient added in v1.3.0 

func NewMultiRaftClient(cc *grpc.ClientConn) MultiRaftClient

type MultiRaftServer added in v1.3.0 

type MultiRaftServer interface {
	ProcessMessage(context.Context, *ProcessMessageRequest) (*Payload, error)
	JoinCluster(context.Context, *JoinClusterRequest) (*JoinClusterResponse, error)
	PromoteMember(context.Context, *PromoteMemberRequest) (*PromoteMemberResponse, error)
	GetMembers(context.Context, *GetMembersRequest) (*GetMembersResponse, error)
	GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
	RemoveMember(context.Context, *RemoveMultiRaftMemberRequest) (*RemoveMultiRaftMemberResponse, error)
	GetTopology(context.Context, *GetTopologyRequest) (*GetTopologyResponse, error)
}

MultiRaftServer is the server API for MultiRaft service.

type NodeClient 

type NodeClient interface {
}

NodeClient is the client API for Node service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNodeClient 

func NewNodeClient(cc *grpc.ClientConn) NodeClient

type NodeServer 

type NodeServer interface {
}

NodeServer is the server API for Node service.

type Payload 

type Payload struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Payload) Descriptor 

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

func (*Payload) GetData 

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

func (*Payload) Marshal added in v1.3.0 

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

func (*Payload) MarshalTo added in v1.3.0 

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

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) Reset 

func (m *Payload) Reset()

func (*Payload) Size added in v1.3.0 

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

func (*Payload) String 

func (m *Payload) String() string

func (*Payload) Unmarshal added in v1.3.0 

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

func (*Payload) XXX_DiscardUnknown 

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal 

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

func (*Payload) XXX_Merge 

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

func (*Payload) XXX_Size 

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal 

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

type PeerResponse 

type PeerResponse struct {
	Status               bool     `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerResponse) Descriptor 

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

func (*PeerResponse) GetStatus 

func (m *PeerResponse) GetStatus() bool

func (*PeerResponse) Marshal added in v1.3.0 

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

func (*PeerResponse) MarshalTo added in v1.3.0 

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

func (*PeerResponse) ProtoMessage 

func (*PeerResponse) ProtoMessage()

func (*PeerResponse) Reset 

func (m *PeerResponse) Reset()

func (*PeerResponse) Size added in v1.3.0 

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

func (*PeerResponse) String 

func (m *PeerResponse) String() string

func (*PeerResponse) Unmarshal added in v1.3.0 

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

func (*PeerResponse) XXX_DiscardUnknown 

func (m *PeerResponse) XXX_DiscardUnknown()

func (*PeerResponse) XXX_Marshal 

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

func (*PeerResponse) XXX_Merge 

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

func (*PeerResponse) XXX_Size 

func (m *PeerResponse) XXX_Size() int

func (*PeerResponse) XXX_Unmarshal 

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

type ProcessMessageRequest added in v1.3.0 

type ProcessMessageRequest struct {
	ClusterID            string          `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"`
	Message              *raftpb.Message `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ProcessMessageRequest) Descriptor added in v1.3.0 

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

func (*ProcessMessageRequest) GetClusterID added in v1.3.0 

func (m *ProcessMessageRequest) GetClusterID() string

func (*ProcessMessageRequest) GetMessage added in v1.3.0 

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

func (*ProcessMessageRequest) Marshal added in v1.3.0 

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

func (*ProcessMessageRequest) MarshalTo added in v1.3.0 

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

func (*ProcessMessageRequest) ProtoMessage added in v1.3.0 

func (*ProcessMessageRequest) ProtoMessage()

func (*ProcessMessageRequest) Reset added in v1.3.0 

func (m *ProcessMessageRequest) Reset()

func (*ProcessMessageRequest) Size added in v1.3.0 

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

func (*ProcessMessageRequest) String added in v1.3.0 

func (m *ProcessMessageRequest) String() string

func (*ProcessMessageRequest) Unmarshal added in v1.3.0 

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

func (*ProcessMessageRequest) XXX_DiscardUnknown added in v1.3.0 

func (m *ProcessMessageRequest) XXX_DiscardUnknown()

func (*ProcessMessageRequest) XXX_Marshal added in v1.3.0 

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

func (*ProcessMessageRequest) XXX_Merge added in v1.3.0 

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

func (*ProcessMessageRequest) XXX_Size added in v1.3.0 

func (m *ProcessMessageRequest) XXX_Size() int

func (*ProcessMessageRequest) XXX_Unmarshal added in v1.3.0 

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

type PromoteMemberRequest added in v1.9.0 

type PromoteMemberRequest struct {
	ClusterID            string       `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"`
	Context              *RaftContext `protobuf:"bytes,2,opt,name=Context,proto3" json:"Context,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PromoteMemberRequest) Descriptor added in v1.9.0 

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

func (*PromoteMemberRequest) GetClusterID added in v1.9.0 

func (m *PromoteMemberRequest) GetClusterID() string

func (*PromoteMemberRequest) GetContext added in v1.9.0 

func (m *PromoteMemberRequest) GetContext() *RaftContext

func (*PromoteMemberRequest) Marshal added in v1.9.0 

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

func (*PromoteMemberRequest) MarshalTo added in v1.9.0 

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

func (*PromoteMemberRequest) ProtoMessage added in v1.9.0 

func (*PromoteMemberRequest) ProtoMessage()

func (*PromoteMemberRequest) Reset added in v1.9.0 

func (m *PromoteMemberRequest) Reset()

func (*PromoteMemberRequest) Size added in v1.9.0 

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

func (*PromoteMemberRequest) String added in v1.9.0 

func (m *PromoteMemberRequest) String() string

func (*PromoteMemberRequest) Unmarshal added in v1.9.0 

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

func (*PromoteMemberRequest) XXX_DiscardUnknown added in v1.9.0 

func (m *PromoteMemberRequest) XXX_DiscardUnknown()

func (*PromoteMemberRequest) XXX_Marshal added in v1.9.0 

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

func (*PromoteMemberRequest) XXX_Merge added in v1.9.0 

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

func (*PromoteMemberRequest) XXX_Size added in v1.9.0 

func (m *PromoteMemberRequest) XXX_Size() int

func (*PromoteMemberRequest) XXX_Unmarshal added in v1.9.0 

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

type PromoteMemberResponse added in v1.9.0 

type PromoteMemberResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PromoteMemberResponse) Descriptor added in v1.9.0 

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

func (*PromoteMemberResponse) Marshal added in v1.9.0 

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

func (*PromoteMemberResponse) MarshalTo added in v1.9.0 

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

func (*PromoteMemberResponse) ProtoMessage added in v1.9.0 

func (*PromoteMemberResponse) ProtoMessage()

func (*PromoteMemberResponse) Reset added in v1.9.0 

func (m *PromoteMemberResponse) Reset()

func (*PromoteMemberResponse) Size added in v1.9.0 

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

func (*PromoteMemberResponse) String added in v1.9.0 

func (m *PromoteMemberResponse) String() string

func (*PromoteMemberResponse) Unmarshal added in v1.9.0 

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

func (*PromoteMemberResponse) XXX_DiscardUnknown added in v1.9.0 

func (m *PromoteMemberResponse) XXX_DiscardUnknown()

func (*PromoteMemberResponse) XXX_Marshal added in v1.9.0 

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

func (*PromoteMemberResponse) XXX_Merge added in v1.9.0 

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

func (*PromoteMemberResponse) XXX_Size added in v1.9.0 

func (m *PromoteMemberResponse) XXX_Size() int

func (*PromoteMemberResponse) XXX_Unmarshal added in v1.9.0 

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

type RaftClient 

type RaftClient interface {
	GetTopology(ctx context.Context, in *GetTopologyRequest, opts ...grpc.CallOption) (*GetTopologyResponse, error)
	ProcessMessage(ctx context.Context, in *raftpb.Message, opts ...grpc.CallOption) (*Payload, error)
	JoinCluster(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*JoinClusterResponse, error)
	PromoteMember(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*PromoteMemberResponse, error)
	GetMembers(ctx context.Context, in *GetMembersRequest, opts ...grpc.CallOption) (*GetMembersResponse, error)
	GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)
	RemoveMember(ctx context.Context, in *RemoveMemberRequest, opts ...grpc.CallOption) (*RemoveMemberResponse, error)
}

RaftClient is the client API for Raft service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRaftClient 

func NewRaftClient(cc *grpc.ClientConn) RaftClient

type RaftContext 

type RaftContext struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Address              string   `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"`
	Clusters             []string `protobuf:"bytes,3,rep,name=Clusters,proto3" json:"Clusters,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RaftContext) Descriptor 

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

func (*RaftContext) GetAddress 

func (m *RaftContext) GetAddress() string

func (*RaftContext) GetClusters added in v1.3.0 

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

func (*RaftContext) GetID 

func (m *RaftContext) GetID() uint64

func (*RaftContext) Marshal added in v1.3.0 

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

func (*RaftContext) MarshalTo added in v1.3.0 

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

func (*RaftContext) ProtoMessage 

func (*RaftContext) ProtoMessage()

func (*RaftContext) Reset 

func (m *RaftContext) Reset()

func (*RaftContext) Size added in v1.3.0 

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

func (*RaftContext) String 

func (m *RaftContext) String() string

func (*RaftContext) Unmarshal added in v1.3.0 

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

func (*RaftContext) XXX_DiscardUnknown 

func (m *RaftContext) XXX_DiscardUnknown()

func (*RaftContext) XXX_Marshal 

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

func (*RaftContext) XXX_Merge 

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

func (*RaftContext) XXX_Size 

func (m *RaftContext) XXX_Size() int

func (*RaftContext) XXX_Unmarshal 

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

type RaftServer 

type RaftServer interface {
	GetTopology(context.Context, *GetTopologyRequest) (*GetTopologyResponse, error)
	ProcessMessage(context.Context, *raftpb.Message) (*Payload, error)
	JoinCluster(context.Context, *RaftContext) (*JoinClusterResponse, error)
	PromoteMember(context.Context, *RaftContext) (*PromoteMemberResponse, error)
	GetMembers(context.Context, *GetMembersRequest) (*GetMembersResponse, error)
	GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
	RemoveMember(context.Context, *RemoveMemberRequest) (*RemoveMemberResponse, error)
}

RaftServer is the server API for Raft service.

type RemoveMemberRequest added in v1.8.16 

type RemoveMemberRequest struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveMemberRequest) Descriptor added in v1.8.16 

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

func (*RemoveMemberRequest) GetID added in v1.8.16 

func (m *RemoveMemberRequest) GetID() uint64

func (*RemoveMemberRequest) Marshal added in v1.8.16 

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

func (*RemoveMemberRequest) MarshalTo added in v1.8.16 

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

func (*RemoveMemberRequest) ProtoMessage added in v1.8.16 

func (*RemoveMemberRequest) ProtoMessage()

func (*RemoveMemberRequest) Reset added in v1.8.16 

func (m *RemoveMemberRequest) Reset()

func (*RemoveMemberRequest) Size added in v1.8.16 

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

func (*RemoveMemberRequest) String added in v1.8.16 

func (m *RemoveMemberRequest) String() string

func (*RemoveMemberRequest) Unmarshal added in v1.8.16 

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

func (*RemoveMemberRequest) XXX_DiscardUnknown added in v1.8.16 

func (m *RemoveMemberRequest) XXX_DiscardUnknown()

func (*RemoveMemberRequest) XXX_Marshal added in v1.8.16 

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

func (*RemoveMemberRequest) XXX_Merge added in v1.8.16 

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

func (*RemoveMemberRequest) XXX_Size added in v1.8.16 

func (m *RemoveMemberRequest) XXX_Size() int

func (*RemoveMemberRequest) XXX_Unmarshal added in v1.8.16 

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

type RemoveMemberResponse added in v1.8.16 

type RemoveMemberResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveMemberResponse) Descriptor added in v1.8.16 

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

func (*RemoveMemberResponse) Marshal added in v1.8.16 

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

func (*RemoveMemberResponse) MarshalTo added in v1.8.16 

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

func (*RemoveMemberResponse) ProtoMessage added in v1.8.16 

func (*RemoveMemberResponse) ProtoMessage()

func (*RemoveMemberResponse) Reset added in v1.8.16 

func (m *RemoveMemberResponse) Reset()

func (*RemoveMemberResponse) Size added in v1.8.16 

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

func (*RemoveMemberResponse) String added in v1.8.16 

func (m *RemoveMemberResponse) String() string

func (*RemoveMemberResponse) Unmarshal added in v1.8.16 

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

func (*RemoveMemberResponse) XXX_DiscardUnknown added in v1.8.16 

func (m *RemoveMemberResponse) XXX_DiscardUnknown()

func (*RemoveMemberResponse) XXX_Marshal added in v1.8.16 

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

func (*RemoveMemberResponse) XXX_Merge added in v1.8.16 

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

func (*RemoveMemberResponse) XXX_Size added in v1.8.16 

func (m *RemoveMemberResponse) XXX_Size() int

func (*RemoveMemberResponse) XXX_Unmarshal added in v1.8.16 

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

type RemoveMultiRaftMemberRequest added in v1.8.16 

type RemoveMultiRaftMemberRequest struct {
	ClusterID            string   `protobuf:"bytes,1,opt,name=ClusterID,proto3" json:"ClusterID,omitempty"`
	ID                   uint64   `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveMultiRaftMemberRequest) Descriptor added in v1.8.16 

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

func (*RemoveMultiRaftMemberRequest) GetClusterID added in v1.8.16 

func (m *RemoveMultiRaftMemberRequest) GetClusterID() string

func (*RemoveMultiRaftMemberRequest) GetID added in v1.8.16 

func (m *RemoveMultiRaftMemberRequest) GetID() uint64

func (*RemoveMultiRaftMemberRequest) Marshal added in v1.8.16 

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

func (*RemoveMultiRaftMemberRequest) MarshalTo added in v1.8.16 

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

func (*RemoveMultiRaftMemberRequest) ProtoMessage added in v1.8.16 

func (*RemoveMultiRaftMemberRequest) ProtoMessage()

func (*RemoveMultiRaftMemberRequest) Reset added in v1.8.16 

func (m *RemoveMultiRaftMemberRequest) Reset()

func (*RemoveMultiRaftMemberRequest) Size added in v1.8.16 

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

func (*RemoveMultiRaftMemberRequest) String added in v1.8.16 

func (m *RemoveMultiRaftMemberRequest) String() string

func (*RemoveMultiRaftMemberRequest) Unmarshal added in v1.8.16 

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

func (*RemoveMultiRaftMemberRequest) XXX_DiscardUnknown added in v1.8.16 

func (m *RemoveMultiRaftMemberRequest) XXX_DiscardUnknown()

func (*RemoveMultiRaftMemberRequest) XXX_Marshal added in v1.8.16 

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

func (*RemoveMultiRaftMemberRequest) XXX_Merge added in v1.8.16 

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

func (*RemoveMultiRaftMemberRequest) XXX_Size added in v1.8.16 

func (m *RemoveMultiRaftMemberRequest) XXX_Size() int

func (*RemoveMultiRaftMemberRequest) XXX_Unmarshal added in v1.8.16 

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

type RemoveMultiRaftMemberResponse added in v1.8.16 

type RemoveMultiRaftMemberResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveMultiRaftMemberResponse) Descriptor added in v1.8.16 

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

func (*RemoveMultiRaftMemberResponse) Marshal added in v1.8.16 

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

func (*RemoveMultiRaftMemberResponse) MarshalTo added in v1.8.16 

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

func (*RemoveMultiRaftMemberResponse) ProtoMessage added in v1.8.16 

func (*RemoveMultiRaftMemberResponse) ProtoMessage()

func (*RemoveMultiRaftMemberResponse) Reset added in v1.8.16 

func (m *RemoveMultiRaftMemberResponse) Reset()

func (*RemoveMultiRaftMemberResponse) Size added in v1.8.16 

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

func (*RemoveMultiRaftMemberResponse) String added in v1.8.16 

func (m *RemoveMultiRaftMemberResponse) String() string

func (*RemoveMultiRaftMemberResponse) Unmarshal added in v1.8.16 

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

func (*RemoveMultiRaftMemberResponse) XXX_DiscardUnknown added in v1.8.16 

func (m *RemoveMultiRaftMemberResponse) XXX_DiscardUnknown()

func (*RemoveMultiRaftMemberResponse) XXX_Marshal added in v1.8.16 

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

func (*RemoveMultiRaftMemberResponse) XXX_Merge added in v1.8.16 

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

func (*RemoveMultiRaftMemberResponse) XXX_Size added in v1.8.16 

func (m *RemoveMultiRaftMemberResponse) XXX_Size() int

func (*RemoveMultiRaftMemberResponse) XXX_Unmarshal added in v1.8.16 

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

type TopologyMemberStatus added in v1.9.0 

type TopologyMemberStatus struct {
	ID                   uint64   `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Address              string   `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"`
	IsLeader             bool     `protobuf:"varint,3,opt,name=IsLeader,proto3" json:"IsLeader,omitempty"`
	IsAlive              bool     `protobuf:"varint,4,opt,name=IsAlive,proto3" json:"IsAlive,omitempty"`
	Applied              uint64   `protobuf:"varint,5,opt,name=Applied,proto3" json:"Applied,omitempty"`
	IsVoter              bool     `protobuf:"varint,6,opt,name=IsVoter,proto3" json:"IsVoter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TopologyMemberStatus) Descriptor added in v1.9.0 

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

func (*TopologyMemberStatus) GetAddress added in v1.9.0 

func (m *TopologyMemberStatus) GetAddress() string

func (*TopologyMemberStatus) GetApplied added in v1.9.0 

func (m *TopologyMemberStatus) GetApplied() uint64

func (*TopologyMemberStatus) GetID added in v1.9.0 

func (m *TopologyMemberStatus) GetID() uint64

func (*TopologyMemberStatus) GetIsAlive added in v1.9.0 

func (m *TopologyMemberStatus) GetIsAlive() bool

func (*TopologyMemberStatus) GetIsLeader added in v1.9.0 

func (m *TopologyMemberStatus) GetIsLeader() bool

func (*TopologyMemberStatus) GetIsVoter added in v1.9.0 

func (m *TopologyMemberStatus) GetIsVoter() bool

func (*TopologyMemberStatus) Marshal added in v1.9.0 

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

func (*TopologyMemberStatus) MarshalTo added in v1.9.0 

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

func (*TopologyMemberStatus) ProtoMessage added in v1.9.0 

func (*TopologyMemberStatus) ProtoMessage()

func (*TopologyMemberStatus) Reset added in v1.9.0 

func (m *TopologyMemberStatus) Reset()

func (*TopologyMemberStatus) Size added in v1.9.0 

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

func (*TopologyMemberStatus) String added in v1.9.0 

func (m *TopologyMemberStatus) String() string

func (*TopologyMemberStatus) Unmarshal added in v1.9.0 

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

func (*TopologyMemberStatus) XXX_DiscardUnknown added in v1.9.0 

func (m *TopologyMemberStatus) XXX_DiscardUnknown()

func (*TopologyMemberStatus) XXX_Marshal added in v1.9.0 

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

func (*TopologyMemberStatus) XXX_Merge added in v1.9.0 

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

func (*TopologyMemberStatus) XXX_Size added in v1.9.0 

func (m *TopologyMemberStatus) XXX_Size() int

func (*TopologyMemberStatus) XXX_Unmarshal added in v1.9.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.