Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FSMSnapshot ¶
type FSMSnapshot struct { }
func (*FSMSnapshot) Persist ¶
func (f *FSMSnapshot) Persist(sink raft.SnapshotSink) error
func (*FSMSnapshot) Release ¶
func (f *FSMSnapshot) Release()
type Raft ¶
type Raft struct {
// contains filtered or unexported fields
}
Raft manages consensus on Jocko cluster using Hashicorp Raft
func (*Raft) Apply ¶
func (b *Raft) Apply(cmd jocko.RaftCommand) error
Apply command to all raft nodes
func (*Raft) Bootstrap ¶
func (b *Raft) Bootstrap(serf jocko.Serf, serfEventCh <-chan *jocko.ClusterMember, commandCh chan<- jocko.RaftCommand) (err error)
Bootstrap is used to bootstrap the raft instance. Commands received by raft are sent on commandCh channel.
Click to show internal directories.
Click to hide internal directories.