2013-12-06 23:43:07 +00:00
|
|
|
package consul
|
|
|
|
|
|
|
|
import (
|
|
|
|
"github.com/hashicorp/raft"
|
|
|
|
"io"
|
|
|
|
)
|
|
|
|
|
|
|
|
// consulFSM implements a finite state machine that is used
|
2013-12-11 01:00:48 +00:00
|
|
|
// along with Raft to provide strong consistency. We implement
|
|
|
|
// this outside the Server to avoid exposing this outside the package.
|
2013-12-06 23:43:07 +00:00
|
|
|
type consulFSM struct {
|
2013-12-11 01:00:48 +00:00
|
|
|
state *StateStore
|
2013-12-06 23:43:07 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
// consulSnapshot is used to provide a snapshot of the current
|
|
|
|
// state in a way that can be accessed concurrently with operations
|
|
|
|
// that may modify the live state.
|
|
|
|
type consulSnapshot struct {
|
|
|
|
fsm *consulFSM
|
|
|
|
}
|
|
|
|
|
2013-12-11 01:00:48 +00:00
|
|
|
// NewFSM is used to construct a new FSM with a blank state
|
|
|
|
func NewFSM() (*consulFSM, error) {
|
|
|
|
state, err := NewStateStore()
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
fsm := &consulFSM{
|
|
|
|
state: state,
|
|
|
|
}
|
|
|
|
return fsm, nil
|
|
|
|
}
|
|
|
|
|
2013-12-06 23:43:07 +00:00
|
|
|
func (c *consulFSM) Apply([]byte) interface{} {
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c *consulFSM) Snapshot() (raft.FSMSnapshot, error) {
|
|
|
|
snap := &consulSnapshot{fsm: c}
|
|
|
|
return snap, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c *consulFSM) Restore(io.ReadCloser) error {
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (s *consulSnapshot) Persist(sink raft.SnapshotSink) error {
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (s *consulSnapshot) Release() {
|
|
|
|
}
|