fsm

package

v0.0.0-...-5c72b2d Latest Latest Go to latest Published: Sep 8, 2021 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type ApplyResponse struct {
	Error error
	Data  interface{}
}

func NewApplyErr(err error) *ApplyResponse

type CommandPayload struct {
	Operation Operation
	Data      map[string]interface{}
}

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

func (f *FSMSnapshot) Persist(sink raft.SnapshotSink) error

func (f *FSMSnapshot) Release()

type Operation int

const (
	Update Operation = iota + 1
	Delete
)

type RaftFSM struct {
	ApplyCh chan *protobuf.Event
	// contains filtered or unexported fields
}

func NewRaftFSM(conf *config.AppConfig, logger logger.WriteLogger) (*RaftFSM, error)

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

Apply is raftコマンドの実行

func (f *RaftFSM) Close() error

Close is 終了処理ユーザー辞書DB、ドキュメントDBのClose

func (f *RaftFSM) Restore(rc io.ReadCloser) error

Restore is 未実装

func (f *RaftFSM) Search(req *protobuf.SearchRequest) ([]byte, error)

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

Snapshot is 未実装

func (f *RaftFSM) Start() error