goraft

README

GoRaft

A Go implementation of the Raft algorithm.

Documentation

Index

• Constants
• type AppendEntriesArgs
• type AppendEntriesReply
• type Raft
  • func NewRaft(id int, peerIds []int, server *Server, applyCh <-chan interface{}) *Raft
  • func (rf *Raft) AppendEntries(args AppendEntriesArgs, reply *AppendEntriesReply) error
  • func (rf *Raft) RequestVote(args RequestVoteArgs, reply *RequestVoteReply) error
  • func (rf *Raft) Stop()
• type RequestVoteArgs
• type RequestVoteReply
• type Server
  • func NewServer(serverId int, peerIds []int, applyCh <-chan interface{}) *Server
  • func (s *Server) Call(id int, serviceMethod string, args interface{}, reply interface{}) error
  • func (s *Server) ConnectToPeer(peerId int, addr net.Addr) error
  • func (s *Server) DisconnectAll()
  • func (s *Server) DisconnectPeer(peerId int) error
  • func (s *Server) GetListenAddr() net.Addr
  • func (s *Server) Serve()
  • func (s *Server) Shutdown()

Constants

const DebugRaft = true

Types

type AppendEntriesArgs

type AppendEntriesArgs struct {
}

type AppendEntriesReply

type AppendEntriesReply struct {
}

type Raft

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

func NewRaft

func NewRaft(id int, peerIds []int, server *Server, applyCh <-chan interface{}) *Raft

func (*Raft) AppendEntries

func (rf *Raft) AppendEntries(args AppendEntriesArgs, reply *AppendEntriesReply) error

func (*Raft) RequestVote

func (rf *Raft) RequestVote(args RequestVoteArgs, reply *RequestVoteReply) error

func (*Raft) Stop

func (rf *Raft) Stop()

type RequestVoteArgs

type RequestVoteArgs struct {
}

type RequestVoteReply

type RequestVoteReply struct {
}

type Server

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

func NewServer

func NewServer(serverId int, peerIds []int, applyCh <-chan interface{}) *Server

func (*Server) Call

func (s *Server) Call(id int, serviceMethod string, args interface{}, reply interface{}) error

func (*Server) ConnectToPeer

func (s *Server) ConnectToPeer(peerId int, addr net.Addr) error

func (*Server) DisconnectAll

func (s *Server) DisconnectAll()

func (*Server) DisconnectPeer

func (s *Server) DisconnectPeer(peerId int) error

func (*Server) GetListenAddr

func (s *Server) GetListenAddr() net.Addr

func (*Server) Serve

func (s *Server) Serve()

func (*Server) Shutdown

func (s *Server) Shutdown()