clusterpb

package
v1.7.10 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2021 License: MPL-2.0 Imports: 7 Imported by: 2

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 

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

func RegisterNodeServer 

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

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 

func (m *GetMembersRequest) GetClusterID() string

func (*GetMembersRequest) Marshal 

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

func (*GetMembersRequest) MarshalTo 

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

func (*GetMembersRequest) ProtoMessage 

func (*GetMembersRequest) ProtoMessage()

func (*GetMembersRequest) Reset 

func (m *GetMembersRequest) Reset()

func (*GetMembersRequest) Size 

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

func (*GetMembersRequest) String 

func (m *GetMembersRequest) String() string

func (*GetMembersRequest) Unmarshal 

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 

func (m *GetMembersResponse) GetCommittedIndex() uint64

func (*GetMembersResponse) GetMembers 

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

func (*GetMembersResponse) Marshal 

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

func (*GetMembersResponse) MarshalTo 

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

func (*GetMembersResponse) ProtoMessage 

func (*GetMembersResponse) ProtoMessage()

func (*GetMembersResponse) Reset 

func (m *GetMembersResponse) Reset()

func (*GetMembersResponse) Size 

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

func (*GetMembersResponse) String 

func (m *GetMembersResponse) String() string

func (*GetMembersResponse) Unmarshal 

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 

func (m *GetStatusRequest) GetClusterID() string

func (*GetStatusRequest) Marshal 

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

func (*GetStatusRequest) MarshalTo 

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

func (*GetStatusRequest) ProtoMessage 

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) Reset 

func (m *GetStatusRequest) Reset()

func (*GetStatusRequest) Size 

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

func (*GetStatusRequest) String 

func (m *GetStatusRequest) String() string

func (*GetStatusRequest) Unmarshal 

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 

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

func (*GetStatusResponse) MarshalTo 

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

func (*GetStatusResponse) ProtoMessage 

func (*GetStatusResponse) ProtoMessage()

func (*GetStatusResponse) Reset 

func (m *GetStatusResponse) Reset()

func (*GetStatusResponse) Size 

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

func (*GetStatusResponse) String 

func (m *GetStatusResponse) String() string

func (*GetStatusResponse) Unmarshal 

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 

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 

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

func (*GetTopologyRequest) GetClusterID 

func (m *GetTopologyRequest) GetClusterID() string

func (*GetTopologyRequest) Marshal 

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

func (*GetTopologyRequest) MarshalTo 

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

func (*GetTopologyRequest) ProtoMessage 

func (*GetTopologyRequest) ProtoMessage()

func (*GetTopologyRequest) Reset 

func (m *GetTopologyRequest) Reset()

func (*GetTopologyRequest) Size 

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

func (*GetTopologyRequest) String 

func (m *GetTopologyRequest) String() string

func (*GetTopologyRequest) Unmarshal 

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

func (*GetTopologyRequest) XXX_DiscardUnknown 

func (m *GetTopologyRequest) XXX_DiscardUnknown()

func (*GetTopologyRequest) XXX_Marshal 

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

func (*GetTopologyRequest) XXX_Merge 

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

func (*GetTopologyRequest) XXX_Size 

func (m *GetTopologyRequest) XXX_Size() int

func (*GetTopologyRequest) XXX_Unmarshal 

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

type GetTopologyResponse 

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 

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

func (*GetTopologyResponse) GetClusterID 

func (m *GetTopologyResponse) GetClusterID() string

func (*GetTopologyResponse) GetCommitted 

func (m *GetTopologyResponse) GetCommitted() uint64

func (*GetTopologyResponse) GetMembers 

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

func (*GetTopologyResponse) Marshal 

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

func (*GetTopologyResponse) MarshalTo 

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

func (*GetTopologyResponse) ProtoMessage 

func (*GetTopologyResponse) ProtoMessage()

func (*GetTopologyResponse) Reset 

func (m *GetTopologyResponse) Reset()

func (*GetTopologyResponse) Size 

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

func (*GetTopologyResponse) String 

func (m *GetTopologyResponse) String() string

func (*GetTopologyResponse) Unmarshal 

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

func (*GetTopologyResponse) XXX_DiscardUnknown 

