cluster

Documentation

Index

• type Cluster
  • func NewCluster(etcdClient *clientv3.Client, conf conf.ClusterConf, log *logrus.Entry, ...) Cluster
• type ClusterManager
  • func (s *ClusterManager) GetInstanceHost() string
  • func (s *ClusterManager) GetInstanceID() string
  • func (s *ClusterManager) GetSuitableInstance(serviceID string) *discover.Instance
  • func (s *ClusterManager) MessageRadio(mes ...db.ClusterMessage)
  • func (s *ClusterManager) Scrape(ch chan<- prometheus.Metric, namespace, exporter string) error
  • func (s *ClusterManager) Start() error
  • func (s *ClusterManager) Stop()

Types

type Cluster

type Cluster interface {
	//Get a node that accepts logs
	GetSuitableInstance(serviceID string) *discover.Instance
	//Cluster message broadcast
	MessageRadio(...db.ClusterMessage)
	Start() error
	Stop()
	GetInstanceID() string
	GetInstanceHost() string
	Scrape(ch chan<- prometheus.Metric, namespace, exporter string) error
}

Cluster

func NewCluster

func NewCluster(etcdClient *clientv3.Client, conf conf.ClusterConf, log *logrus.Entry, storeManager store.Manager) Cluster

NewCluster

type ClusterManager

type ClusterManager struct {
	Conf conf.ClusterConf
	// contains filtered or unexported fields
}

ClusterManager

func (*ClusterManager) GetInstanceHost

func (s *ClusterManager) GetInstanceHost() string

func (*ClusterManager) GetInstanceID

func (s *ClusterManager) GetInstanceID() string

func (*ClusterManager) GetSuitableInstance

func (s *ClusterManager) GetSuitableInstance(serviceID string) *discover.Instance

GetSuitableInstance

func (*ClusterManager) MessageRadio

func (s *ClusterManager) MessageRadio(mes ...db.ClusterMessage)

MessageRadio

func (*ClusterManager) Scrape

func (s *ClusterManager) Scrape(ch chan<- prometheus.Metric, namespace, exporter string) error

Scrape prometheus monitor metrics

func (*ClusterManager) Start

func (s *ClusterManager) Start() error

Start

func (*ClusterManager) Stop

func (s *ClusterManager) Stop()

Stop