globalclockupdater

type Config struct {
	// NewUpdater returns a new global clock updater.
	NewUpdater func() globalclock.Updater

	// LocalClock is the local wall clock. The times returned must
	// contain a monotonic component (Go 1.9+).
	LocalClock clock.Clock

	// UpdateInterval is the amount of time in between clock updates.
	UpdateInterval time.Duration

	// Logger determines where we write log messages.
	Logger Logger
}

type Logger interface {
	Tracef(string, ...interface{})
	Infof(string, ...interface{})
	Debugf(string, ...interface{})
	Errorf(string, ...interface{})
	Warningf(string, ...interface{})
}

type ManifoldConfig struct {
	Clock     clock.Clock
	RaftName  string
	StateName string

	FSM            raftlease.ReadOnlyClock
	NewWorker      func(Config) (worker.Worker, error)
	NewTarget      func(*state.State, raftleasestore.Logger) raftlease.NotifyTarget
	UpdateInterval time.Duration
	Logger         Logger
}

type RaftApplier interface {
	// Apply applies the input command to Raft's FSM and returns
	// a future that can be used to wait for completion.
	// A non-zero timeout limits the time that we will wait for
	// the operation to be started.
	// Attempting to apply commands to a non-leader node causes
	// an error to be returned.
	Apply(cmd []byte, timeout time.Duration) raft.ApplyFuture

	// State returns the current Raft node state; leader, follower etc.
	State() raft.RaftState
}

type Sleeper interface {
	Sleep(time.Duration)
}

type Timer interface {
	After(time.Duration) <-chan time.Time
}