func (m *GetTopologyResponse) XXX_DiscardUnknown()

func (*GetTopologyResponse) XXX_Marshal 

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

func (*GetTopologyResponse) XXX_Merge 

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

func (*GetTopologyResponse) XXX_Size 

func (m *GetTopologyResponse) XXX_Size() int

func (*GetTopologyResponse) XXX_Unmarshal 

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

type JoinClusterRequest 

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 

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

func (*JoinClusterRequest) GetClusterID 

func (m *JoinClusterRequest) GetClusterID() string

func (*JoinClusterRequest) GetContext 

func (m *JoinClusterRequest) GetContext() *RaftContext

func (*JoinClusterRequest) Marshal 

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

func (*JoinClusterRequest) MarshalTo 

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

func (*JoinClusterRequest) ProtoMessage 

func (*JoinClusterRequest) ProtoMessage()

func (*JoinClusterRequest) Reset 

func (m *JoinClusterRequest) Reset()

func (*JoinClusterRequest) Size 

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

func (*JoinClusterRequest) String 

func (m *JoinClusterRequest) String() string

func (*JoinClusterRequest) Unmarshal 

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

func (*JoinClusterRequest) XXX_DiscardUnknown 

func (m *JoinClusterRequest) XXX_DiscardUnknown()

func (*JoinClusterRequest) XXX_Marshal 

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

func (*JoinClusterRequest) XXX_Merge 

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

func (*JoinClusterRequest) XXX_Size 

func (m *JoinClusterRequest) XXX_Size() int

func (*JoinClusterRequest) XXX_Unmarshal 

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 

func (m *JoinClusterResponse) GetCommit() uint64

func (*JoinClusterResponse) Marshal 

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

func (*JoinClusterResponse) MarshalTo 

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

func (*JoinClusterResponse) ProtoMessage 

func (*JoinClusterResponse) ProtoMessage()

func (*JoinClusterResponse) Reset 

func (m *JoinClusterResponse) Reset()

func (*JoinClusterResponse) Size 

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

func (*JoinClusterResponse) String 

func (m *JoinClusterResponse) String() string

