replicator

Documentation

Index

• Constants
• func FailsafeCheck(state *structs.ScalingState, config *structs.Config, threshold int, ...) (passing bool)
• func SetFailsafeMode(state *structs.ScalingState, config *structs.Config, enabled bool, ...) (err error)
• type LeaderCandidate
• type Runner
  • func NewRunner(config *structs.Config) (*Runner, error)
  • func (r *Runner) Start()
  • func (r *Runner) Stop()

Constants

const (
	ClusterType = "worker_pool"
	JobType     = "job_group"
)

Provides failsafe notification types.

Functions

func FailsafeCheck

func FailsafeCheck(state *structs.ScalingState, config *structs.Config,
	threshold int, message *notifier.FailureMessage) (passing bool)

FailsafeCheck implements the failsafe mode circuit breaker that will trip automatically if enough critical failures are detected. Once tripped, the circuit breaker must be reset by a human operator.

func SetFailsafeMode

func SetFailsafeMode(state *structs.ScalingState, config *structs.Config,
	enabled bool, message *notifier.FailureMessage) (err error)

SetFailsafeMode is used to toggle the distributed failsafe mode lock.

Types

type LeaderCandidate

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

LeaderCandidate runs the leader election.

type Runner

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

Runner is the main runner struct.

func NewRunner

func NewRunner(config *structs.Config) (*Runner, error)

NewRunner sets up the Runner type.

func (*Runner) Start

func (r *Runner) Start()

Start is the main entry point into Replicator and launches processes based on the configuration.

func (*Runner) Stop

func (r *Runner) Stop()

Stop halts the execution of this runner.