raftnodepb

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2024 License: AGPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_experiment_metastore_raftnode_raftnodepb_raft_node_proto protoreflect.FileDescriptor
View Source 
var RaftNodeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "raft_node.RaftNodeService",
	HandlerType: (*RaftNodeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReadIndex",
			Handler:    _RaftNodeService_ReadIndex_Handler,
		},
		{
			MethodName: "NodeInfo",
			Handler:    _RaftNodeService_NodeInfo_Handler,
		},
		{
			MethodName: "RemoveNode",
			Handler:    _RaftNodeService_RemoveNode_Handler,
		},
		{
			MethodName: "AddNode",
			Handler:    _RaftNodeService_AddNode_Handler,
		},
		{
			MethodName: "DemoteLeader",
			Handler:    _RaftNodeService_DemoteLeader_Handler,
		},
		{
			MethodName: "PromoteToLeader",
			Handler:    _RaftNodeService_PromoteToLeader_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "experiment/metastore/raftnode/raftnodepb/raft_node.proto",
}

RaftNodeService_ServiceDesc is the grpc.ServiceDesc for RaftNodeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterRaftNodeServiceServer 

func RegisterRaftNodeServiceServer(s grpc.ServiceRegistrar, srv RaftNodeServiceServer)

Types

type AddNodeRequest 

type AddNodeRequest struct {
	ServerId    string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	CurrentTerm uint64 `protobuf:"varint,2,opt,name=current_term,json=currentTerm,proto3" json:"current_term,omitempty"`
	// contains filtered or unexported fields
}

func (*AddNodeRequest) Descriptor deprecated 

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

Deprecated: Use AddNodeRequest.ProtoReflect.Descriptor instead.

func (*AddNodeRequest) GetCurrentTerm 

func (x *AddNodeRequest) GetCurrentTerm() uint64

func (*AddNodeRequest) GetServerId 

func (x *AddNodeRequest) GetServerId() string

func (*AddNodeRequest) MarshalToSizedBufferVT 

func (m *AddNodeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AddNodeRequest) MarshalToVT 

func (m *AddNodeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*AddNodeRequest) MarshalVT 

func (m *AddNodeRequest) MarshalVT() (dAtA []byte, err error)

func (*AddNodeRequest) ProtoMessage 

func (*AddNodeRequest) ProtoMessage()

func (*AddNodeRequest) ProtoReflect 

func (x *AddNodeRequest) ProtoReflect() protoreflect.Message

func (*AddNodeRequest) Reset 

func (x *AddNodeRequest) Reset()

func (*AddNodeRequest) SizeVT 

func (m *AddNodeRequest) SizeVT() (n int)

func (*AddNodeRequest) String 

func (x *AddNodeRequest) String() string

func (*AddNodeRequest) UnmarshalVT 

func (m *AddNodeRequest) UnmarshalVT(dAtA []byte) error

type AddNodeResponse 

type AddNodeResponse struct {
	// contains filtered or unexported fields
}

func (*AddNodeResponse) Descriptor deprecated 

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

Deprecated: Use AddNodeResponse.ProtoReflect.Descriptor instead.

func (*AddNodeResponse) MarshalToSizedBufferVT 

func (m *AddNodeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AddNodeResponse) MarshalToVT 

func (m *AddNodeResponse) MarshalToVT(dAtA []byte) (int, error)

func (*AddNodeResponse) MarshalVT 

func (m *AddNodeResponse) MarshalVT() (dAtA []byte, err error)

func (*AddNodeResponse) ProtoMessage 

func (*AddNodeResponse) ProtoMessage()

func (*AddNodeResponse) ProtoReflect 

func (x *AddNodeResponse) ProtoReflect() protoreflect.Message

func (*AddNodeResponse) Reset 

func (x *AddNodeResponse) Reset()

func (*AddNodeResponse) SizeVT 

func (m *AddNodeResponse) SizeVT() (n int)

func (*AddNodeResponse) String 

func (x *AddNodeResponse) String() string

func (*AddNodeResponse) UnmarshalVT 

func (m *AddNodeResponse) UnmarshalVT(dAtA []byte) error

type DemoteLeaderRequest 

type DemoteLeaderRequest struct {
	ServerId    string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	CurrentTerm uint64 `protobuf:"varint,2,opt,name=current_term,json=currentTerm,proto3" json:"current_term,omitempty"`
	// contains filtered or unexported fields
}