func (*JoinClusterResponse) Unmarshal 

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"`
	LatencyMs            int64    `protobuf:"varint,5,opt,name=LatencyMs,proto3" json:"LatencyMs,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) GetLatencyMs added in v1.7.10 

func (m *Member) GetLatencyMs() int64

func (*Member) Marshal 

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

func (*Member) MarshalTo 

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

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) Reset 

func (m *Member) Reset()

func (*Member) Size 

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

func (*Member) String 

func (m *Member) String() string

func (*Member) Unmarshal 

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 

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 

func NewMultiRaftClient(cc *grpc.ClientConn) MultiRaftClient

type MultiRaftServer 

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 

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

func (*Payload) MarshalTo 

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

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) Reset 

func (m *Payload) Reset()

func (*Payload) Size 

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

func (*Payload) String 

func (m *Payload) String() string

func (*Payload) Unmarshal 

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 

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

func (*PeerResponse) MarshalTo 

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

func (*PeerResponse) ProtoMessage 

func (*PeerResponse) ProtoMessage()

func (*PeerResponse) Reset 

func (m *PeerResponse) Reset()

func (*PeerResponse) Size 

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

func (*PeerResponse) String 

func (m *PeerResponse) String() string

func (*PeerResponse) Unmarshal 

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 

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 

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

func (*ProcessMessageRequest) GetClusterID 

func (m *ProcessMessageRequest) GetClusterID() string

func (*ProcessMessageRequest) GetMessage 

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

func (*ProcessMessageRequest) Marshal 

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

func (*ProcessMessageRequest) MarshalTo 

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

func (*ProcessMessageRequest) ProtoMessage 

func (*ProcessMessageRequest) ProtoMessage()

func (*ProcessMessageRequest) Reset 

func (m *ProcessMessageRequest) Reset()

func (*ProcessMessageRequest) Size 

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

func (*ProcessMessageRequest) String 

func (m *ProcessMessageRequest) String() string

func (*ProcessMessageRequest) Unmarshal 

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

func (*ProcessMessageRequest) XXX_DiscardUnknown 

func (m *ProcessMessageRequest) XXX_DiscardUnknown()

func (*ProcessMessageRequest) XXX_Marshal 

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

func (*ProcessMessageRequest) XXX_Merge 

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

func (*ProcessMessageRequest) XXX_Size 

func (m *ProcessMessageRequest) XXX_Size() int

func (*ProcessMessageRequest) XXX_Unmarshal 

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

type PromoteMemberRequest 

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 

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

func (*PromoteMemberRequest) GetClusterID 

func (m *PromoteMemberRequest) GetClusterID() string

func (*PromoteMemberRequest) GetContext 

func (m *PromoteMemberRequest) GetContext() *RaftContext

func (*PromoteMemberRequest) Marshal 

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

func (*PromoteMemberRequest) MarshalTo 

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

func (*PromoteMemberRequest) ProtoMessage 

func (*PromoteMemberRequest) ProtoMessage()

func (*PromoteMemberRequest) Reset 

func (m *PromoteMemberRequest) Reset()

func (*PromoteMemberRequest) Size 

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

func (*PromoteMemberRequest) String 

func (m *PromoteMemberRequest) String() string

func (*PromoteMemberRequest) Unmarshal 

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

func (*PromoteMemberRequest) XXX_DiscardUnknown 

func (m *PromoteMemberRequest) XXX_DiscardUnknown()

func (*PromoteMemberRequest) XXX_Marshal 

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

func (*PromoteMemberRequest) XXX_Merge 

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

func (*PromoteMemberRequest) XXX_Size 

func (m *PromoteMemberRequest) XXX_Size() int

func (*PromoteMemberRequest) XXX_Unmarshal 

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

type PromoteMemberResponse 

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

func (*PromoteMemberResponse) Descriptor 

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

func (*PromoteMemberResponse) Marshal 

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

func (*PromoteMemberResponse) MarshalTo 

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

func (*PromoteMemberResponse) ProtoMessage 

func (*PromoteMemberResponse) ProtoMessage()

func (*PromoteMemberResponse) Reset 

func (m *PromoteMemberResponse) Reset()

func (*PromoteMemberResponse) Size 

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

func (*PromoteMemberResponse) String 

func (m *PromoteMemberResponse) String() string

func (*PromoteMemberResponse) Unmarshal 

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

func (*PromoteMemberResponse) XXX_DiscardUnknown 

func (m *PromoteMemberResponse) XXX_DiscardUnknown()

func (*PromoteMemberResponse) XXX_Marshal 

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

func (*PromoteMemberResponse) XXX_Merge 

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

func (*PromoteMemberResponse) XXX_Size 

func (m *PromoteMemberResponse) XXX_Size() int

func (*PromoteMemberResponse) XXX_Unmarshal 

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

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 

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

func (*RaftContext) GetID 

func (m *RaftContext) GetID() uint64

func (*RaftContext) Marshal 

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

func (*RaftContext) MarshalTo 

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

func (*RaftContext) ProtoMessage 

func (*RaftContext) ProtoMessage()

func (*RaftContext) Reset 

func (m *RaftContext) Reset()

func (*RaftContext) Size 

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

func (*RaftContext) String 

func (m *RaftContext) String() string

func (*RaftContext) Unmarshal 

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 RaftProposeRequest added in v1.6.1 

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

func (*RaftProposeRequest) Descriptor added in v1.6.1 

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

func (*RaftProposeRequest) GetData added in v1.6.1 

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

func (*RaftProposeRequest) GetID added in v1.6.1 

func (m *RaftProposeRequest) GetID() uint64

func (*RaftProposeRequest) Marshal added in v1.6.1 

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

func (*RaftProposeRequest) MarshalTo added in v1.6.1 

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

func (*RaftProposeRequest) ProtoMessage added in v1.6.1 

func (*RaftProposeRequest) ProtoMessage()

func (*RaftProposeRequest) Reset added in v1.6.1 

func (m *RaftProposeRequest) Reset()

func (*RaftProposeRequest) Size added in v1.6.1 

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

func (*RaftProposeRequest) String added in v1.6.1 

func (m *RaftProposeRequest) String() string

func (*RaftProposeRequest) Unmarshal added in v1.6.1 

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

func (*RaftProposeRequest) XXX_DiscardUnknown added in v1.6.1 

func (m *RaftProposeRequest) XXX_DiscardUnknown()

func (*RaftProposeRequest) XXX_Marshal added in v1.6.1 

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

func (*RaftProposeRequest) XXX_Merge added in v1.6.1 

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

func (*RaftProposeRequest) XXX_Size added in v1.6.1 

func (m *RaftProposeRequest) XXX_Size() int

func (*RaftProposeRequest) XXX_Unmarshal added in v1.6.1 

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

type RemoveMemberRequest 

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

func (*RemoveMemberRequest) Descriptor 

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

func (*RemoveMemberRequest) GetForce 

func (m *RemoveMemberRequest) GetForce() bool

func (*RemoveMemberRequest) GetID 

func (m *RemoveMemberRequest) GetID() uint64

func (*RemoveMemberRequest) Marshal 

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

func (*RemoveMemberRequest) MarshalTo 

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

func (*RemoveMemberRequest) ProtoMessage 

func (*RemoveMemberRequest) ProtoMessage()

func (*RemoveMemberRequest) Reset 

func (m *RemoveMemberRequest) Reset()

func (*RemoveMemberRequest) Size 

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

func (*RemoveMemberRequest) String 

func (m *RemoveMemberRequest) String() string

func (*RemoveMemberRequest) Unmarshal 

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

func (*RemoveMemberRequest) XXX_DiscardUnknown 

func (m *RemoveMemberRequest) XXX_DiscardUnknown()

func (*RemoveMemberRequest) XXX_Marshal 

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

func (*RemoveMemberRequest) XXX_Merge 

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

func (*RemoveMemberRequest) XXX_Size 

func (m *RemoveMemberRequest) XXX_Size() int

func (*RemoveMemberRequest) XXX_Unmarshal 

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

type RemoveMemberResponse 

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

func (*RemoveMemberResponse) Descriptor 

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

func (*RemoveMemberResponse) Marshal 

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

func (*RemoveMemberResponse) MarshalTo 

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

func (*RemoveMemberResponse) ProtoMessage 

func (*RemoveMemberResponse) ProtoMessage()

func (*RemoveMemberResponse) Reset 

func (m *RemoveMemberResponse) Reset()

func (*RemoveMemberResponse) Size 

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

func (*RemoveMemberResponse) String 

func (m *RemoveMemberResponse) String() string

func (*RemoveMemberResponse) Unmarshal 

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

func (*RemoveMemberResponse) XXX_DiscardUnknown 

func (m *RemoveMemberResponse) XXX_DiscardUnknown()

func (*RemoveMemberResponse) XXX_Marshal 

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

func (*RemoveMemberResponse) XXX_Merge 

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

func (*RemoveMemberResponse) XXX_Size 

func (m *RemoveMemberResponse) XXX_Size() int

func (*RemoveMemberResponse) XXX_Unmarshal 

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

type RemoveMultiRaftMemberRequest 

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"`
	Force                bool     `protobuf:"varint,3,opt,name=Force,proto3" json:"Force,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveMultiRaftMemberRequest) Descriptor 

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

func (*RemoveMultiRaftMemberRequest) GetClusterID 

func (m *RemoveMultiRaftMemberRequest) GetClusterID() string

func (*RemoveMultiRaftMemberRequest) GetForce 

func (m *RemoveMultiRaftMemberRequest) GetForce() bool

func (*RemoveMultiRaftMemberRequest) GetID 

func (m *RemoveMultiRaftMemberRequest) GetID() uint64

func (*RemoveMultiRaftMemberRequest) Marshal 

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

func (*RemoveMultiRaftMemberRequest) MarshalTo 

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

func (*RemoveMultiRaftMemberRequest) ProtoMessage 

func (*RemoveMultiRaftMemberRequest) ProtoMessage()

func (*RemoveMultiRaftMemberRequest) Reset 

func (m *RemoveMultiRaftMemberRequest) Reset()

func (*RemoveMultiRaftMemberRequest) Size 

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

func (*RemoveMultiRaftMemberRequest) String 

func (m *RemoveMultiRaftMemberRequest) String() string

func (*RemoveMultiRaftMemberRequest) Unmarshal 

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

func (*RemoveMultiRaftMemberRequest) XXX_DiscardUnknown 

func (m *RemoveMultiRaftMemberRequest) XXX_DiscardUnknown()

func (*RemoveMultiRaftMemberRequest) XXX_Marshal 

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

func (*RemoveMultiRaftMemberRequest) XXX_Merge 

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

func (*RemoveMultiRaftMemberRequest) XXX_Size 

func (m *RemoveMultiRaftMemberRequest) XXX_Size() int

func (*RemoveMultiRaftMemberRequest) XXX_Unmarshal 

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

type RemoveMultiRaftMemberResponse 

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

func (*RemoveMultiRaftMemberResponse) Descriptor 

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

func (*RemoveMultiRaftMemberResponse) Marshal 

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

func (*RemoveMultiRaftMemberResponse) MarshalTo 

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

func (*RemoveMultiRaftMemberResponse) ProtoMessage 

func (*RemoveMultiRaftMemberResponse) ProtoMessage()

func (*RemoveMultiRaftMemberResponse) Reset 

func (m *RemoveMultiRaftMemberResponse) Reset()

func (*RemoveMultiRaftMemberResponse) Size 

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

func (*RemoveMultiRaftMemberResponse) String 

func (m *RemoveMultiRaftMemberResponse) String() string

func (*RemoveMultiRaftMemberResponse) Unmarshal 

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

func (*RemoveMultiRaftMemberResponse) XXX_DiscardUnknown 

func (m *RemoveMultiRaftMemberResponse) XXX_DiscardUnknown()

func (*RemoveMultiRaftMemberResponse) XXX_Marshal 

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

func (*RemoveMultiRaftMemberResponse) XXX_Merge 

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

func (*RemoveMultiRaftMemberResponse) XXX_Size 

func (m *RemoveMultiRaftMemberResponse) XXX_Size() int

func (*RemoveMultiRaftMemberResponse) XXX_Unmarshal 

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

type TopologyMemberStatus 

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"`
	LatencyMs            int64    `protobuf:"varint,7,opt,name=LatencyMs,proto3" json:"LatencyMs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TopologyMemberStatus) Descriptor 

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

func (*TopologyMemberStatus) GetAddress 

func (m *TopologyMemberStatus) GetAddress() string

func (*TopologyMemberStatus) GetApplied 

func (m *TopologyMemberStatus) GetApplied() uint64

func (*TopologyMemberStatus) GetID 

func (m *TopologyMemberStatus) GetID() uint64

func (*TopologyMemberStatus) GetIsAlive 

func (m *TopologyMemberStatus) GetIsAlive() bool

func (*TopologyMemberStatus) GetIsLeader 

func (m *TopologyMemberStatus) GetIsLeader() bool

func (*TopologyMemberStatus) GetIsVoter 

func (m *TopologyMemberStatus) GetIsVoter() bool

func (*TopologyMemberStatus) GetLatencyMs added in v1.7.10 

func (m *TopologyMemberStatus) GetLatencyMs() int64

func (*TopologyMemberStatus) Marshal 

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

func (*TopologyMemberStatus) MarshalTo 

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

func (*TopologyMemberStatus) ProtoMessage 

func (*TopologyMemberStatus) ProtoMessage()

func (*TopologyMemberStatus) Reset 

func (m *TopologyMemberStatus) Reset()

func (*TopologyMemberStatus) Size 

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

func (*TopologyMemberStatus) String 

func (m *TopologyMemberStatus) String() string

func (*TopologyMemberStatus) Unmarshal 

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

func (*TopologyMemberStatus) XXX_DiscardUnknown 

func (m *TopologyMemberStatus) XXX_DiscardUnknown()

func (*TopologyMemberStatus) XXX_Marshal 

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

func (*TopologyMemberStatus) XXX_Merge 

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

func (*TopologyMemberStatus) XXX_Size 

func (m *TopologyMemberStatus) XXX_Size() int

func (*TopologyMemberStatus) XXX_Unmarshal 

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.