Help us shape the future of Go! Take the 2026 Go Developer Survey

replicator

package
v1.0.1 Latest Latest
Warning

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

Go to latest
Published: Sep 15, 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