message

package
v0.0.5 Latest Latest
Warning

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

 Go to latest Published: Feb 11, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_raft_proto protoreflect.FileDescriptor

Functions

func RegisterMessageServer 

func RegisterMessageServer(s *grpc.Server, srv MessageServer)

Types

type AppendEntriesReply 

type AppendEntriesReply struct {
	Term          int32 `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	Success       bool  `protobuf:"varint,2,opt,name=Success,proto3" json:"Success,omitempty"`
	ConflictIndex int32 `protobuf:"varint,3,opt,name=ConflictIndex,proto3" json:"ConflictIndex,omitempty"`
	ConflictTerm  int32 `protobuf:"varint,4,opt,name=ConflictTerm,proto3" json:"ConflictTerm,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendEntriesReply) Descriptor deprecated 

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

Deprecated: Use AppendEntriesReply.ProtoReflect.Descriptor instead.

func (*AppendEntriesReply) GetConflictIndex 

func (x *AppendEntriesReply) GetConflictIndex() int32

func (*AppendEntriesReply) GetConflictTerm 

func (x *AppendEntriesReply) GetConflictTerm() int32

func (*AppendEntriesReply) GetSuccess 

func (x *AppendEntriesReply) GetSuccess() bool

func (*AppendEntriesReply) GetTerm 

func (x *AppendEntriesReply) GetTerm() int32

func (*AppendEntriesReply) ProtoMessage 

func (*AppendEntriesReply) ProtoMessage()

func (*AppendEntriesReply) ProtoReflect 

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

func (*AppendEntriesReply) Reset 

func (x *AppendEntriesReply) Reset()

func (*AppendEntriesReply) String 

func (x *AppendEntriesReply) String() string

type AppendEntriesRequest 

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

func (*AppendEntriesRequest) Descriptor deprecated 

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

Deprecated: Use AppendEntriesRequest.ProtoReflect.Descriptor instead.

func (*AppendEntriesRequest) GetEntries 

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

func (*AppendEntriesRequest) GetLeaderCommit 

func (x *AppendEntriesRequest) GetLeaderCommit() int32

func (*AppendEntriesRequest) GetLeaderId 

func (x *AppendEntriesRequest) GetLeaderId() string

func (*AppendEntriesRequest) GetPrevLogIndex 

func (x *AppendEntriesRequest) GetPrevLogIndex() int32

func (*AppendEntriesRequest) GetPrevLogTerm 

func (x *AppendEntriesRequest) GetPrevLogTerm() int32

func (*AppendEntriesRequest) GetTerm 

func (x *AppendEntriesRequest) GetTerm() int32

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 AppendEntriesRequest_LogEntry 

type AppendEntriesRequest_LogEntry struct {
	Command string `protobuf:"bytes,1,opt,name=Command,proto3" json:"Command,omitempty"`
	Term    int32  `protobuf:"varint,2,opt,name=Term,proto3" json:"Term,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendEntriesRequest_LogEntry) Descriptor deprecated 

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

Deprecated: Use AppendEntriesRequest_LogEntry.ProtoReflect.Descriptor instead.

func (*AppendEntriesRequest_LogEntry) GetCommand 

func (x *AppendEntriesRequest_LogEntry) GetCommand() string

func (*AppendEntriesRequest_LogEntry) GetTerm 

func (x *AppendEntriesRequest_LogEntry) GetTerm() int32

func (*AppendEntriesRequest_LogEntry) ProtoMessage 

func (*AppendEntriesRequest_LogEntry) ProtoMessage()

func (*AppendEntriesRequest_LogEntry) ProtoReflect 

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

func (*AppendEntriesRequest_LogEntry) Reset 

func (x *AppendEntriesRequest_LogEntry) Reset()

func (*AppendEntriesRequest_LogEntry) String 

func (x *AppendEntriesRequest_LogEntry) String() string

type ForwardMessageReply 

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

func (*ForwardMessageReply) Descriptor deprecated 

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

Deprecated: Use ForwardMessageReply.ProtoReflect.Descriptor instead.

func (*ForwardMessageReply) GetSubmitGranted 

func (x *ForwardMessageReply) GetSubmitGranted() bool

func (*ForwardMessageReply) GetTerm 

func (x *ForwardMessageReply) GetTerm() int32

func (*ForwardMessageReply) ProtoMessage 

func (*ForwardMessageReply) ProtoMessage()

func (*ForwardMessageReply) ProtoReflect 

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

func (*ForwardMessageReply) Reset 

func (x *ForwardMessageReply) Reset()

func (*ForwardMessageReply) String 

func (x *ForwardMessageReply) String() string

type ForwardMessageRequest 

type ForwardMessageRequest struct {
	Term    int32  `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	NodeID  string `protobuf:"bytes,2,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
	Command string `protobuf:"bytes,3,opt,name=Command,proto3" json:"Command,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardMessageRequest) Descriptor deprecated 

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

Deprecated: Use ForwardMessageRequest.ProtoReflect.Descriptor instead.

func (*ForwardMessageRequest) GetCommand 

func (x *ForwardMessageRequest) GetCommand() string

func (*ForwardMessageRequest) GetNodeID 

func (x *ForwardMessageRequest) GetNodeID() string

func (*ForwardMessageRequest) GetTerm 

func (x *ForwardMessageRequest) GetTerm() int32

func (*ForwardMessageRequest) ProtoMessage 

func (*ForwardMessageRequest) ProtoMessage()

func (*ForwardMessageRequest) ProtoReflect 

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

func (*ForwardMessageRequest) Reset 

func (x *ForwardMessageRequest) Reset()

func (*ForwardMessageRequest) String 

func (x *ForwardMessageRequest) String() string

type MessageClient 

type MessageClient interface {
	RequestVote(ctx context.Context, in *RequestVoteRequest, opts ...grpc.CallOption) (*RequestVoteReply, error)
	AppendEntries(ctx context.Context, in *AppendEntriesRequest, opts ...grpc.CallOption) (*AppendEntriesReply, error)
	ForwardMessage(ctx context.Context, in *ForwardMessageRequest, opts ...grpc.CallOption) (*ForwardMessageReply, error)
	Replica(ctx context.Context, in *ReplicaRequest, opts ...grpc.CallOption) (*ReplicaReply, error)
}

MessageClient is the client API for Message service.

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

func NewMessageClient 

func NewMessageClient(cc grpc.ClientConnInterface) MessageClient

type MessageServer 

type MessageServer interface {
	RequestVote(context.Context, *RequestVoteRequest) (*RequestVoteReply, error)
	AppendEntries(context.Context, *AppendEntriesRequest) (*AppendEntriesReply, error)
	ForwardMessage(context.Context, *ForwardMessageRequest) (*ForwardMessageReply, error)
	Replica(context.Context, *ReplicaRequest) (*ReplicaReply, error)
}

MessageServer is the server API for Message service.

type ReplicaReply 

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

func (*ReplicaReply) Descriptor deprecated 

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

Deprecated: Use ReplicaReply.ProtoReflect.Descriptor instead.

func (*ReplicaReply) GetSuccess 

func (x *ReplicaReply) GetSuccess() bool

func (*ReplicaReply) ProtoMessage 

func (*ReplicaReply) ProtoMessage()

func (*ReplicaReply) ProtoReflect 

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

func (*ReplicaReply) Reset 

func (x *ReplicaReply) Reset()

func (*ReplicaReply) String 

func (x *ReplicaReply) String() string

type ReplicaRequest 

type ReplicaRequest struct {
	Nodes []*ReplicaRequest_NodeInfo `protobuf:"bytes,1,rep,name=Nodes,proto3" json:"Nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaRequest) Descriptor deprecated 

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

Deprecated: Use ReplicaRequest.ProtoReflect.Descriptor instead.

func (*ReplicaRequest) GetNodes 

func (x *ReplicaRequest) GetNodes() []*ReplicaRequest_NodeInfo

func (*ReplicaRequest) ProtoMessage 

func (*ReplicaRequest) ProtoMessage()

func (*ReplicaRequest) ProtoReflect 

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

func (*ReplicaRequest) Reset 

func (x *ReplicaRequest) Reset()

func (*ReplicaRequest) String 

func (x *ReplicaRequest) String() string

type ReplicaRequest_NodeInfo 

type ReplicaRequest_NodeInfo struct {
	NodeID   string `protobuf:"bytes,1,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
	IsRemove bool   `protobuf:"varint,2,opt,name=IsRemove,proto3" json:"IsRemove,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaRequest_NodeInfo) Descriptor deprecated 

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

Deprecated: Use ReplicaRequest_NodeInfo.ProtoReflect.Descriptor instead.

func (*ReplicaRequest_NodeInfo) GetIsRemove 

func (x *ReplicaRequest_NodeInfo) GetIsRemove() bool

func (*ReplicaRequest_NodeInfo) GetNodeID 

func (x *ReplicaRequest_NodeInfo) GetNodeID() string

func (*ReplicaRequest_NodeInfo) ProtoMessage 

func (*ReplicaRequest_NodeInfo) ProtoMessage()

func (*ReplicaRequest_NodeInfo) ProtoReflect 

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

func (*ReplicaRequest_NodeInfo) Reset 

func (x *ReplicaRequest_NodeInfo) Reset()

func (*ReplicaRequest_NodeInfo) String 

func (x *ReplicaRequest_NodeInfo) String() string

type RequestVoteReply 

type RequestVoteReply struct {
	Term        int32 `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 (*RequestVoteReply) Descriptor deprecated 

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

Deprecated: Use RequestVoteReply.ProtoReflect.Descriptor instead.

func (*RequestVoteReply) GetTerm 

func (x *RequestVoteReply) GetTerm() int32

func (*RequestVoteReply) GetVoteGranted 

func (x *RequestVoteReply) GetVoteGranted() bool

func (*RequestVoteReply) ProtoMessage 

func (*RequestVoteReply) ProtoMessage()

func (*RequestVoteReply) ProtoReflect 

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

func (*RequestVoteReply) Reset 

func (x *RequestVoteReply) Reset()

func (*RequestVoteReply) String 

func (x *RequestVoteReply) String() string

type RequestVoteRequest 

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

func (*RequestVoteRequest) Descriptor deprecated 

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

Deprecated: Use RequestVoteRequest.ProtoReflect.Descriptor instead.

func (*RequestVoteRequest) GetCandidateId 

func (x *RequestVoteRequest) GetCandidateId() string

func (*RequestVoteRequest) GetLastLogIndex 

func (x *RequestVoteRequest) GetLastLogIndex() int32

func (*RequestVoteRequest) GetLastLogTerm 

func (x *RequestVoteRequest) GetLastLogTerm() int32

func (*RequestVoteRequest) GetTerm 

func (x *RequestVoteRequest) GetTerm() int32

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 UnimplementedMessageServer 

type UnimplementedMessageServer struct {
}

UnimplementedMessageServer can be embedded to have forward compatible implementations.

func (*UnimplementedMessageServer) AppendEntries 

func (*UnimplementedMessageServer) AppendEntries(context.Context, *AppendEntriesRequest) (*AppendEntriesReply, error)

func (*UnimplementedMessageServer) ForwardMessage 

func (*UnimplementedMessageServer) ForwardMessage(context.Context, *ForwardMessageRequest) (*ForwardMessageReply, error)

func (*UnimplementedMessageServer) Replica 

func (*UnimplementedMessageServer) Replica(context.Context, *ReplicaRequest) (*ReplicaReply, error)

func (*UnimplementedMessageServer) RequestVote 

func (*UnimplementedMessageServer) RequestVote(context.Context, *RequestVoteRequest) (*RequestVoteReply, 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.