Documentation ¶
Index ¶
- type MetricsSubsystem
- func (m *MetricsSubsystem) Name() string
- func (m *MetricsSubsystem) PrefixMetricName(metricName string) string
- func (m *MetricsSubsystem) Reload(s *server.Server) error
- func (m *MetricsSubsystem) Shutdown(s *server.Server) error
- func (m *MetricsSubsystem) Start(s *server.Server) error
- func (m *MetricsSubsystem) StatsDClient() statsd.ClientInterface
- type Options
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetricsSubsystem ¶
type MetricsSubsystem struct { Server *server.Server Options *Options // contains filtered or unexported fields }
Metrics Subsystem uses dogstatsd to submit metrics for queues middleware is used to send metrics for suceeded/failed job count and time to complete a task is used to track the count of each queue and how long the next job has been waiting
func (*MetricsSubsystem) Name ¶
func (m *MetricsSubsystem) Name() string
Name - returns the name of the subsystem or plugin
func (*MetricsSubsystem) PrefixMetricName ¶
func (m *MetricsSubsystem) PrefixMetricName(metricName string) string
PrefixMetricName - adds configured namespace to the metric
func (*MetricsSubsystem) Reload ¶
func (m *MetricsSubsystem) Reload(s *server.Server) error
Reload - the config is reloaded by faktory hot reload is currently unsupported
func (*MetricsSubsystem) Shutdown ¶
func (m *MetricsSubsystem) Shutdown(s *server.Server) error
Shutdown - nothing needs to be done but the function must exist for subsystems
func (*MetricsSubsystem) Start ¶
func (m *MetricsSubsystem) Start(s *server.Server) error
Start starts the subsystem get options from global config "metrics"
func (*MetricsSubsystem) StatsDClient ¶
func (m *MetricsSubsystem) StatsDClient() statsd.ClientInterface
StatsDClient returns the statsd client
Click to show internal directories.
Click to hide internal directories.