poller

Documentation

Index

• type Cluster
• type ClusterStatusPoller
  • func NewClustersStatusPoller(globalConfig *mode.GlobalConfig) (ClusterStatusPoller, error)
• type Clusters
• type ClustersStatusPoller
  • func (p *ClustersStatusPoller) Clusters() Clusters
  • func (p *ClustersStatusPoller) NeedLeaderElection() bool
  • func (p *ClustersStatusPoller) Start(stop <-chan struct{}) error

Types

type Cluster

type Cluster struct {
	Name   string `json:"name"`
	URL    string `json:"url"`
	Active bool   `json:"active"`
}

type ClusterStatusPoller

type ClusterStatusPoller interface {
	Start(<-chan struct{}) error
	NeedLeaderElection() bool
	Clusters() Clusters
}

func NewClustersStatusPoller

func NewClustersStatusPoller(globalConfig *mode.GlobalConfig) (ClusterStatusPoller, error)

type Clusters

type Clusters []Cluster

type ClustersStatusPoller

type ClustersStatusPoller struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*ClustersStatusPoller) Clusters

func (p *ClustersStatusPoller) Clusters() Clusters

func (*ClustersStatusPoller) NeedLeaderElection

func (p *ClustersStatusPoller) NeedLeaderElection() bool

func (*ClustersStatusPoller) Start

func (p *ClustersStatusPoller) Start(stop <-chan struct{}) error