raft

package
v0.0.0-...-1c1f771 Latest Latest
Warning

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

 Go to latest Published: Dec 14, 2023 License: MIT, MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_raft_proto protoreflect.FileDescriptor
View Source 
var RaftServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "raft.RaftServer",
	HandlerType: (*RaftServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ClusterStatusHandler",
			Handler:    _RaftServer_ClusterStatusHandler_Handler,
		},
		{
			MethodName: "ClusterJoinHandler",
			Handler:    _RaftServer_ClusterJoinHandler_Handler,
		},
		{
			MethodName: "ClusterLeaveHandler",
			Handler:    _RaftServer_ClusterLeaveHandler_Handler,
		},
		{
			MethodName: "AppendEntriesRequestHandler",
			Handler:    _RaftServer_AppendEntriesRequestHandler_Handler,
		},
		{
			MethodName: "VoteRequestHandler",
			Handler:    _RaftServer_VoteRequestHandler_Handler,
		},
		{
			MethodName: "NewVoteHandler",
			Handler:    _RaftServer_NewVoteHandler_Handler,
		},
		{
			MethodName: "SnapshotRequestHandler",
			Handler:    _RaftServer_SnapshotRequestHandler_Handler,
		},
		{
			MethodName: "SnapshotRecoveryRequestHandler",
			Handler:    _RaftServer_SnapshotRecoveryRequestHandler_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "raft.proto",
}

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

Functions

func RegisterRaftServerServer 

func RegisterRaftServerServer(s grpc.ServiceRegistrar, srv RaftServerServer)

Types

type AppendEntriesRequest 

