exporter

Documentation

Index

• func HttpHandler() http.Handler
• type ExecutorCollector
  • func (c *ExecutorCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *ExecutorCollector) Describe(ch chan<- *prometheus.Desc)
  • func (c *ExecutorCollector) Handle(cxt context.Context, e goevent.Event)
  • func (c *ExecutorCollector) Topic() []string
• type LeaderCollector
  • func (c *LeaderCollector) Collect(ch chan<- prometheus.Metric)
  • func (c *LeaderCollector) Describe(ch chan<- *prometheus.Desc)
  • func (c *LeaderCollector) Handle(cxt context.Context, e goevent.Event)
  • func (c *LeaderCollector) Topic() []string

Functions

func HttpHandler

func HttpHandler() http.Handler

HttpHandler used to handle metrics request you can use it like that

http.Handle("/metrics", exporter.HttpHandler)

because it depend on Keeper, so you should call this function after keeper start

Types

type ExecutorCollector

type ExecutorCollector struct {
	RunningTaskCount   int64
	SuccessTaskCount   uint64
	FailedTaskCount    uint64
	CompletedTaskCount uint64

	ParseElapsedMs   int64
	ParseFailedCount int64
}

ExecutorCollector

func (*ExecutorCollector) Collect

func (c *ExecutorCollector) Collect(ch chan<- prometheus.Metric)

Collect

func (*ExecutorCollector) Describe

func (c *ExecutorCollector) Describe(ch chan<- *prometheus.Desc)

Describe

func (*ExecutorCollector) Handle

func (c *ExecutorCollector) Handle(cxt context.Context, e goevent.Event)

Handle is goevent's handler

func (*ExecutorCollector) Topic

func (c *ExecutorCollector) Topic() []string

Topic is goevent's topic

type LeaderCollector

type LeaderCollector struct {
	DispatchElapsedMs   int64
	DispatchFailedCount int64
}

ExecutorCollector

func (*LeaderCollector) Collect

func (c *LeaderCollector) Collect(ch chan<- prometheus.Metric)

Collect

func (*LeaderCollector) Describe

func (c *LeaderCollector) Describe(ch chan<- *prometheus.Desc)

Describe

func (*LeaderCollector) Handle

func (c *LeaderCollector) Handle(cxt context.Context, e goevent.Event)

Handle is goevent's handler

func (*LeaderCollector) Topic

func (c *LeaderCollector) Topic() []string

Topic is goevent's topic