Documentation
¶
Index ¶
- Variables
- type ZmqTransporter
- func (t *ZmqTransporter) Install(bindto string, server raft.Server)
- func (t *ZmqTransporter) SendAppendEntriesRequest(server raft.Server, peer *raft.Peer, req *raft.AppendEntriesRequest) *raft.AppendEntriesResponse
- func (t *ZmqTransporter) SendSnapshotRecoveryRequest(server raft.Server, peer *raft.Peer, req *raft.SnapshotRecoveryRequest) *raft.SnapshotRecoveryResponse
- func (t *ZmqTransporter) SendSnapshotRequest(server raft.Server, peer *raft.Peer, req *raft.SnapshotRequest) *raft.SnapshotResponse
- func (t *ZmqTransporter) SendVoteRequest(server raft.Server, peer *raft.Peer, req *raft.RequestVoteRequest) *raft.RequestVoteResponse
Constants ¶
This section is empty.
Variables ¶
View Source
var ( MSG_VOTE = "vote" MSG_APPENDENTRIES = "appendEntries" )
Functions ¶
This section is empty.
Types ¶
type ZmqTransporter ¶
type ZmqTransporter struct {
}
ZMQ transporter is a transport layer used for communication between multiple servers using ZMQ messaging.
func NewZmqTransporter ¶
func NewZmqTransporter() *ZmqTransporter
func (*ZmqTransporter) Install ¶
func (t *ZmqTransporter) Install(bindto string, server raft.Server)
func (*ZmqTransporter) SendAppendEntriesRequest ¶
func (t *ZmqTransporter) SendAppendEntriesRequest(server raft.Server, peer *raft.Peer, req *raft.AppendEntriesRequest) *raft.AppendEntriesResponse
func (*ZmqTransporter) SendSnapshotRecoveryRequest ¶
func (t *ZmqTransporter) SendSnapshotRecoveryRequest(server raft.Server, peer *raft.Peer, req *raft.SnapshotRecoveryRequest) *raft.SnapshotRecoveryResponse
Sends a SnapshotRequest RPC to a peer.
func (*ZmqTransporter) SendSnapshotRequest ¶
func (t *ZmqTransporter) SendSnapshotRequest(server raft.Server, peer *raft.Peer, req *raft.SnapshotRequest) *raft.SnapshotResponse
Sends a SnapshotRequest RPC to a peer.
func (*ZmqTransporter) SendVoteRequest ¶
func (t *ZmqTransporter) SendVoteRequest(server raft.Server, peer *raft.Peer, req *raft.RequestVoteRequest) *raft.RequestVoteResponse
Source Files
Click to show internal directories.
Click to hide internal directories.