raft

Documentation

Index

• func NewFSM(opts FSMOpts) raft.FSM
• type FSM
  • func (fsm *FSM) Apply(log *raft.Log) interface{}
  • func (fsm *FSM) Restore(snapshot io.ReadCloser) error
  • func (fsm *FSM) Snapshot() (raft.FSMSnapshot, error)
• type FSMOpts
• type Opts
• type Raft
  • func NewRaft(opts Opts) *Raft
  • func (r *Raft) AddVoter(id raft.ServerID, address raft.ServerAddress, prevIndex uint64, ...) error
  • func (r *Raft) Apply(cmd []byte, timeout time.Duration) raft.ApplyFuture
  • func (r *Raft) HasJoinedCluster() bool
  • func (r *Raft) IsRaftLeader() bool
  • func (r *Raft) RaftInit(ctx context.Context)
  • func (r *Raft) RaftShutdown()
  • func (r *Raft) RemoveServer(meta memberlist.NodeMeta) error
  • func (r *Raft) TakeSnapshot() error
• type Snapshot
  • func NewFSMSnapshot(opts SnapshotOpts) *Snapshot
  • func (s *Snapshot) Persist(sink raft.SnapshotSink) error
  • func (s *Snapshot) Release()
• type SnapshotOpts

Functions

func NewFSM

func NewFSM(opts FSMOpts) raft.FSM

Types

type FSM

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

func (*FSM) Apply

func (fsm *FSM) Apply(log *raft.Log) interface{}

Apply Implements raft.FSM interface

func (*FSM) Restore

func (fsm *FSM) Restore(snapshot io.ReadCloser) error

Restore implements raft.FSM interface

func (*FSM) Snapshot

func (fsm *FSM) Snapshot() (raft.FSMSnapshot, error)

Snapshot implements raft.FSM interface

type FSMOpts

type FSMOpts struct {
	Config                config.Config
	GetState              func() map[int]map[string]internal.KeyData
	GetCommand            func(command string) (internal.Command, error)
	SetValues             func(ctx context.Context, entries map[string]interface{}) error
	SetExpiry             func(ctx context.Context, key string, expire time.Time, touch bool)
	DeleteKey             func(ctx context.Context, key string) error
	StartSnapshot         func()
	FinishSnapshot        func()
	SetLatestSnapshotTime func(msec int64)
	GetHandlerFuncParams  func(ctx context.Context, cmd []string, conn *net.Conn) internal.HandlerFuncParams
}

type Opts

type Opts struct {
	Config                config.Config
	SetValues             func(ctx context.Context, entries map[string]interface{}) error
	SetExpiry             func(ctx context.Context, key string, expire time.Time, touch bool)
	GetState              func() map[int]map[string]internal.KeyData
	GetCommand            func(command string) (internal.Command, error)
	DeleteKey             func(ctx context.Context, key string) error
	StartSnapshot         func()
	FinishSnapshot        func()
	SetLatestSnapshotTime func(msec int64)
	GetHandlerFuncParams  func(ctx context.Context, cmd []string, conn *net.Conn) internal.HandlerFuncParams
}

type Raft

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

func NewRaft

func NewRaft(opts Opts) *Raft

func (*Raft) AddVoter

func (r *Raft) AddVoter(
	id raft.ServerID,
	address raft.ServerAddress,
	prevIndex uint64,
	timeout time.Duration,
) error

func (*Raft) Apply

func (r *Raft) Apply(cmd []byte, timeout time.Duration) raft.ApplyFuture

func (*Raft) HasJoinedCluster

func (r *Raft) HasJoinedCluster() bool

func (*Raft) IsRaftLeader

func (r *Raft) IsRaftLeader() bool

func (*Raft) RaftInit

func (r *Raft) RaftInit(ctx context.Context)

func (*Raft) RaftShutdown

func (r *Raft) RaftShutdown()

func (*Raft) RemoveServer

func (r *Raft) RemoveServer(meta memberlist.NodeMeta) error

func (*Raft) TakeSnapshot

func (r *Raft) TakeSnapshot() error

type Snapshot

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

func NewFSMSnapshot

func NewFSMSnapshot(opts SnapshotOpts) *Snapshot

func (*Snapshot) Persist

func (s *Snapshot) Persist(sink raft.SnapshotSink) error

Persist implements FSMSnapshot interface

func (*Snapshot) Release

func (s *Snapshot) Release()

Release implements FSMSnapshot interface

type SnapshotOpts

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