type AppendEntriesRequest struct {
	Term         uint64      `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	PrevLogIndex uint64      `protobuf:"varint,2,opt,name=PrevLogIndex,proto3" json:"PrevLogIndex,omitempty"`
	PrevLogTerm  uint64      `protobuf:"varint,3,opt,name=PrevLogTerm,proto3" json:"PrevLogTerm,omitempty"`
	CommitIndex  uint64      `protobuf:"varint,4,opt,name=CommitIndex,proto3" json:"CommitIndex,omitempty"`
	LeaderName   string      `protobuf:"bytes,5,opt,name=LeaderName,proto3" json:"LeaderName,omitempty"`
	Entries      []*LogEntry `protobuf:"bytes,6,rep,name=Entries,proto3" json:"Entries,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendEntriesRequest) Descriptor deprecated 

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

Deprecated: Use AppendEntriesRequest.ProtoReflect.Descriptor instead.

func (*AppendEntriesRequest) GetCommitIndex 

func (x *AppendEntriesRequest) GetCommitIndex() uint64

func (*AppendEntriesRequest) GetEntries 

func (x *AppendEntriesRequest) GetEntries() []*LogEntry

func (*AppendEntriesRequest) GetLeaderName 

func (x *AppendEntriesRequest) GetLeaderName() string

func (*AppendEntriesRequest) GetPrevLogIndex 

func (x *AppendEntriesRequest) GetPrevLogIndex() uint64

func (*AppendEntriesRequest) GetPrevLogTerm 

func (x *AppendEntriesRequest) GetPrevLogTerm() uint64

func (*AppendEntriesRequest) GetTerm 

func (x *AppendEntriesRequest) GetTerm() uint64

func (*AppendEntriesRequest) ProtoMessage 

func (*AppendEntriesRequest) ProtoMessage()

func (*AppendEntriesRequest) ProtoReflect 

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

func (*AppendEntriesRequest) Reset 

func (x *AppendEntriesRequest) Reset()

func (*AppendEntriesRequest) String 

func (x *AppendEntriesRequest) String() string

type AppendEntriesResponse 

type AppendEntriesResponse struct {
	Term        uint64 `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	Index       uint64 `protobuf:"varint,2,opt,name=Index,proto3" json:"Index,omitempty"`
	CommitIndex uint64 `protobuf:"varint,3,opt,name=CommitIndex,proto3" json:"CommitIndex,omitempty"`
	Success     bool   `protobuf:"varint,4,opt,name=Success,proto3" json:"Success,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendEntriesResponse) Descriptor deprecated 

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

Deprecated: Use AppendEntriesResponse.ProtoReflect.Descriptor instead.

func (*AppendEntriesResponse) GetCommitIndex 

func (x *AppendEntriesResponse) GetCommitIndex() uint64

func (*AppendEntriesResponse) GetIndex 

func (x *AppendEntriesResponse) GetIndex() uint64

func (*AppendEntriesResponse) GetSuccess 

func (x *AppendEntriesResponse) GetSuccess() bool

func (*AppendEntriesResponse) GetTerm 

func (x *AppendEntriesResponse) GetTerm() uint64

func (*AppendEntriesResponse) ProtoMessage 

func (*AppendEntriesResponse) ProtoMessage()

func (*AppendEntriesResponse) ProtoReflect 

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

func (*AppendEntriesResponse) Reset 

func (x *AppendEntriesResponse) Reset()

func (*AppendEntriesResponse) String 

func (x *AppendEntriesResponse) String() string

type ClusterJoinRequest 

type ClusterJoinRequest struct {
	Name             string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ConnectionString string `protobuf:"bytes,2,opt,name=connectionString,proto3" json:"connectionString,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterJoinRequest) Descriptor deprecated 

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

Deprecated: Use ClusterJoinRequest.ProtoReflect.Descriptor instead.

func (*ClusterJoinRequest) GetConnectionString 

func (x *ClusterJoinRequest) GetConnectionString() string

func (*ClusterJoinRequest) GetName 

func (x *ClusterJoinRequest) GetName() string

func (*ClusterJoinRequest) ProtoMessage 

func (*ClusterJoinRequest) ProtoMessage()

func (*ClusterJoinRequest) ProtoReflect 

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

func (*ClusterJoinRequest) Reset 

func (x *ClusterJoinRequest) Reset()

func (*ClusterJoinRequest) String 

func (x *ClusterJoinRequest) String() string

type ClusterJoinResponse 

type ClusterJoinResponse struct {
	ErrMsg string `protobuf:"bytes,1,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterJoinResponse) Descriptor deprecated 

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

Deprecated: Use ClusterJoinResponse.ProtoReflect.Descriptor instead.

func (*ClusterJoinResponse) GetErrMsg 

func (x *ClusterJoinResponse) GetErrMsg() string

func (*ClusterJoinResponse) ProtoMessage 

func (*ClusterJoinResponse) ProtoMessage()

func (*ClusterJoinResponse) ProtoReflect 

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

func (*ClusterJoinResponse) Reset 

func (x *ClusterJoinResponse) Reset()

func (*ClusterJoinResponse) String 

func (x *ClusterJoinResponse) String() string

type ClusterLeaveRequest 

type ClusterLeaveRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterLeaveRequest) Descriptor deprecated 

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

Deprecated: Use ClusterLeaveRequest.ProtoReflect.Descriptor instead.

func (*ClusterLeaveRequest) GetName 

func (x *ClusterLeaveRequest) GetName() string

func (*ClusterLeaveRequest) ProtoMessage 

func (*ClusterLeaveRequest) ProtoMessage()

func (*ClusterLeaveRequest) ProtoReflect 

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

func (*ClusterLeaveRequest) Reset 

func (x *ClusterLeaveRequest) Reset()

func (*ClusterLeaveRequest) String 

func (x *ClusterLeaveRequest) String() string

type ClusterLeaveResponse 

type ClusterLeaveResponse struct {
	ErrMsg string `protobuf:"bytes,1,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterLeaveResponse) Descriptor deprecated 

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

Deprecated: Use ClusterLeaveResponse.ProtoReflect.Descriptor instead.

func (*ClusterLeaveResponse) GetErrMsg 

func (x *ClusterLeaveResponse) GetErrMsg() string

func (*ClusterLeaveResponse) ProtoMessage 

func (*ClusterLeaveResponse) ProtoMessage()

func (*ClusterLeaveResponse) ProtoReflect 

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

func (*ClusterLeaveResponse) Reset 

func (x *ClusterLeaveResponse) Reset()

func (*ClusterLeaveResponse) String 

func (x *ClusterLeaveResponse) String() string

type ClusterStatusRequest 

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

func (*ClusterStatusRequest) Descriptor deprecated 

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

Deprecated: Use ClusterStatusRequest.ProtoReflect.Descriptor instead.

func (*ClusterStatusRequest) ProtoMessage 

func (*ClusterStatusRequest) ProtoMessage()

func (*ClusterStatusRequest) ProtoReflect 

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

func (*ClusterStatusRequest) Reset 

func (x *ClusterStatusRequest) Reset()

func (*ClusterStatusRequest) String 

func (x *ClusterStatusRequest) String() string

type ClusterStatusResponse 

type ClusterStatusResponse struct {
	IsLeader bool     `protobuf:"varint,1,opt,name=isLeader,proto3" json:"isLeader,omitempty"`
	Leader   string   `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	Peers    []string `protobuf:"bytes,3,rep,name=Peers,proto3" json:"Peers,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterStatusResponse) Descriptor deprecated 

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

Deprecated: Use ClusterStatusResponse.ProtoReflect.Descriptor instead.

func (*ClusterStatusResponse) GetIsLeader 

func (x *ClusterStatusResponse) GetIsLeader() bool

func (*ClusterStatusResponse) GetLeader 

func (x *ClusterStatusResponse) GetLeader() string

func (*ClusterStatusResponse) GetPeers 

func (x *ClusterStatusResponse) GetPeers() []string

func (*ClusterStatusResponse) ProtoMessage 

func (*ClusterStatusResponse) ProtoMessage()

func (*ClusterStatusResponse) ProtoReflect 

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

func (*ClusterStatusResponse) Reset 

func (x *ClusterStatusResponse) Reset()

func (*ClusterStatusResponse) String 

func (x *ClusterStatusResponse) String() string

type LogEntry 

type LogEntry struct {
	Index       uint64 `protobuf:"varint,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Term        uint64 `protobuf:"varint,2,opt,name=Term,proto3" json:"Term,omitempty"`
	CommandName string `protobuf:"bytes,3,opt,name=CommandName,proto3" json:"CommandName,omitempty"`
	Command     []byte `protobuf:"bytes,4,opt,name=Command,proto3" json:"Command,omitempty"` // for nop-command
	// contains filtered or unexported fields
}

func (*LogEntry) Descriptor deprecated 

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetCommand 

func (x *LogEntry) GetCommand() []byte

func (*LogEntry) GetCommandName 

func (x *LogEntry) GetCommandName() string

func (*LogEntry) GetIndex 

func (x *LogEntry) GetIndex() uint64

func (*LogEntry) GetTerm 

func (x *LogEntry) GetTerm() uint64

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

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

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) String 

func (x *LogEntry) String() string

type NewVoteRequest 

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

func (*NewVoteRequest) Descriptor deprecated 

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

Deprecated: Use NewVoteRequest.ProtoReflect.Descriptor instead.

func (*NewVoteRequest) ProtoMessage 

func (*NewVoteRequest) ProtoMessage()

func (*NewVoteRequest) ProtoReflect 

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

func (*NewVoteRequest) Reset 

func (x *NewVoteRequest) Reset()

func (*NewVoteRequest) String 

func (x *NewVoteRequest) String() string

type NewVoteResponse 

type NewVoteResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*NewVoteResponse) Descriptor deprecated 

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

