manager

Documentation

Index

• type MetricManager
  • func NewMetricManager(roleEvent chan bcsMetric.RoleType, config *config.Config, ...) *MetricManager
  • func (cli *MetricManager) Run()
• type Pipeline
  • func NewPipeLine(ctx context.Context) *Pipeline
  • func (pl *Pipeline) Do(id string, f func())
  • func (pl *Pipeline) Start()
  • func (pl *Pipeline) Stop()

Types

type MetricManager

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

func NewMetricManager

func NewMetricManager(roleEvent chan bcsMetric.RoleType, config *config.Config, storage storage.Storage, route route.Route, zk zk.Zk) *MetricManager

func (*MetricManager) Run

func (cli *MetricManager) Run()

type Pipeline

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

func NewPipeLine

func NewPipeLine(ctx context.Context) *Pipeline

func (*Pipeline) Do

func (pl *Pipeline) Do(id string, f func())

func (*Pipeline) Start

func (pl *Pipeline) Start()

func (*Pipeline) Stop

func (pl *Pipeline) Stop()