fsm

Documentation

Index

• type ApplyRequest
• type ApplyResponse
• type Fsm
  • func New(nodeConfig node.Config) *Fsm
  • func (f *Fsm) Apply(log *raft.Log) interface{}
  • func (f *Fsm) Restore(closer io.ReadCloser) error
  • func (f *Fsm) Snapshot() (raft.FSMSnapshot, error)

Types

type ApplyRequest

type ApplyRequest struct {
	Command func() interface{}
}

type ApplyResponse

type ApplyResponse struct {
	Data  interface{}
	Error error
}

type Fsm

type Fsm struct {
	Raft    *raft.Raft
	Manager *transport.Manager
	// contains filtered or unexported fields
}

func New

func New(nodeConfig node.Config) *Fsm

func (*Fsm) Apply

func (f *Fsm) Apply(log *raft.Log) interface{}

func (*Fsm) Restore

func (f *Fsm) Restore(closer io.ReadCloser) error

func (*Fsm) Snapshot

func (f *Fsm) Snapshot() (raft.FSMSnapshot, error)