func (*DemoteLeaderRequest) Descriptor deprecated 

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

Deprecated: Use DemoteLeaderRequest.ProtoReflect.Descriptor instead.

func (*DemoteLeaderRequest) GetCurrentTerm 

func (x *DemoteLeaderRequest) GetCurrentTerm() uint64

func (*DemoteLeaderRequest) GetServerId 

func (x *DemoteLeaderRequest) GetServerId() string

func (*DemoteLeaderRequest) MarshalToSizedBufferVT 

func (m *DemoteLeaderRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DemoteLeaderRequest) MarshalToVT 

func (m *DemoteLeaderRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DemoteLeaderRequest) MarshalVT 

func (m *DemoteLeaderRequest) MarshalVT() (dAtA []byte, err error)

func (*DemoteLeaderRequest) ProtoMessage 

func (*DemoteLeaderRequest) ProtoMessage()

func (*DemoteLeaderRequest) ProtoReflect 

func (x *DemoteLeaderRequest) ProtoReflect() protoreflect.Message

func (*DemoteLeaderRequest) Reset 

func (x *DemoteLeaderRequest) Reset()

func (*DemoteLeaderRequest) SizeVT 

func (m *DemoteLeaderRequest) SizeVT() (n int)

func (*DemoteLeaderRequest) String 

func (x *DemoteLeaderRequest) String() string

func (*DemoteLeaderRequest) UnmarshalVT 

func (m *DemoteLeaderRequest) UnmarshalVT(dAtA []byte) error

type DemoteLeaderResponse 

type DemoteLeaderResponse struct {
	// contains filtered or unexported fields
}

func (*DemoteLeaderResponse) Descriptor deprecated 

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

Deprecated: Use DemoteLeaderResponse.ProtoReflect.Descriptor instead.

func (*DemoteLeaderResponse) MarshalToSizedBufferVT 

func (m *DemoteLeaderResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DemoteLeaderResponse) MarshalToVT 

func (m *DemoteLeaderResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DemoteLeaderResponse) MarshalVT 

func (m *DemoteLeaderResponse) MarshalVT() (dAtA []byte, err error)

func (*DemoteLeaderResponse) ProtoMessage 

func (*DemoteLeaderResponse) ProtoMessage()

func (*DemoteLeaderResponse) ProtoReflect 

func (x *DemoteLeaderResponse) ProtoReflect() protoreflect.Message

func (*DemoteLeaderResponse) Reset 

func (x *DemoteLeaderResponse) Reset()

func (*DemoteLeaderResponse) SizeVT 

func (m *DemoteLeaderResponse) SizeVT() (n int)

func (*DemoteLeaderResponse) String 

func (x *DemoteLeaderResponse) String() string

func (*DemoteLeaderResponse) UnmarshalVT 

func (m *DemoteLeaderResponse) UnmarshalVT(dAtA []byte) error

type NodeInfo 

