raftutil

Documentation

Overview

Code generated by go generate; DO NOT EDIT.

Index

• Variables
• func FindFileInPath(file string, p string) (path string, err error)
• func FindRaftDir(p string) (raftpath string, err error)
• func FindRaftFile(p string) (raftpath string, err error)
• func LogEntries(p string) (<-chan interface{}, <-chan error, error)
• func RaftStateInfo(p string) (store *raftboltdb.BoltStore, firstIdx uint64, lastIdx uint64, err error)
• func RestoreFromArchive(archive io.Reader, filter *nomad.FSMFilter) (*state.StateStore, *raft.SnapshotMeta, error)
• func StateAsMap(store *state.StateStore) map[string][]interface{}
• type FSMHelper
  • func NewFSM(p string) (*FSMHelper, error)
  • func (f *FSMHelper) ApplyAll() (index uint64, term uint64, err error)
  • func (f *FSMHelper) ApplyNext() (index uint64, term uint64, err error)
  • func (f *FSMHelper) ApplyUntil(stopIdx uint64) (idx uint64, term uint64, err error)
  • func (f *FSMHelper) Close()
  • func (f *FSMHelper) State() *state.StateStore
  • func (f *FSMHelper) StateAsMap() map[string][]interface{}

Variables

var ErrNoMoreLogs = fmt.Errorf("no more logs")

Functions

func FindFileInPath

func FindFileInPath(file string, p string) (path string, err error)

FindFileInPath searches for file in path p

func FindRaftDir

func FindRaftDir(p string) (raftpath string, err error)

FindRaftDir finds raft.db and returns parent directory path

func FindRaftFile

func FindRaftFile(p string) (raftpath string, err error)

FindRaftFile finds raft.db and returns path

func LogEntries

func LogEntries(p string) (<-chan interface{}, <-chan error, error)

LogEntries reads the raft logs found in the data directory found at the path `p`, and returns a channel of logs, and a channel of warnings. If opening the raft state returns an error, both channels will be nil.

func RaftStateInfo

func RaftStateInfo(p string) (store *raftboltdb.BoltStore, firstIdx uint64, lastIdx uint64, err error)

RaftStateInfo returns info about the nomad state, as found in the passed data-dir directory

func RestoreFromArchive

func RestoreFromArchive(archive io.Reader, filter *nomad.FSMFilter) (*state.StateStore, *raft.SnapshotMeta, error)

func StateAsMap

func StateAsMap(store *state.StateStore) map[string][]interface{}

StateAsMap returns a json-able representation of the state

Types

type FSMHelper

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

func NewFSM

func NewFSM(p string) (*FSMHelper, error)

func (*FSMHelper) ApplyAll

func (f *FSMHelper) ApplyAll() (index uint64, term uint64, err error)

func (*FSMHelper) ApplyNext

func (f *FSMHelper) ApplyNext() (index uint64, term uint64, err error)

func (*FSMHelper) ApplyUntil

func (f *FSMHelper) ApplyUntil(stopIdx uint64) (idx uint64, term uint64, err error)

ApplyUntil applies all raft entries until (inclusive) the passed index.

func (*FSMHelper) Close

func (f *FSMHelper) Close()

func (*FSMHelper) State

func (f *FSMHelper) State() *state.StateStore

func (*FSMHelper) StateAsMap

func (f *FSMHelper) StateAsMap() map[string][]interface{}