Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

raft

package

Go to main page

Versions in this module

v0

v0.3.0

Feb 7, 2014

Changes in this version

+ const AddPeerEventType

+ const DefaultHeartbeatInterval

+ const ElectionTimeoutThresholdEventType

+ const ElectionTimeoutThresholdPercent

+ const HeartbeatEventType

+ const HeartbeatIntervalEventType

+ const LeaderChangeEventType

+ const RemovePeerEventType

+ const StateChangeEventType

+ const TermChangeEventType

+ type CommandApply interface

+ Apply func(Context) (interface{}, error)

+ type Context interface

+ CommitIndex func() uint64

+ CurrentIndex func() uint64

+ CurrentTerm func() uint64

+ Server func() Server

+ type Event interface

+ PrevValue func() interface{}

+ Source func() interface{}

+ Type func() string

+ Value func() interface{}

+ type EventListener func(Event)

type HTTPTransporter

+ Transport *http.Transport

+ func (t *HTTPTransporter) SnapshotPath() string

+ func (t *HTTPTransporter) SnapshotRecoveryPath() string

type Server

+ AddEventListener func(string, EventListener)

+ HeartbeatInterval func() time.Duration

+ SetHeartbeatInterval func(duration time.Duration)

v0.2.0

Dec 23, 2013

Changes in this version

+ const Candidate

+ const Debug

+ const DefaultElectionTimeout

+ const DefaultHeartbeatTimeout

+ const Follower

+ const Leader

+ const MaxLogEntriesPerRequest

+ const NumberOfLogEntriesAfterSnapshot

+ const Snapshotting

+ const Stopped

+ const Trace

+ var CommandTimeoutError = errors.New("raft: Command timeout")

+ var DuplicatePeerError = errors.New("raft.Server: Duplicate peer")

+ var NotLeaderError = errors.New("raft.Server: Not current leader")

+ func LogLevel() int

+ func RegisterCommand(command Command)

+ func SetLogLevel(level int)

+ type AppendEntriesRequest struct

+ CommitIndex uint64

+ Entries []*LogEntry

+ LeaderName string

+ PrevLogIndex uint64

+ PrevLogTerm uint64

+ Term uint64

+ func (req *AppendEntriesRequest) Decode(r io.Reader) (int, error)

+ func (req *AppendEntriesRequest) Encode(w io.Writer) (int, error)

+ type AppendEntriesResponse struct

+ CommitIndex uint64

+ Index uint64

+ Success bool

+ Term uint64

+ func (resp *AppendEntriesResponse) Decode(r io.Reader) (int, error)

+ func (resp *AppendEntriesResponse) Encode(w io.Writer) (int, error)

+ type Command interface

+ Apply func(server Server) (interface{}, error)

+ CommandName func() string

+ type CommandEncoder interface

+ Decode func(r io.Reader) error

+ Encode func(w io.Writer) error

+ type Config struct

+ CommitIndex uint64

+ Peers []*Peer

+ type DefaultJoinCommand struct

+ ConnectionString string

+ Name string

+ func (c *DefaultJoinCommand) Apply(server Server) (interface{}, error)

+ func (c *DefaultJoinCommand) CommandName() string

+ func (c *DefaultJoinCommand) NodeName() string

+ type DefaultLeaveCommand struct

+ Name string

+ func (c *DefaultLeaveCommand) Apply(server Server) (interface{}, error)

+ func (c *DefaultLeaveCommand) CommandName() string

+ func (c *DefaultLeaveCommand) NodeName() string

+ type HTTPMuxer interface

+ HandleFunc func(string, func(http.ResponseWriter, *http.Request))

+ type HTTPTransporter struct

+ DisableKeepAlives bool

+ func NewHTTPTransporter(prefix string) *HTTPTransporter

+ func (t *HTTPTransporter) AppendEntriesPath() string

+ func (t *HTTPTransporter) Install(server Server, mux HTTPMuxer)

+ func (t *HTTPTransporter) Prefix() string

+ func (t *HTTPTransporter) RequestVotePath() string

+ func (t *HTTPTransporter) SendAppendEntriesRequest(server Server, peer *Peer, req *AppendEntriesRequest) *AppendEntriesResponse

+ func (t *HTTPTransporter) SendSnapshotRecoveryRequest(server Server, peer *Peer, req *SnapshotRecoveryRequest) *SnapshotRecoveryResponse

+ func (t *HTTPTransporter) SendSnapshotRequest(server Server, peer *Peer, req *SnapshotRequest) *SnapshotResponse

+ func (t *HTTPTransporter) SendVoteRequest(server Server, peer *Peer, req *RequestVoteRequest) *RequestVoteResponse

+ type JoinCommand interface

+ Apply func(server Server) (interface{}, error)

+ CommandName func() string

+ NodeName func() string

+ type LeaveCommand interface

+ Apply func(server Server) (interface{}, error)

+ CommandName func() string