Deprecated: Use NewVoteResponse.ProtoReflect.Descriptor instead.

func (*NewVoteResponse) GetOk 

func (x *NewVoteResponse) GetOk() bool

func (*NewVoteResponse) ProtoMessage 

func (*NewVoteResponse) ProtoMessage()

func (*NewVoteResponse) ProtoReflect 

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

func (*NewVoteResponse) Reset 

func (x *NewVoteResponse) Reset()

func (*NewVoteResponse) String 

func (x *NewVoteResponse) String() string

type Peer 

type Peer struct {
	Name             string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	ConnectionString string `protobuf:"bytes,2,opt,name=ConnectionString,proto3" json:"ConnectionString,omitempty"`
	// contains filtered or unexported fields
}

func (*Peer) Descriptor deprecated 

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

Deprecated: Use Peer.ProtoReflect.Descriptor instead.

func (*Peer) GetConnectionString 

func (x *Peer) GetConnectionString() string

func (*Peer) GetName 

func (x *Peer) GetName() string

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) ProtoReflect 

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

func (*Peer) Reset 

func (x *Peer) Reset()

func (*Peer) String 

func (x *Peer) String() string

type RaftServerClient 

type RaftServerClient interface {
	ClusterStatusHandler(ctx context.Context, in *ClusterStatusRequest, opts ...grpc.CallOption) (*ClusterStatusResponse, error)
	ClusterJoinHandler(ctx context.Context, in *ClusterJoinRequest, opts ...grpc.CallOption) (*ClusterJoinResponse, error)
	ClusterLeaveHandler(ctx context.Context, in *ClusterLeaveRequest, opts ...grpc.CallOption) (*ClusterLeaveResponse, error)
	AppendEntriesRequestHandler(ctx context.Context, in *AppendEntriesRequest, opts ...grpc.CallOption) (*AppendEntriesResponse, error)
	VoteRequestHandler(ctx context.Context, in *RequestVoteRequest, opts ...grpc.CallOption) (*RequestVoteResponse, error)
	NewVoteHandler(ctx context.Context, in *NewVoteRequest, opts ...grpc.CallOption) (*NewVoteResponse, error)
	SnapshotRequestHandler(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (*SnapshotResponse, error)
	SnapshotRecoveryRequestHandler(ctx context.Context, in *SnapshotRecoveryRequest, opts ...grpc.CallOption) (*SnapshotRecoveryResponse, error)
}

RaftServerClient is the client API for RaftServer service.

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

func NewRaftServerClient 

func NewRaftServerClient(cc grpc.ClientConnInterface) RaftServerClient

type RaftServerServer 

type RaftServerServer interface {
	ClusterStatusHandler(context.Context, *ClusterStatusRequest) (*ClusterStatusResponse, error)
	ClusterJoinHandler(context.Context, *ClusterJoinRequest) (*ClusterJoinResponse, error)
	ClusterLeaveHandler(context.Context, *ClusterLeaveRequest) (*ClusterLeaveResponse, error)
	AppendEntriesRequestHandler(context.Context, *AppendEntriesRequest) (*AppendEntriesResponse, error)
	VoteRequestHandler(context.Context, *RequestVoteRequest) (*RequestVoteResponse, error)
	NewVoteHandler(context.Context, *NewVoteRequest) (*NewVoteResponse, error)
	SnapshotRequestHandler(context.Context, *SnapshotRequest) (*SnapshotResponse, error)
	SnapshotRecoveryRequestHandler(context.Context, *SnapshotRecoveryRequest) (*SnapshotRecoveryResponse, error)
	// contains filtered or unexported methods
}

RaftServerServer is the server API for RaftServer service. All implementations must embed UnimplementedRaftServerServer for forward compatibility

type RequestVoteRequest 

type RequestVoteRequest struct {
	Term          uint64 `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	LastLogIndex  uint64 `protobuf:"varint,2,opt,name=LastLogIndex,proto3" json:"LastLogIndex,omitempty"`
	LastLogTerm   uint64 `protobuf:"varint,3,opt,name=LastLogTerm,proto3" json:"LastLogTerm,omitempty"`
	CandidateName string `protobuf:"bytes,4,opt,name=CandidateName,proto3" json:"CandidateName,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestVoteRequest) Descriptor deprecated 

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

Deprecated: Use RequestVoteRequest.ProtoReflect.Descriptor instead.

func (*RequestVoteRequest) GetCandidateName 

func (x *RequestVoteRequest) GetCandidateName() string

func (*RequestVoteRequest) GetLastLogIndex 

func (x *RequestVoteRequest) GetLastLogIndex() uint64

func (*RequestVoteRequest) GetLastLogTerm 

func (x *RequestVoteRequest) GetLastLogTerm() uint64

func (*RequestVoteRequest) GetTerm 

func (x *RequestVoteRequest) GetTerm() uint64

func (*RequestVoteRequest) ProtoMessage 

func (*RequestVoteRequest) ProtoMessage()

func (*RequestVoteRequest) ProtoReflect 

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

func (*RequestVoteRequest) Reset 

func (x *RequestVoteRequest) Reset()

func (*RequestVoteRequest) String 

func (x *RequestVoteRequest) String() string

type RequestVoteResponse 

type RequestVoteResponse struct {
	Term        uint64 `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	VoteGranted bool   `protobuf:"varint,2,opt,name=VoteGranted,proto3" json:"VoteGranted,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestVoteResponse) Descriptor deprecated 

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

Deprecated: Use RequestVoteResponse.ProtoReflect.Descriptor instead.

func (*RequestVoteResponse) GetTerm 

func (x *RequestVoteResponse) GetTerm() uint64

func (*RequestVoteResponse) GetVoteGranted 

func (x *RequestVoteResponse) GetVoteGranted() bool

func (*RequestVoteResponse) ProtoMessage 

func (*RequestVoteResponse) ProtoMessage()

func (*RequestVoteResponse) ProtoReflect 

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

func (*RequestVoteResponse) Reset 

func (x *RequestVoteResponse) Reset()

func (*RequestVoteResponse) String 

func (x *RequestVoteResponse) String() string

type SnapshotRecoveryRequest 

type SnapshotRecoveryRequest struct {
	LeaderName string  `protobuf:"bytes,1,opt,name=LeaderName,proto3" json:"LeaderName,omitempty"`
	LastIndex  uint64  `protobuf:"varint,2,opt,name=LastIndex,proto3" json:"LastIndex,omitempty"`
	LastTerm   uint64  `protobuf:"varint,3,opt,name=LastTerm,proto3" json:"LastTerm,omitempty"`
	Peers      []*Peer `protobuf:"bytes,4,rep,name=Peers,proto3" json:"Peers,omitempty"`
	State      []byte  `protobuf:"bytes,5,opt,name=State,proto3" json:"State,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotRecoveryRequest) Descriptor deprecated 

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

Deprecated: Use SnapshotRecoveryRequest.ProtoReflect.Descriptor instead.

func (*SnapshotRecoveryRequest) GetLastIndex 

func (x *SnapshotRecoveryRequest) GetLastIndex() uint64

func (*SnapshotRecoveryRequest) GetLastTerm 

func (x *SnapshotRecoveryRequest) GetLastTerm() uint64

func (*SnapshotRecoveryRequest) GetLeaderName 

func (x *SnapshotRecoveryRequest) GetLeaderName() string

func (*SnapshotRecoveryRequest) GetPeers 

func (x *SnapshotRecoveryRequest) GetPeers() []*Peer

func (*SnapshotRecoveryRequest) GetState 

func (x *SnapshotRecoveryRequest) GetState() []byte

func (*SnapshotRecoveryRequest) ProtoMessage 

func (*SnapshotRecoveryRequest) ProtoMessage()

func (*SnapshotRecoveryRequest) ProtoReflect 

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

func (*SnapshotRecoveryRequest) Reset 

func (x *SnapshotRecoveryRequest) Reset()

func (*SnapshotRecoveryRequest) String 

func (x *SnapshotRecoveryRequest) String() string

type SnapshotRecoveryResponse 

type SnapshotRecoveryResponse struct {
	Term        uint64 `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	Success     bool   `protobuf:"varint,2,opt,name=Success,proto3" json:"Success,omitempty"`
	CommitIndex uint64 `protobuf:"varint,3,opt,name=CommitIndex,proto3" json:"CommitIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotRecoveryResponse) Descriptor deprecated 

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

Deprecated: Use SnapshotRecoveryResponse.ProtoReflect.Descriptor instead.

func (*SnapshotRecoveryResponse) GetCommitIndex 

func (x *SnapshotRecoveryResponse) GetCommitIndex() uint64

func (*SnapshotRecoveryResponse) GetSuccess 

func (x *SnapshotRecoveryResponse) GetSuccess() bool

func (*SnapshotRecoveryResponse) GetTerm 

func (x *SnapshotRecoveryResponse) GetTerm() uint64

func (*SnapshotRecoveryResponse) ProtoMessage 

func (*SnapshotRecoveryResponse) ProtoMessage()

func (*SnapshotRecoveryResponse) ProtoReflect 

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

func (*SnapshotRecoveryResponse) Reset 

func (x *SnapshotRecoveryResponse) Reset()

func (*SnapshotRecoveryResponse) String 

func (x *SnapshotRecoveryResponse) String() string

type SnapshotRequest 

type SnapshotRequest struct {
	LeaderName string `protobuf:"bytes,1,opt,name=LeaderName,proto3" json:"LeaderName,omitempty"`
	LastIndex  uint64 `protobuf:"varint,2,opt,name=LastIndex,proto3" json:"LastIndex,omitempty"`
	LastTerm   uint64 `protobuf:"varint,3,opt,name=LastTerm,proto3" json:"LastTerm,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotRequest) Descriptor deprecated 

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

Deprecated: Use SnapshotRequest.ProtoReflect.Descriptor instead.

func (*SnapshotRequest) GetLastIndex 

func (x *SnapshotRequest) GetLastIndex() uint64

func (*SnapshotRequest) GetLastTerm 

func (x *SnapshotRequest) GetLastTerm() uint64

func (*SnapshotRequest) GetLeaderName 

func (x *SnapshotRequest) GetLeaderName() string

func (*SnapshotRequest) ProtoMessage 

func (*SnapshotRequest) ProtoMessage()

func (*SnapshotRequest) ProtoReflect 

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

func (*SnapshotRequest) Reset 

func (x *SnapshotRequest) Reset()

func (*SnapshotRequest) String 

func (x *SnapshotRequest) String() string

type SnapshotResponse 

type SnapshotResponse struct {
	Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotResponse) Descriptor deprecated 

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

Deprecated: Use SnapshotResponse.ProtoReflect.Descriptor instead.

func (*SnapshotResponse) GetSuccess 

func (x *SnapshotResponse) GetSuccess() bool

func (*SnapshotResponse) ProtoMessage 

func (*SnapshotResponse) ProtoMessage()

func (*SnapshotResponse) ProtoReflect 

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

func (*SnapshotResponse) Reset 

func (x *SnapshotResponse) Reset()

func (*SnapshotResponse) String 

func (x *SnapshotResponse) String() string

type UnimplementedRaftServerServer 

type UnimplementedRaftServerServer struct {
}

UnimplementedRaftServerServer must be embedded to have forward compatible implementations.

func (UnimplementedRaftServerServer) AppendEntriesRequestHandler 

func (UnimplementedRaftServerServer) AppendEntriesRequestHandler(context.Context, *AppendEntriesRequest) (*AppendEntriesResponse, error)

func (UnimplementedRaftServerServer) ClusterJoinHandler 

func (UnimplementedRaftServerServer) ClusterJoinHandler(context.Context, *ClusterJoinRequest) (*ClusterJoinResponse, error)

func (UnimplementedRaftServerServer) ClusterLeaveHandler 

func (UnimplementedRaftServerServer) ClusterLeaveHandler(context.Context, *ClusterLeaveRequest) (*ClusterLeaveResponse, error)

func (UnimplementedRaftServerServer) ClusterStatusHandler 

func (UnimplementedRaftServerServer) ClusterStatusHandler(context.Context, *ClusterStatusRequest) (*ClusterStatusResponse, error)

func (UnimplementedRaftServerServer) NewVoteHandler 

func (UnimplementedRaftServerServer) NewVoteHandler(context.Context, *NewVoteRequest) (*NewVoteResponse, error)

func (UnimplementedRaftServerServer) SnapshotRecoveryRequestHandler 

func (UnimplementedRaftServerServer) SnapshotRecoveryRequestHandler(context.Context, *SnapshotRecoveryRequest) (*SnapshotRecoveryResponse, error)

func (UnimplementedRaftServerServer) SnapshotRequestHandler 

func (UnimplementedRaftServerServer) SnapshotRequestHandler(context.Context, *SnapshotRequest) (*SnapshotResponse, error)

func (UnimplementedRaftServerServer) VoteRequestHandler 

func (UnimplementedRaftServerServer) VoteRequestHandler(context.Context, *RequestVoteRequest) (*RequestVoteResponse, error)

type UnsafeRaftServerServer 

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

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

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.