type NodeInfo struct {
	ServerId           string           `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	AdvertisedAddress  string           `protobuf:"bytes,2,opt,name=advertised_address,json=advertisedAddress,proto3" json:"advertised_address,omitempty"`
	State              string           `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	LeaderId           string           `protobuf:"bytes,4,opt,name=leader_id,json=leaderId,proto3" json:"leader_id,omitempty"`
	CommitIndex        uint64           `protobuf:"varint,5,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	AppliedIndex       uint64           `protobuf:"varint,6,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	LastIndex          uint64           `protobuf:"varint,7,opt,name=last_index,json=lastIndex,proto3" json:"last_index,omitempty"`
	Stats              *NodeInfo_Stats  `protobuf:"bytes,8,opt,name=stats,proto3" json:"stats,omitempty"`
	Peers              []*NodeInfo_Peer `protobuf:"bytes,9,rep,name=peers,proto3" json:"peers,omitempty"`
	ConfigurationIndex uint64           `protobuf:"varint,10,opt,name=configuration_index,json=configurationIndex,proto3" json:"configuration_index,omitempty"`
	CurrentTerm        uint64           `protobuf:"varint,11,opt,name=current_term,json=currentTerm,proto3" json:"current_term,omitempty"`
	BuildVersion       string           `protobuf:"bytes,12,opt,name=build_version,json=buildVersion,proto3" json:"build_version,omitempty"`
	BuildRevision      string           `protobuf:"bytes,13,opt,name=build_revision,json=buildRevision,proto3" json:"build_revision,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetAdvertisedAddress 

func (x *NodeInfo) GetAdvertisedAddress() string

func (*NodeInfo) GetAppliedIndex 

func (x *NodeInfo) GetAppliedIndex() uint64

func (*NodeInfo) GetBuildRevision 

func (x *NodeInfo) GetBuildRevision() string

func (*NodeInfo) GetBuildVersion 

func (x *NodeInfo) GetBuildVersion() string

func (*NodeInfo) GetCommitIndex 

func (x *NodeInfo) GetCommitIndex() uint64

func (*NodeInfo) GetConfigurationIndex 

func (x *NodeInfo) GetConfigurationIndex() uint64

func (*NodeInfo) GetCurrentTerm 

func (x *NodeInfo) GetCurrentTerm() uint64

func (*NodeInfo) GetLastIndex 

func (x *NodeInfo) GetLastIndex() uint64

func (*NodeInfo) GetLeaderId 

func (x *NodeInfo) GetLeaderId() string

func (*NodeInfo) GetPeers 

func (x *NodeInfo) GetPeers() []*NodeInfo_Peer

func (*NodeInfo) GetServerId 

func (x *NodeInfo) GetServerId() string

func (*NodeInfo) GetState 

func (x *NodeInfo) GetState() string

func (*NodeInfo) GetStats 

func (x *NodeInfo) GetStats() *NodeInfo_Stats

func (*NodeInfo) MarshalToSizedBufferVT 

func (m *NodeInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NodeInfo) MarshalToVT 

func (m *NodeInfo) MarshalToVT(dAtA []byte) (int, error)

func (*NodeInfo) MarshalVT 

func (m *NodeInfo) MarshalVT() (dAtA []byte, err error)

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

func (x *NodeInfo) ProtoReflect() protoreflect.Message

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) SizeVT 

func (m *NodeInfo) SizeVT() (n int)

func (*NodeInfo) String 

func (x *NodeInfo) String() string

func (*NodeInfo) UnmarshalVT 

func (m *NodeInfo) UnmarshalVT(dAtA []byte) error

type NodeInfoRequest 

type NodeInfoRequest struct {
	// contains filtered or unexported fields
}

func (*NodeInfoRequest) Descriptor deprecated 

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

Deprecated: Use NodeInfoRequest.ProtoReflect.Descriptor instead.

func (*NodeInfoRequest) MarshalToSizedBufferVT 

func (m *NodeInfoRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NodeInfoRequest) MarshalToVT 

func (m *NodeInfoRequest) MarshalToVT(dAtA []byte) (int, error)

func (*NodeInfoRequest) MarshalVT 

func (m *NodeInfoRequest) MarshalVT() (dAtA []byte, err error)

func (*NodeInfoRequest) ProtoMessage 

func (*NodeInfoRequest) ProtoMessage()

func (*NodeInfoRequest) ProtoReflect 

func (x *NodeInfoRequest) ProtoReflect() protoreflect.Message

func (*NodeInfoRequest) Reset 

func (x *NodeInfoRequest) Reset()

func (*NodeInfoRequest) SizeVT 

func (m *NodeInfoRequest) SizeVT() (n int)

func (*NodeInfoRequest) String 

func (x *NodeInfoRequest) String() string

func (*NodeInfoRequest) UnmarshalVT 

func (m *NodeInfoRequest) UnmarshalVT(dAtA []byte) error

type NodeInfoResponse 

type NodeInfoResponse struct {
	Node *NodeInfo `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfoResponse) Descriptor deprecated 

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

Deprecated: Use NodeInfoResponse.ProtoReflect.Descriptor instead.

func (*NodeInfoResponse) GetNode 

func (x *NodeInfoResponse) GetNode() *NodeInfo

func (*NodeInfoResponse) MarshalToSizedBufferVT 

func (m *NodeInfoResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NodeInfoResponse) MarshalToVT 

func (m *NodeInfoResponse) MarshalToVT(dAtA []byte) (int, error)

func (*NodeInfoResponse) MarshalVT 

func (m *NodeInfoResponse) MarshalVT() (dAtA []byte, err error)

func (*NodeInfoResponse) ProtoMessage 

func (*NodeInfoResponse) ProtoMessage()

func (*NodeInfoResponse) ProtoReflect 

func (x *NodeInfoResponse) ProtoReflect() protoreflect.Message