+ NodeName func() string

+ type Log struct

+ ApplyFunc func(Command) (interface{}, error)

+ func (l *Log) CommitIndex() uint64

+ type LogEntry struct

+ Command []byte

+ CommandName string

+ Index uint64

+ Position int64

+ Term uint64

+ type NOPCommand struct

+ func (c NOPCommand) Apply(server Server) (interface{}, error)

+ func (c NOPCommand) CommandName() string

+ func (c NOPCommand) Decode(r io.Reader) error

+ func (c NOPCommand) Encode(w io.Writer) error

+ type Peer struct

+ ConnectionString string

+ Name string

+ type RequestVoteRequest struct

+ CandidateName string

+ LastLogIndex uint64

+ LastLogTerm uint64

+ Term uint64

+ func (req *RequestVoteRequest) Decode(r io.Reader) (int, error)

+ func (req *RequestVoteRequest) Encode(w io.Writer) (int, error)

+ type RequestVoteResponse struct

+ Term uint64

+ VoteGranted bool

+ func (resp *RequestVoteResponse) Decode(r io.Reader) (int, error)

+ func (resp *RequestVoteResponse) Encode(w io.Writer) (int, error)

+ type Server interface

+ AddPeer func(name string, connectiongString string) error

+ AppendEntries func(req *AppendEntriesRequest) *AppendEntriesResponse

+ CommitIndex func() uint64

+ Context func() interface{}

+ Do func(command Command) (interface{}, error)

+ ElectionTimeout func() time.Duration

+ GetState func() string

+ HeartbeatTimeout func() time.Duration

+ IsLogEmpty func() bool

+ LastCommandName func() string

+ Leader func() string

+ LoadSnapshot func() error

+ LogEntries func() []*LogEntry

+ LogPath func() string

+ MemberCount func() int

+ Name func() string

+ Path func() string

+ Peers func() map[string]*Peer

+ QuorumSize func() int

+ RemovePeer func(name string) error

+ RequestSnapshot func(req *SnapshotRequest) *SnapshotResponse

+ RequestVote func(req *RequestVoteRequest) *RequestVoteResponse

+ Running func() bool

+ SetElectionTimeout func(duration time.Duration)

+ SetHeartbeatTimeout func(duration time.Duration)

+ SetTransporter func(t Transporter)

+ SnapshotPath func(lastIndex uint64, lastTerm uint64) string

+ SnapshotRecoveryRequest func(req *SnapshotRecoveryRequest) *SnapshotRecoveryResponse

+ Start func() error

+ State func() string

+ StateMachine func() StateMachine

+ Stop func()

+ TakeSnapshot func() error

+ Term func() uint64

+ Transporter func() Transporter

+ VotedFor func() string

+ func NewServer(name string, path string, transporter Transporter, stateMachine StateMachine, ...) (Server, error)

+ type Snapshot struct

+ LastIndex uint64

+ LastTerm uint64

+ Path string

+ Peers []*Peer

+ State []byte

+ type SnapshotRecoveryRequest struct

+ LastIndex uint64

+ LastTerm uint64

+ LeaderName string

+ Peers []*Peer

+ State []byte

+ func (req *SnapshotRecoveryRequest) Decode(r io.Reader) (int, error)

+ func (req *SnapshotRecoveryRequest) Encode(w io.Writer) (int, error)

+ type SnapshotRecoveryResponse struct

+ CommitIndex uint64

+ Success bool

+ Term uint64

+ func (req *SnapshotRecoveryResponse) Decode(r io.Reader) (int, error)

+ func (req *SnapshotRecoveryResponse) Encode(w io.Writer) (int, error)

+ type SnapshotRequest struct

+ LastIndex uint64

+ LastTerm uint64

+ LeaderName string

+ func (req *SnapshotRequest) Decode(r io.Reader) (int, error)

+ func (req *SnapshotRequest) Encode(w io.Writer) (int, error)

+ type SnapshotResponse struct

+ Success bool

+ func (resp *SnapshotResponse) Decode(r io.Reader) (int, error)

+ func (resp *SnapshotResponse) Encode(w io.Writer) (int, error)

+ type StateMachine interface

+ Recovery func([]byte) error

+ Save func() ([]byte, error)

+ type Transporter interface

+ SendAppendEntriesRequest func(server Server, peer *Peer, req *AppendEntriesRequest) *AppendEntriesResponse

+ SendSnapshotRecoveryRequest func(server Server, peer *Peer, req *SnapshotRecoveryRequest) *SnapshotRecoveryResponse

+ SendSnapshotRequest func(server Server, peer *Peer, req *SnapshotRequest) *SnapshotResponse

+ SendVoteRequest func(server Server, peer *Peer, req *RequestVoteRequest) *RequestVoteResponse

v0.2.0-rc4

Dec 23, 2013

v0.2.0-rc3

Dec 16, 2013

v0.2.0-rc2

Dec 6, 2013