Documentation
¶
Index ¶
Constants ¶
View Source
const ( Endpoint = "/metrics" EchoShutdownTimeout = 5 * time.Second )
Variables ¶
View Source
var ( ErrServerNotSpecified = fmt.Errorf("web server is not specified") ErrServerAlreadyStarted = fmt.Errorf("server already started") )
View Source
var (
ErrServerIsNotSet = fmt.Errorf("traking object is not set")
)
View Source
var Module = fx.Provide( NewLogger, New, NewSchedulerMetrics, )
Functions ¶
func LoggerValid ¶
Types ¶
type MetricTracker ¶
type MetricTracker interface {
SetUp() error
}
func NewGRPCTracker ¶
func NewGRPCTracker(server *grpc.Server) MetricTracker
type Monitor ¶
type Monitor interface {
TrackMetrics(metrics ...MetricTracker) Monitor
StartDetached(logger *zap.Logger)
Start() error
GracefulStop() error
Error() error
}
func New ¶
func New(conf config.MonitoringConfig) Monitor
type SchedulerMetrics ¶
type SchedulerMetrics interface {
AddScheduled(taskType string) SchedulerMetrics
AddExecuted(taskType string) SchedulerMetrics
UpdateExecutionTime(taskType string, duration time.Duration) SchedulerMetrics
AddTaskSuccess(taskType string) SchedulerMetrics
AddTaskFailed(taskType string) SchedulerMetrics
}
func NewSchedulerMetrics ¶
func NewSchedulerMetrics() SchedulerMetrics
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package monitoring_mocks is a generated GoMock package.
|
Package monitoring_mocks is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.