state

package

v0.0.0-...-4cfcb05 Latest Latest Go to latest Published: Aug 30, 2016 License: MIT Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package state stores and retrieves the peer information for coordination. Different backend stores should be supported. Currently only Consul is.

This section is empty.

This section is empty.

This section is empty.

type Bootstrap struct {
	First time.Time
}

Bootstrap stores information about when the cluster was first bootstrap'd

type Config struct {
	Me     Peer
	Prefix string // the prefix for the remote state
}

Config is the high level settings for running capman

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

ConsulConfig is how to connect to the consul agent

type ExternalState interface {
	IsBootstrap() (*Bootstrap, error)
	SetBootstrap() (*Bootstrap, error)
	Heartbeat() error
	Peers() (Peers, error)
}

ExternalState is the interface for dealing with the external state store.

func NewConsul(config Config, consulConfig ConsulConfig) ExternalState

NewConsul creates a new consul impl of ExternalState

type Peer struct {
	Host     string
	IP       string
	LastSeen time.Time
}

Peer represents the state of a peer

func (p Peer) IsHealthy(duration time.Duration) bool

IsHealthy determines if this peer is in a healthy state.

type Peers []Peer

Peers is a slice of peers

func (ps Peers) Healthy(duration time.Duration) Peers

Healthy returns the list of Healthy Peers