replicator

package
v1.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 22, 2017 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

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

Provides failsafe notification types.

Variables

This section is empty.

Functions

func FailsafeCheck added in v0.0.2

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 added in v0.0.2

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 added in v0.0.2

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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL