agent

Documentation

Index

• func DBNotificationThread(ctx context.Context, w Worker)
• func NewGoCronLogger() gocron.Logger
• func NewScheduler() gocron.Scheduler
• func PrometheusListenerThread()
• func RegisterAgent(pool db.PgxIface, provider string)
• type PrometheusMonitor
  • func NewPrometheusMonitor() *PrometheusMonitor
  • func (p PrometheusMonitor) IncrementJob(_ uuid.UUID, name string, tags []string, status gocron.JobStatus)
  • func (p PrometheusMonitor) RecordJobTiming(startTime, endTime time.Time, _ uuid.UUID, name string, tags []string)
• type Worker

Functions

func DBNotificationThread

func DBNotificationThread(ctx context.Context, w Worker)

func NewGoCronLogger

func NewGoCronLogger() gocron.Logger

func NewScheduler

func NewScheduler() gocron.Scheduler

func PrometheusListenerThread

func PrometheusListenerThread()

func RegisterAgent

func RegisterAgent(pool db.PgxIface, provider string)

Types

type PrometheusMonitor

type PrometheusMonitor struct {
	// contains filtered or unexported fields
}

func NewPrometheusMonitor

func NewPrometheusMonitor() *PrometheusMonitor

func (PrometheusMonitor) IncrementJob

func (p PrometheusMonitor) IncrementJob(_ uuid.UUID, name string, tags []string, status gocron.JobStatus)

func (PrometheusMonitor) RecordJobTiming

func (p PrometheusMonitor) RecordJobTiming(startTime, endTime time.Time, _ uuid.UUID, name string, tags []string)

type Worker

type Worker interface {
	ProcessServices(context.Context) error
	ProcessEndpoint(context.Context, strfmt.UUID) error
	GetPool() db.PgxIface
	GetScheduler() gocron.Scheduler
}