Documentation ¶
Index ¶
- func ViaPrometheus() cfg.Option[Config]
- func WithPort(port int) cfg.Option[Config]
- type Config
- type Metrics
- type Prometheus
- func (m Prometheus) IncExecutorExecCalls(id string)
- func (m Prometheus) IncExecutorExecErrors(id string)
- func (m Prometheus) IncExecutorNextCalls(id string)
- func (m Prometheus) IncSchedulerNextCalls()
- func (m Prometheus) IncSelectorSelectCalls()
- func (m Prometheus) IncSelectorSelectErrors()
- func (m Prometheus) IsUp(up bool)
- func (m Prometheus) ObserveExecLatency(ctx context.Context, id string, dur time.Duration)
- func (m Prometheus) Registry() (*prometheus.Registry, error)
- func (m Prometheus) Shutdown(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ViaPrometheus ¶
Types ¶
type Metrics ¶
type Metrics interface { IncSchedulerNextCalls() IncSelectorSelectCalls() IncSelectorSelectErrors() IncExecutorExecCalls(id string) IncExecutorExecErrors(id string) ObserveExecLatency(ctx context.Context, id string, dur time.Duration) IncExecutorNextCalls(id string) IsUp(bool) Shutdown(ctx context.Context) error }
type Prometheus ¶
type Prometheus struct {
// contains filtered or unexported fields
}
func (Prometheus) IncExecutorExecCalls ¶
func (m Prometheus) IncExecutorExecCalls(id string)
func (Prometheus) IncExecutorExecErrors ¶
func (m Prometheus) IncExecutorExecErrors(id string)
func (Prometheus) IncExecutorNextCalls ¶
func (m Prometheus) IncExecutorNextCalls(id string)
func (Prometheus) IncSchedulerNextCalls ¶
func (m Prometheus) IncSchedulerNextCalls()
func (Prometheus) IncSelectorSelectCalls ¶
func (m Prometheus) IncSelectorSelectCalls()
func (Prometheus) IncSelectorSelectErrors ¶
func (m Prometheus) IncSelectorSelectErrors()
func (Prometheus) IsUp ¶
func (m Prometheus) IsUp(up bool)
func (Prometheus) ObserveExecLatency ¶
func (Prometheus) Registry ¶
func (m Prometheus) Registry() (*prometheus.Registry, error)
Click to show internal directories.
Click to hide internal directories.