Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

raftnodepb

package

Go to main page

Versions in this module

v1

v1.12.0

Jan 15, 2025

v1.11.1

Jan 9, 2025

v1.11.0

Dec 19, 2024

Changes in this version

+ var File_experiment_metastore_raftnode_raftnodepb_raft_node_proto protoreflect.FileDescriptor

+ var RaftNodeService_ServiceDesc = grpc.ServiceDesc

+ func RegisterRaftNodeServiceServer(s grpc.ServiceRegistrar, srv RaftNodeServiceServer)

+ type AddNodeRequest struct

+ CurrentTerm uint64

+ ServerId string

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

+ func (*AddNodeRequest) ProtoMessage()

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

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

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

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

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

+ func (x *AddNodeRequest) GetCurrentTerm() uint64

+ func (x *AddNodeRequest) GetServerId() string

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

+ func (x *AddNodeRequest) Reset()

+ func (x *AddNodeRequest) String() string

+ type AddNodeResponse struct

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

+ func (*AddNodeResponse) ProtoMessage()

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

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

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

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

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

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

+ func (x *AddNodeResponse) Reset()

+ func (x *AddNodeResponse) String() string

+ type DemoteLeaderRequest struct

+ CurrentTerm uint64

+ ServerId string

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

+ func (*DemoteLeaderRequest) ProtoMessage()

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

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

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

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

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

+ func (x *DemoteLeaderRequest) GetCurrentTerm() uint64

+ func (x *DemoteLeaderRequest) GetServerId() string

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

+ func (x *DemoteLeaderRequest) Reset()

+ func (x *DemoteLeaderRequest) String() string

+ type DemoteLeaderResponse struct

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

+ func (*DemoteLeaderResponse) ProtoMessage()

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

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

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

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

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

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

+ func (x *DemoteLeaderResponse) Reset()

+ func (x *DemoteLeaderResponse) String() string

+ type NodeInfo struct

+ AdvertisedAddress string

+ AppliedIndex uint64

+ BuildRevision string

+ BuildVersion string

+ CommitIndex uint64

+ ConfigurationIndex uint64

+ CurrentTerm uint64

+ LastIndex uint64

+ LeaderId string

+ Peers []*NodeInfo_Peer

+ ServerId string

+ State string

+ Stats *NodeInfo_Stats

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

+ func (*NodeInfo) ProtoMessage()

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

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

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

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

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

+ func (x *NodeInfo) GetAdvertisedAddress() string

+ func (x *NodeInfo) GetAppliedIndex() uint64

+ func (x *NodeInfo) GetBuildRevision() string

+ func (x *NodeInfo) GetBuildVersion() string

+ func (x *NodeInfo) GetCommitIndex() uint64

+ func (x *NodeInfo) GetConfigurationIndex() uint64

+ func (x *NodeInfo) GetCurrentTerm() uint64

+ func (x *NodeInfo) GetLastIndex() uint64

+ func (x *NodeInfo) GetLeaderId() string

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

+ func (x *NodeInfo) GetServerId() string

+ func (x *NodeInfo) GetState() string

+ func (x *NodeInfo) GetStats() *NodeInfo_Stats

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

+ func (x *NodeInfo) Reset()

+ func (x *NodeInfo) String() string

+ type NodeInfoRequest struct

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

+ func (*NodeInfoRequest) ProtoMessage()

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

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

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

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

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

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

+ func (x *NodeInfoRequest) Reset()

+ func (x *NodeInfoRequest) String() string

+ type NodeInfoResponse struct

+ Node *NodeInfo

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

+ func (*NodeInfoResponse) ProtoMessage()

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

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

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

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

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

+ func (x *NodeInfoResponse) GetNode() *NodeInfo

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

+ func (x *NodeInfoResponse) Reset()

+ func (x *NodeInfoResponse) String() string

+ type NodeInfo_Peer struct

+ ServerAddress string

+ ServerId string

+ Suffrage string

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

+ func (*NodeInfo_Peer) ProtoMessage()

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

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

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

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

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

+ func (x *NodeInfo_Peer) GetServerAddress() string