func (*NodeInfoResponse) Reset 

func (x *NodeInfoResponse) Reset()

func (*NodeInfoResponse) SizeVT 

func (m *NodeInfoResponse) SizeVT() (n int)

func (*NodeInfoResponse) String 

func (x *NodeInfoResponse) String() string

func (*NodeInfoResponse) UnmarshalVT 

func (m *NodeInfoResponse) UnmarshalVT(dAtA []byte) error

type NodeInfo_Peer 

type NodeInfo_Peer struct {
	ServerId      string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	ServerAddress string `protobuf:"bytes,2,opt,name=server_address,json=serverAddress,proto3" json:"server_address,omitempty"`
	Suffrage      string `protobuf:"bytes,3,opt,name=suffrage,proto3" json:"suffrage,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo_Peer) Descriptor deprecated 

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

Deprecated: Use NodeInfo_Peer.ProtoReflect.Descriptor instead.

func (*NodeInfo_Peer) GetServerAddress 

func (x *NodeInfo_Peer) GetServerAddress() string

func (*NodeInfo_Peer) GetServerId 

func (x *NodeInfo_Peer) GetServerId() string

func (*NodeInfo_Peer) GetSuffrage 

func (x *NodeInfo_Peer) GetSuffrage() string

func (*NodeInfo_Peer) MarshalToSizedBufferVT 

func (m *NodeInfo_Peer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NodeInfo_Peer) MarshalToVT 

func (m *NodeInfo_Peer) MarshalToVT(dAtA []byte) (int, error)

func (*NodeInfo_Peer) MarshalVT 

func (m *NodeInfo_Peer) MarshalVT() (dAtA []byte, err error)

func (*NodeInfo_Peer) ProtoMessage 

func (*NodeInfo_Peer) ProtoMessage()

func (*NodeInfo_Peer) ProtoReflect 

func (x *NodeInfo_Peer) ProtoReflect() protoreflect.Message

func (*NodeInfo_Peer) Reset 

func (x *NodeInfo_Peer) Reset()

func (*NodeInfo_Peer) SizeVT 

func (m *NodeInfo_Peer) SizeVT() (n int)

func (*NodeInfo_Peer) String 

func (x *NodeInfo_Peer) String() string

func (*NodeInfo_Peer) UnmarshalVT 

func (m *NodeInfo_Peer) UnmarshalVT(dAtA []byte) error

type NodeInfo_Stats 

type NodeInfo_Stats struct {
	Name  []string `protobuf:"bytes,1,rep,name=name,proto3" json:"name,omitempty"`
	Value []string `protobuf:"bytes,2,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo_Stats) Descriptor deprecated 

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

Deprecated: Use NodeInfo_Stats.ProtoReflect.Descriptor instead.

func (*NodeInfo_Stats) GetName 

func (x *NodeInfo_Stats) GetName() []string

func (*NodeInfo_Stats) GetValue 

func (x *NodeInfo_Stats) GetValue() []string

func (*NodeInfo_Stats) MarshalToSizedBufferVT 

func (m *NodeInfo_Stats) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*NodeInfo_Stats) MarshalToVT 

func (m *NodeInfo_Stats) MarshalToVT(dAtA []byte) (int, error)

func (*NodeInfo_Stats) MarshalVT 

func (m *NodeInfo_Stats) MarshalVT() (dAtA []byte, err error)

func (*NodeInfo_Stats) ProtoMessage 

func (*NodeInfo_Stats) ProtoMessage()

func (*NodeInfo_Stats) ProtoReflect 

func (x *NodeInfo_Stats) ProtoReflect() protoreflect.Message

func (*NodeInfo_Stats) Reset 

func (x *NodeInfo_Stats) Reset()

func (*NodeInfo_Stats) SizeVT 

func (m *NodeInfo_Stats) SizeVT() (n int)

func (*NodeInfo_Stats) String 

func (x *NodeInfo_Stats) String() string

func (*NodeInfo_Stats) UnmarshalVT 

func (m *NodeInfo_Stats) UnmarshalVT(dAtA []byte) error

type PromoteToLeaderRequest 

type PromoteToLeaderRequest struct {
	ServerId    string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	CurrentTerm uint64 `protobuf:"varint,2,opt,name=current_term,json=currentTerm,proto3" json:"current_term,omitempty"`
	// contains filtered or unexported fields
}

func (*PromoteToLeaderRequest) Descriptor deprecated 

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

