controller

Documentation

Index

• type EtcdController
  • func NewEtcdController(leaderLock locking.Lock, backupStore backup.Store, ...) (*EtcdController, error)
  • func (m *EtcdController) InvalidateControlStore() error
  • func (m *EtcdController) Run(ctx context.Context)
• type EtcdMemberId

Types

type EtcdController

type EtcdController struct {

	// CycleInterval is the time to wait in between iterations of the state synchronization loop, when no progress has been made previously
	CycleInterval time.Duration
	// contains filtered or unexported fields
}

EtcdController is the controller that runs the etcd cluster - adding & removing members, backups/restores etcd

func NewEtcdController

func NewEtcdController(leaderLock locking.Lock, backupStore backup.Store, backupInterval time.Duration, controlStore commands.Store, controlRefreshInterval time.Duration, clusterName string, dnsSuffix string, peers privateapi.Peers, etcdClientsCA *pki.CA, disableEtcdTLS bool) (*EtcdController, error)

NewEtcdController is the constructor for an EtcdController

func (*EtcdController) InvalidateControlStore

func (m *EtcdController) InvalidateControlStore() error

func (*EtcdController) Run

func (m *EtcdController) Run(ctx context.Context)

Run starts an EtcdController. It runs indefinitely - until ctx is no longer valid.

type EtcdMemberId

type EtcdMemberId string