Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func HttpHandler ¶
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 ¶
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
Click to show internal directories.
Click to hide internal directories.