Deprecated: Use PromoteToLeaderRequest.ProtoReflect.Descriptor instead.

func (*PromoteToLeaderRequest) GetCurrentTerm 

func (x *PromoteToLeaderRequest) GetCurrentTerm() uint64

func (*PromoteToLeaderRequest) GetServerId 

func (x *PromoteToLeaderRequest) GetServerId() string

func (*PromoteToLeaderRequest) MarshalToSizedBufferVT 

func (m *PromoteToLeaderRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PromoteToLeaderRequest) MarshalToVT 

func (m *PromoteToLeaderRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PromoteToLeaderRequest) MarshalVT 

func (m *PromoteToLeaderRequest) MarshalVT() (dAtA []byte, err error)

func (*PromoteToLeaderRequest) ProtoMessage 

func (*PromoteToLeaderRequest) ProtoMessage()

func (*PromoteToLeaderRequest) ProtoReflect 

func (x *PromoteToLeaderRequest) ProtoReflect() protoreflect.Message

func (*PromoteToLeaderRequest) Reset 

func (x *PromoteToLeaderRequest) Reset()

func (*PromoteToLeaderRequest) SizeVT 

func (m *PromoteToLeaderRequest) SizeVT() (n int)

func (*PromoteToLeaderRequest) String 

func (x *PromoteToLeaderRequest) String() string

func (*PromoteToLeaderRequest) UnmarshalVT 

func (m *PromoteToLeaderRequest) UnmarshalVT(dAtA []byte) error

type PromoteToLeaderResponse 

type PromoteToLeaderResponse struct {
	// contains filtered or unexported fields
}

func (*PromoteToLeaderResponse) Descriptor deprecated 

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

Deprecated: Use PromoteToLeaderResponse.ProtoReflect.Descriptor instead.

func (*PromoteToLeaderResponse) MarshalToSizedBufferVT 

func (m *PromoteToLeaderResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PromoteToLeaderResponse) MarshalToVT 

func (m *PromoteToLeaderResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PromoteToLeaderResponse) MarshalVT 

func (m *PromoteToLeaderResponse) MarshalVT() (dAtA []byte, err error)

func (*PromoteToLeaderResponse) ProtoMessage 

func (*PromoteToLeaderResponse) ProtoMessage()

func (*PromoteToLeaderResponse) ProtoReflect 

func (x *PromoteToLeaderResponse) ProtoReflect() protoreflect.Message

func (*PromoteToLeaderResponse) Reset 

func (x *PromoteToLeaderResponse) Reset()

func (*PromoteToLeaderResponse) SizeVT 

func (m *PromoteToLeaderResponse) SizeVT() (n int)

func (*PromoteToLeaderResponse) String 

func (x *PromoteToLeaderResponse) String() string

func (*PromoteToLeaderResponse) UnmarshalVT 

func (m *PromoteToLeaderResponse) UnmarshalVT(dAtA []byte) error

type RaftNode 

type RaftNode struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftNode) Descriptor deprecated 

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

Deprecated: Use RaftNode.ProtoReflect.Descriptor instead.

func (*RaftNode) GetAddress 

func (x *RaftNode) GetAddress() string

func (*RaftNode) GetId 

func (x *RaftNode) GetId() string

func (*RaftNode) MarshalToSizedBufferVT 

func (m *RaftNode) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RaftNode) MarshalToVT 

func (m *RaftNode) MarshalToVT(dAtA []byte) (int, error)

func (*RaftNode) MarshalVT 

func (m *RaftNode) MarshalVT() (dAtA []byte, err error)

func (*RaftNode) ProtoMessage 

func (*RaftNode) ProtoMessage()

func (*RaftNode) ProtoReflect 

func (x *RaftNode) ProtoReflect() protoreflect.Message

func (*RaftNode) Reset 

func (x *RaftNode) Reset()

func (*RaftNode) SizeVT 

func (m *RaftNode) SizeVT() (n int)

func (*RaftNode) String 

func (x *RaftNode) String() string

func (*RaftNode) UnmarshalVT 

func (m *RaftNode) UnmarshalVT(dAtA []byte) error

type RaftNodeServiceClient 