+ func (x *NodeInfo_Peer) GetServerId() string

+ func (x *NodeInfo_Peer) GetSuffrage() string

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

+ func (x *NodeInfo_Peer) Reset()

+ func (x *NodeInfo_Peer) String() string

+ type NodeInfo_Stats struct

+ Name []string

+ Value []string

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

+ func (*NodeInfo_Stats) ProtoMessage()

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

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

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

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

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

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

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

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

+ func (x *NodeInfo_Stats) Reset()

+ func (x *NodeInfo_Stats) String() string

+ type PromoteToLeaderRequest struct

+ CurrentTerm uint64

+ ServerId string

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

+ func (*PromoteToLeaderRequest) ProtoMessage()

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

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

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

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

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

+ func (x *PromoteToLeaderRequest) GetCurrentTerm() uint64

+ func (x *PromoteToLeaderRequest) GetServerId() string

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

+ func (x *PromoteToLeaderRequest) Reset()

+ func (x *PromoteToLeaderRequest) String() string

+ type PromoteToLeaderResponse struct

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

+ func (*PromoteToLeaderResponse) ProtoMessage()

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

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

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

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

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

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

+ func (x *PromoteToLeaderResponse) Reset()

+ func (x *PromoteToLeaderResponse) String() string

+ type RaftNode struct

+ Address string

+ Id string

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

+ func (*RaftNode) ProtoMessage()

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

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

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

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

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

+ func (x *RaftNode) GetAddress() string

+ func (x *RaftNode) GetId() string

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

+ func (x *RaftNode) Reset()

+ func (x *RaftNode) String() string

+ type RaftNodeServiceClient interface

+ AddNode func(ctx context.Context, in *AddNodeRequest, opts ...grpc.CallOption) (*AddNodeResponse, error)

+ DemoteLeader func(ctx context.Context, in *DemoteLeaderRequest, opts ...grpc.CallOption) (*DemoteLeaderResponse, error)

+ NodeInfo func(ctx context.Context, in *NodeInfoRequest, opts ...grpc.CallOption) (*NodeInfoResponse, error)

+ PromoteToLeader func(ctx context.Context, in *PromoteToLeaderRequest, opts ...grpc.CallOption) (*PromoteToLeaderResponse, error)

+ ReadIndex func(ctx context.Context, in *ReadIndexRequest, opts ...grpc.CallOption) (*ReadIndexResponse, error)

+ RemoveNode func(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*RemoveNodeResponse, error)

+ func NewRaftNodeServiceClient(cc grpc.ClientConnInterface) RaftNodeServiceClient

+ type RaftNodeServiceServer interface

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

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

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

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

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

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

+ type ReadIndexRequest struct

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

+ func (*ReadIndexRequest) ProtoMessage()

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

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

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

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

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

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

+ func (x *ReadIndexRequest) Reset()

+ func (x *ReadIndexRequest) String() string

+ type ReadIndexResponse struct

+ CommitIndex uint64

+ Term uint64

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

+ func (*ReadIndexResponse) ProtoMessage()

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

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

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

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

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

+ func (x *ReadIndexResponse) GetCommitIndex() uint64

+ func (x *ReadIndexResponse) GetTerm() uint64

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

+ func (x *ReadIndexResponse) Reset()

+ func (x *ReadIndexResponse) String() string

+ type RemoveNodeRequest struct

+ CurrentTerm uint64

+ ServerId string

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

+ func (*RemoveNodeRequest) ProtoMessage()

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

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

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

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

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

+ func (x *RemoveNodeRequest) GetCurrentTerm() uint64

+ func (x *RemoveNodeRequest) GetServerId() string

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

+ func (x *RemoveNodeRequest) Reset()

+ func (x *RemoveNodeRequest) String() string

+ type RemoveNodeResponse struct

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

+ func (*RemoveNodeResponse) ProtoMessage()

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

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

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

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

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

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

+ func (x *RemoveNodeResponse) Reset()

+ func (x *RemoveNodeResponse) String() string

+ type UnimplementedRaftNodeServiceServer struct

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

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

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

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

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

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

+ type UnsafeRaftNodeServiceServer interface