cluster

Documentation

Index

• type DNodes
  • func (ns DNodes) Len() int
  • func (ns DNodes) Less(i, j int) bool
  • func (ns DNodes) Swap(i, j int)
• type EtcdBackend
  • func (e *EtcdBackend) AttemptRecovery(m *cluster.Machine)
  • func (e *EtcdBackend) DeploymentComplete(d *deployment.Deployment)
  • func (e *EtcdBackend) DeploymentFailed(d *deployment.Deployment)
  • func (e *EtcdBackend) GetString(key string) string
  • func (e *EtcdBackend) GetValue(key string) map[string]interface{}
  • func (e *EtcdBackend) GetValues(key string) map[string]interface{}
  • func (e *EtcdBackend) IncrementDeploymentCount()
  • func (e *EtcdBackend) Init(clstr *cluster.Cluster, m *cluster.Machine)
  • func (e *EtcdBackend) Watch(key string, callback func(string))
• type EtcdBackendConfig

Types

type DNodes

type DNodes struct {
	client.Nodes
}

func (DNodes) Len

func (ns DNodes) Len() int

func (DNodes) Less

func (ns DNodes) Less(i, j int) bool

func (DNodes) Swap

func (ns DNodes) Swap(i, j int)

type EtcdBackend

type EtcdBackend struct {
	Status chan string
	Signal chan int
	// contains filtered or unexported fields
}

func (*EtcdBackend) AttemptRecovery

func (e *EtcdBackend) AttemptRecovery(m *cluster.Machine)

func (*EtcdBackend) DeploymentComplete

func (e *EtcdBackend) DeploymentComplete(d *deployment.Deployment)

Callback for storing a deployment information to etcd

func (*EtcdBackend) DeploymentFailed

func (e *EtcdBackend) DeploymentFailed(d *deployment.Deployment)

Noop

func (*EtcdBackend) GetString

func (e *EtcdBackend) GetString(key string) string

func (*EtcdBackend) GetValue

func (e *EtcdBackend) GetValue(key string) map[string]interface{}

func (*EtcdBackend) GetValues

func (e *EtcdBackend) GetValues(key string) map[string]interface{}

func (*EtcdBackend) IncrementDeploymentCount

func (e *EtcdBackend) IncrementDeploymentCount()

Increment the count, which is used in recovery situations

func (*EtcdBackend) Init

func (e *EtcdBackend) Init(clstr *cluster.Cluster, m *cluster.Machine)

func (*EtcdBackend) Watch

func (e *EtcdBackend) Watch(key string, callback func(string))

type EtcdBackendConfig

type EtcdBackendConfig struct {
	Endpoints           []string `json:"endpoints"`
	MachinePrefix       string   `json:"machine-prefix"`
	DeploymentPrefix    string   `json:"deployment-prefix"`
	TTL                 int64    `json:"ttl"`
	FailoverTimeout     int64
	FailoverUnit        time.Duration
	Prefix              string `json:"node-prefix"`
	RecoveryParticipant bool   `json:"recovery-participant"`
}