type RaftNodeServiceClient interface {
	ReadIndex(ctx context.Context, in *ReadIndexRequest, opts ...grpc.CallOption) (*ReadIndexResponse, error)
	NodeInfo(ctx context.Context, in *NodeInfoRequest, opts ...grpc.CallOption) (*NodeInfoResponse, error)
	RemoveNode(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*RemoveNodeResponse, error)
	AddNode(ctx context.Context, in *AddNodeRequest, opts ...grpc.CallOption) (*AddNodeResponse, error)
	DemoteLeader(ctx context.Context, in *DemoteLeaderRequest, opts ...grpc.CallOption) (*DemoteLeaderResponse, error)
	PromoteToLeader(ctx context.Context, in *PromoteToLeaderRequest, opts ...grpc.CallOption) (*PromoteToLeaderResponse, error)
}

RaftNodeServiceClient is the client API for RaftNodeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRaftNodeServiceClient 

func NewRaftNodeServiceClient(cc grpc.ClientConnInterface) RaftNodeServiceClient

type RaftNodeServiceServer 

type RaftNodeServiceServer interface {
	ReadIndex(context.Context, *ReadIndexRequest) (*ReadIndexResponse, error)
	NodeInfo(context.Context, *NodeInfoRequest) (*NodeInfoResponse, error)
	RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)
	AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)
	DemoteLeader(context.Context, *DemoteLeaderRequest) (*DemoteLeaderResponse, error)
	PromoteToLeader(context.Context, *PromoteToLeaderRequest) (*PromoteToLeaderResponse, error)
	// contains filtered or unexported methods
}

RaftNodeServiceServer is the server API for RaftNodeService service. All implementations must embed UnimplementedRaftNodeServiceServer for forward compatibility

type ReadIndexRequest 

type ReadIndexRequest struct {
	// contains filtered or unexported fields
}

func (*ReadIndexRequest) Descriptor deprecated 

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

Deprecated: Use ReadIndexRequest.ProtoReflect.Descriptor instead.

func (*ReadIndexRequest) MarshalToSizedBufferVT 

func (m *ReadIndexRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReadIndexRequest) MarshalToVT 

func (m *ReadIndexRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ReadIndexRequest) MarshalVT 

func (m *ReadIndexRequest) MarshalVT() (dAtA []byte, err error)

func (*ReadIndexRequest) ProtoMessage 

func (*ReadIndexRequest) ProtoMessage()

func (*ReadIndexRequest) ProtoReflect 

func (x *ReadIndexRequest) ProtoReflect() protoreflect.Message

func (*ReadIndexRequest) Reset 

func (x *ReadIndexRequest) Reset()

func (*ReadIndexRequest) SizeVT 

func (m *ReadIndexRequest) SizeVT() (n int)

func (*ReadIndexRequest) String 

func (x *ReadIndexRequest) String() string

func (*ReadIndexRequest) UnmarshalVT 

func (m *ReadIndexRequest) UnmarshalVT(dAtA []byte) error

type ReadIndexResponse 

type ReadIndexResponse struct {
	CommitIndex uint64 `protobuf:"varint,1,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	Term        uint64 `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadIndexResponse) Descriptor deprecated 

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

Deprecated: Use ReadIndexResponse.ProtoReflect.Descriptor instead.

func (*ReadIndexResponse) GetCommitIndex 

func (x *ReadIndexResponse) GetCommitIndex() uint64

func (*ReadIndexResponse) GetTerm 

func (x *ReadIndexResponse) GetTerm() uint64

func (*ReadIndexResponse) MarshalToSizedBufferVT 

func (m *ReadIndexResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReadIndexResponse) MarshalToVT 

func (m *ReadIndexResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ReadIndexResponse) MarshalVT 

func (m *ReadIndexResponse) MarshalVT() (dAtA []byte, err error)

func (*ReadIndexResponse) ProtoMessage 

func (*ReadIndexResponse) ProtoMessage()

func (*ReadIndexResponse) ProtoReflect 

func (x *ReadIndexResponse) ProtoReflect() protoreflect.Message

func (*ReadIndexResponse) Reset 

func (x *ReadIndexResponse) Reset()

func (*ReadIndexResponse) SizeVT 

func (m *ReadIndexResponse) SizeVT() (n int)

func (*ReadIndexResponse) String 

func (x *ReadIndexResponse) String() string

func (*ReadIndexResponse) UnmarshalVT 

func (m *ReadIndexResponse) UnmarshalVT(dAtA []byte) error

type RemoveNodeRequest 

