influxquery

Documentation

Index

• type WatchInfluxKateway
  • func (this *WatchInfluxKateway) Init(ctx monitor.Context)
  • func (this *WatchInfluxKateway) Run()
• type WatchNgxErr
  • func (this *WatchNgxErr) Init(ctx monitor.Context)
  • func (this *WatchNgxErr) Run()
• type WatchRedis
  • func (this *WatchRedis) Init(ctx monitor.Context)
  • func (this *WatchRedis) Run()

Types

type WatchInfluxKateway

type WatchInfluxKateway struct {
	Zkzone *zk.ZkZone
	Stop   <-chan struct{}
	Tick   time.Duration
	Wg     *sync.WaitGroup
	// contains filtered or unexported fields
}

WatchInfluxKateway continuously query InfluxDB for kateway aggregated metrics.

func (*WatchInfluxKateway) Init

func (this *WatchInfluxKateway) Init(ctx monitor.Context)

func (*WatchInfluxKateway) Run

func (this *WatchInfluxKateway) Run()

type WatchNgxErr

type WatchNgxErr struct {
	Zkzone *zk.ZkZone
	Stop   <-chan struct{}
	Tick   time.Duration
	Wg     *sync.WaitGroup
	// contains filtered or unexported fields
}

func (*WatchNgxErr) Init

func (this *WatchNgxErr) Init(ctx monitor.Context)

func (*WatchNgxErr) Run

func (this *WatchNgxErr) Run()

type WatchRedis

type WatchRedis struct {
	Zkzone *zk.ZkZone
	Stop   <-chan struct{}
	Tick   time.Duration
	Wg     *sync.WaitGroup
	// contains filtered or unexported fields
}

func (*WatchRedis) Init

func (this *WatchRedis) Init(ctx monitor.Context)

func (*WatchRedis) Run

func (this *WatchRedis) Run()