Documentation ¶
Overview ¶
Package protobufs is a generated protocol buffer package.
It is generated from these files:
common.proto communication.proto nodelist.proto
It has these top-level messages:
EntryPb VoteRequestPb VoteResponsePb AppendRequestPb JoinRequestPb AppendResponsePb ProposalResponsePb DiscoveryResponsePb NodePb NodeListPb
Index ¶
- type AppendRequestPb
- func (*AppendRequestPb) Descriptor() ([]byte, []int)
- func (m *AppendRequestPb) GetEntries() []*EntryPb
- func (m *AppendRequestPb) GetLeaderCommit() uint64
- func (m *AppendRequestPb) GetLeaderId() uint64
- func (m *AppendRequestPb) GetPrevLogIndex() uint64
- func (m *AppendRequestPb) GetPrevLogTerm() uint64
- func (m *AppendRequestPb) GetTerm() uint64
- func (*AppendRequestPb) ProtoMessage()
- func (m *AppendRequestPb) Reset()
- func (m *AppendRequestPb) String() string
- type AppendResponsePb
- type DiscoveryResponsePb
- type EntryPb
- func (*EntryPb) Descriptor() ([]byte, []int)
- func (m *EntryPb) GetData() []byte
- func (m *EntryPb) GetIndex() uint64
- func (m *EntryPb) GetTags() []string
- func (m *EntryPb) GetTerm() uint64
- func (m *EntryPb) GetTimestamp() int64
- func (m *EntryPb) GetType() int32
- func (*EntryPb) ProtoMessage()
- func (m *EntryPb) Reset()
- func (m *EntryPb) String() string
- type JoinRequestPb
- func (*JoinRequestPb) Descriptor() ([]byte, []int)
- func (m *JoinRequestPb) GetClusterId() uint64
- func (m *JoinRequestPb) GetConfigEntries() []*EntryPb
- func (m *JoinRequestPb) GetEntries() []*EntryPb
- func (m *JoinRequestPb) GetLast() bool
- func (*JoinRequestPb) ProtoMessage()
- func (m *JoinRequestPb) Reset()
- func (m *JoinRequestPb) String() string
- type NodeListPb
- type NodePb
- type ProposalResponsePb
- type UserPb
- type UserTablePb
- type VoteRequestPb
- func (*VoteRequestPb) Descriptor() ([]byte, []int)
- func (m *VoteRequestPb) GetCandidateId() uint64
- func (m *VoteRequestPb) GetClusterId() uint64
- func (m *VoteRequestPb) GetLastLogIndex() uint64
- func (m *VoteRequestPb) GetLastLogTerm() uint64
- func (m *VoteRequestPb) GetTerm() uint64
- func (*VoteRequestPb) ProtoMessage()
- func (m *VoteRequestPb) Reset()
- func (m *VoteRequestPb) String() string
- type VoteResponsePb
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppendRequestPb ¶
type AppendRequestPb struct { Term *uint64 `protobuf:"varint,1,req,name=term" json:"term,omitempty"` LeaderId *uint64 `protobuf:"fixed64,2,req,name=leaderId" json:"leaderId,omitempty"` PrevLogIndex *uint64 `protobuf:"varint,3,req,name=prevLogIndex" json:"prevLogIndex,omitempty"` PrevLogTerm *uint64 `protobuf:"varint,4,req,name=prevLogTerm" json:"prevLogTerm,omitempty"` LeaderCommit *uint64 `protobuf:"varint,5,req,name=leaderCommit" json:"leaderCommit,omitempty"` Entries []*EntryPb `protobuf:"bytes,6,rep,name=entries" json:"entries,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AppendRequestPb) Descriptor ¶
func (*AppendRequestPb) Descriptor() ([]byte, []int)
func (*AppendRequestPb) GetEntries ¶
func (m *AppendRequestPb) GetEntries() []*EntryPb
func (*AppendRequestPb) GetLeaderCommit ¶
func (m *AppendRequestPb) GetLeaderCommit() uint64
func (*AppendRequestPb) GetLeaderId ¶
func (m *AppendRequestPb) GetLeaderId() uint64
func (*AppendRequestPb) GetPrevLogIndex ¶
func (m *AppendRequestPb) GetPrevLogIndex() uint64
func (*AppendRequestPb) GetPrevLogTerm ¶
func (m *AppendRequestPb) GetPrevLogTerm() uint64
func (*AppendRequestPb) GetTerm ¶
func (m *AppendRequestPb) GetTerm() uint64
func (*AppendRequestPb) ProtoMessage ¶
func (*AppendRequestPb) ProtoMessage()
func (*AppendRequestPb) Reset ¶
func (m *AppendRequestPb) Reset()
func (*AppendRequestPb) String ¶
func (m *AppendRequestPb) String() string
type AppendResponsePb ¶
type AppendResponsePb struct { Term *uint64 `protobuf:"varint,1,req,name=term" json:"term,omitempty"` Success *bool `protobuf:"varint,2,req,name=success" json:"success,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AppendResponsePb) Descriptor ¶
func (*AppendResponsePb) Descriptor() ([]byte, []int)
func (*AppendResponsePb) GetSuccess ¶
func (m *AppendResponsePb) GetSuccess() bool
func (*AppendResponsePb) GetTerm ¶
func (m *AppendResponsePb) GetTerm() uint64
func (*AppendResponsePb) ProtoMessage ¶
func (*AppendResponsePb) ProtoMessage()
func (*AppendResponsePb) Reset ¶
func (m *AppendResponsePb) Reset()
func (*AppendResponsePb) String ¶
func (m *AppendResponsePb) String() string
type DiscoveryResponsePb ¶
type DiscoveryResponsePb struct { NodeId *uint64 `protobuf:"fixed64,1,req,name=nodeId" json:"nodeId,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*DiscoveryResponsePb) Descriptor ¶
func (*DiscoveryResponsePb) Descriptor() ([]byte, []int)
func (*DiscoveryResponsePb) GetNodeId ¶
func (m *DiscoveryResponsePb) GetNodeId() uint64
func (*DiscoveryResponsePb) ProtoMessage ¶
func (*DiscoveryResponsePb) ProtoMessage()
func (*DiscoveryResponsePb) Reset ¶
func (m *DiscoveryResponsePb) Reset()
func (*DiscoveryResponsePb) String ¶
func (m *DiscoveryResponsePb) String() string
type EntryPb ¶
type EntryPb struct { Index *uint64 `protobuf:"varint,1,req,name=index" json:"index,omitempty"` Type *int32 `protobuf:"varint,2,req,name=type" json:"type,omitempty"` Term *uint64 `protobuf:"varint,3,opt,name=term" json:"term,omitempty"` Timestamp *int64 `protobuf:"varint,4,opt,name=timestamp" json:"timestamp,omitempty"` Tags []string `protobuf:"bytes,5,rep,name=tags" json:"tags,omitempty"` Data []byte `protobuf:"bytes,6,opt,name=data" json:"data,omitempty"` XXX_unrecognized []byte `json:"-"` }
A single Raft entry.
func (*EntryPb) Descriptor ¶
func (*EntryPb) GetTimestamp ¶
func (*EntryPb) ProtoMessage ¶
func (*EntryPb) ProtoMessage()
type JoinRequestPb ¶
type JoinRequestPb struct { ClusterId *uint64 `protobuf:"fixed64,1,req,name=clusterId" json:"clusterId,omitempty"` Last *bool `protobuf:"varint,2,opt,name=last" json:"last,omitempty"` Entries []*EntryPb `protobuf:"bytes,3,rep,name=entries" json:"entries,omitempty"` ConfigEntries []*EntryPb `protobuf:"bytes,4,rep,name=configEntries" json:"configEntries,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*JoinRequestPb) Descriptor ¶
func (*JoinRequestPb) Descriptor() ([]byte, []int)
func (*JoinRequestPb) GetClusterId ¶
func (m *JoinRequestPb) GetClusterId() uint64
func (*JoinRequestPb) GetConfigEntries ¶ added in v0.5.2
func (m *JoinRequestPb) GetConfigEntries() []*EntryPb
func (*JoinRequestPb) GetEntries ¶
func (m *JoinRequestPb) GetEntries() []*EntryPb
func (*JoinRequestPb) GetLast ¶
func (m *JoinRequestPb) GetLast() bool
func (*JoinRequestPb) ProtoMessage ¶
func (*JoinRequestPb) ProtoMessage()
func (*JoinRequestPb) Reset ¶
func (m *JoinRequestPb) Reset()
func (*JoinRequestPb) String ¶
func (m *JoinRequestPb) String() string
type NodeListPb ¶
type NodeListPb struct { Current []*NodePb `protobuf:"bytes,1,rep,name=current" json:"current,omitempty"` Next []*NodePb `protobuf:"bytes,2,rep,name=next" json:"next,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*NodeListPb) Descriptor ¶
func (*NodeListPb) Descriptor() ([]byte, []int)
func (*NodeListPb) GetCurrent ¶
func (m *NodeListPb) GetCurrent() []*NodePb
func (*NodeListPb) GetNext ¶
func (m *NodeListPb) GetNext() []*NodePb
func (*NodeListPb) ProtoMessage ¶
func (*NodeListPb) ProtoMessage()
func (*NodeListPb) Reset ¶
func (m *NodeListPb) Reset()
func (*NodeListPb) String ¶
func (m *NodeListPb) String() string
type NodePb ¶
type NodePb struct { NodeId *uint64 `protobuf:"fixed64,1,req,name=nodeId" json:"nodeId,omitempty"` Address *string `protobuf:"bytes,2,req,name=address" json:"address,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*NodePb) Descriptor ¶
func (*NodePb) GetAddress ¶
func (*NodePb) ProtoMessage ¶
func (*NodePb) ProtoMessage()
type ProposalResponsePb ¶
type ProposalResponsePb struct { NewIndex *uint64 `protobuf:"varint,1,req,name=newIndex" json:"newIndex,omitempty"` Error *string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ProposalResponsePb) Descriptor ¶
func (*ProposalResponsePb) Descriptor() ([]byte, []int)
func (*ProposalResponsePb) GetError ¶
func (m *ProposalResponsePb) GetError() string
func (*ProposalResponsePb) GetNewIndex ¶
func (m *ProposalResponsePb) GetNewIndex() uint64
func (*ProposalResponsePb) ProtoMessage ¶
func (*ProposalResponsePb) ProtoMessage()
func (*ProposalResponsePb) Reset ¶
func (m *ProposalResponsePb) Reset()
func (*ProposalResponsePb) String ¶
func (m *ProposalResponsePb) String() string
type UserPb ¶ added in v0.5.5
type UserPb struct { User *string `protobuf:"bytes,1,req,name=user" json:"user,omitempty"` Salt []byte `protobuf:"bytes,2,req,name=salt" json:"salt,omitempty"` Password []byte `protobuf:"bytes,3,req,name=password" json:"password,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*UserPb) Descriptor ¶ added in v0.5.5
func (*UserPb) GetPassword ¶ added in v0.5.5
func (*UserPb) ProtoMessage ¶ added in v0.5.5
func (*UserPb) ProtoMessage()
type UserTablePb ¶ added in v0.5.5
type UserTablePb struct { Users []*UserPb `protobuf:"bytes,1,rep,name=users" json:"users,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*UserTablePb) Descriptor ¶ added in v0.5.5
func (*UserTablePb) Descriptor() ([]byte, []int)
func (*UserTablePb) GetUsers ¶ added in v0.5.5
func (m *UserTablePb) GetUsers() []*UserPb
func (*UserTablePb) ProtoMessage ¶ added in v0.5.5
func (*UserTablePb) ProtoMessage()
func (*UserTablePb) Reset ¶ added in v0.5.5
func (m *UserTablePb) Reset()
func (*UserTablePb) String ¶ added in v0.5.5
func (m *UserTablePb) String() string
type VoteRequestPb ¶
type VoteRequestPb struct { Term *uint64 `protobuf:"varint,1,req,name=term" json:"term,omitempty"` CandidateId *uint64 `protobuf:"fixed64,2,req,name=candidateId" json:"candidateId,omitempty"` LastLogIndex *uint64 `protobuf:"varint,3,req,name=lastLogIndex" json:"lastLogIndex,omitempty"` LastLogTerm *uint64 `protobuf:"varint,4,req,name=lastLogTerm" json:"lastLogTerm,omitempty"` ClusterId *uint64 `protobuf:"fixed64,5,req,name=clusterId" json:"clusterId,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*VoteRequestPb) Descriptor ¶
func (*VoteRequestPb) Descriptor() ([]byte, []int)
func (*VoteRequestPb) GetCandidateId ¶
func (m *VoteRequestPb) GetCandidateId() uint64
func (*VoteRequestPb) GetClusterId ¶
func (m *VoteRequestPb) GetClusterId() uint64
func (*VoteRequestPb) GetLastLogIndex ¶
func (m *VoteRequestPb) GetLastLogIndex() uint64
func (*VoteRequestPb) GetLastLogTerm ¶
func (m *VoteRequestPb) GetLastLogTerm() uint64
func (*VoteRequestPb) GetTerm ¶
func (m *VoteRequestPb) GetTerm() uint64
func (*VoteRequestPb) ProtoMessage ¶
func (*VoteRequestPb) ProtoMessage()
func (*VoteRequestPb) Reset ¶
func (m *VoteRequestPb) Reset()
func (*VoteRequestPb) String ¶
func (m *VoteRequestPb) String() string
type VoteResponsePb ¶
type VoteResponsePb struct { NodeId *uint64 `protobuf:"fixed64,1,req,name=nodeId" json:"nodeId,omitempty"` Term *uint64 `protobuf:"varint,2,req,name=term" json:"term,omitempty"` VoteGranted *bool `protobuf:"varint,3,req,name=voteGranted" json:"voteGranted,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*VoteResponsePb) Descriptor ¶
func (*VoteResponsePb) Descriptor() ([]byte, []int)
func (*VoteResponsePb) GetNodeId ¶
func (m *VoteResponsePb) GetNodeId() uint64
func (*VoteResponsePb) GetTerm ¶
func (m *VoteResponsePb) GetTerm() uint64
func (*VoteResponsePb) GetVoteGranted ¶
func (m *VoteResponsePb) GetVoteGranted() bool
func (*VoteResponsePb) ProtoMessage ¶
func (*VoteResponsePb) ProtoMessage()
func (*VoteResponsePb) Reset ¶
func (m *VoteResponsePb) Reset()
func (*VoteResponsePb) String ¶
func (m *VoteResponsePb) String() string
Click to show internal directories.
Click to hide internal directories.