type RemoveNodeRequest struct {
	ServerId    string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	CurrentTerm uint64 `protobuf:"varint,2,opt,name=current_term,json=currentTerm,proto3" json:"current_term,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveNodeRequest) Descriptor deprecated 

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

Deprecated: Use RemoveNodeRequest.ProtoReflect.Descriptor instead.

func (*RemoveNodeRequest) GetCurrentTerm 

func (x *RemoveNodeRequest) GetCurrentTerm() uint64

func (*RemoveNodeRequest) GetServerId 

func (x *RemoveNodeRequest) GetServerId() string

func (*RemoveNodeRequest) MarshalToSizedBufferVT 

func (m *RemoveNodeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RemoveNodeRequest) MarshalToVT 

func (m *RemoveNodeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RemoveNodeRequest) MarshalVT 

func (m *RemoveNodeRequest) MarshalVT() (dAtA []byte, err error)

func (*RemoveNodeRequest) ProtoMessage 

func (*RemoveNodeRequest) ProtoMessage()

func (*RemoveNodeRequest) ProtoReflect 

func (x *RemoveNodeRequest) ProtoReflect() protoreflect.Message

func (*RemoveNodeRequest) Reset 

func (x *RemoveNodeRequest) Reset()

func (*RemoveNodeRequest) SizeVT 

func (m *RemoveNodeRequest) SizeVT() (n int)

func (*RemoveNodeRequest) String 

func (x *RemoveNodeRequest) String() string

func (*RemoveNodeRequest) UnmarshalVT 

func (m *RemoveNodeRequest) UnmarshalVT(dAtA []byte) error

type RemoveNodeResponse 

type RemoveNodeResponse struct {
	// contains filtered or unexported fields
}

func (*RemoveNodeResponse) Descriptor deprecated 

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

Deprecated: Use RemoveNodeResponse.ProtoReflect.Descriptor instead.

func (*RemoveNodeResponse) MarshalToSizedBufferVT 

func (m *RemoveNodeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RemoveNodeResponse) MarshalToVT 

func (m *RemoveNodeResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RemoveNodeResponse) MarshalVT 

func (m *RemoveNodeResponse) MarshalVT() (dAtA []byte, err error)

func (*RemoveNodeResponse) ProtoMessage 

func (*RemoveNodeResponse) ProtoMessage()

func (*RemoveNodeResponse) ProtoReflect 

func (x *RemoveNodeResponse) ProtoReflect() protoreflect.Message

func (*RemoveNodeResponse) Reset 

func (x *RemoveNodeResponse) Reset()

func (*RemoveNodeResponse) SizeVT 

func (m *RemoveNodeResponse) SizeVT() (n int)

func (*RemoveNodeResponse) String 

func (x *RemoveNodeResponse) String() string

func (*RemoveNodeResponse) UnmarshalVT 

func (m *RemoveNodeResponse) UnmarshalVT(dAtA []byte) error

type UnimplementedRaftNodeServiceServer 

type UnimplementedRaftNodeServiceServer struct {
}

UnimplementedRaftNodeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRaftNodeServiceServer) AddNode 

func (UnimplementedRaftNodeServiceServer) AddNode(context.Context, *AddNodeRequest) (*AddNodeResponse, error)

func (UnimplementedRaftNodeServiceServer) DemoteLeader 

func (UnimplementedRaftNodeServiceServer) DemoteLeader(context.Context, *DemoteLeaderRequest) (*DemoteLeaderResponse, error)

func (UnimplementedRaftNodeServiceServer) NodeInfo 

func (UnimplementedRaftNodeServiceServer) NodeInfo(context.Context, *NodeInfoRequest) (*NodeInfoResponse, error)

func (UnimplementedRaftNodeServiceServer) PromoteToLeader 

func (UnimplementedRaftNodeServiceServer) PromoteToLeader(context.Context, *PromoteToLeaderRequest) (*PromoteToLeaderResponse, error)

func (UnimplementedRaftNodeServiceServer) ReadIndex 

func (UnimplementedRaftNodeServiceServer) ReadIndex(context.Context, *ReadIndexRequest) (*ReadIndexResponse, error)

func (UnimplementedRaftNodeServiceServer) RemoveNode 

func (UnimplementedRaftNodeServiceServer) RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)

type UnsafeRaftNodeServiceServer 

type UnsafeRaftNodeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeRaftNodeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RaftNodeServiceServer will result in compilation errors.

Source Files

View all Source files

Directories

Path Synopsis

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.