agent

package

v1.3.1 Latest Latest Go to latest Published: Apr 10, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/sapcc/archer

Links

Open Source Insights

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 DebugMonitor
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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DBNotificationThread ¶

func DBNotificationThread(ctx context.Context, w Worker)

func NewGoCronLogger ¶ added in v1.3.0

func NewGoCronLogger() gocron.Logger

func NewScheduler ¶ added in v1.3.0

func NewScheduler() gocron.Scheduler

func PrometheusListenerThread ¶

func PrometheusListenerThread()

func RegisterAgent ¶

func RegisterAgent(pool db.PgxIface, provider string)

Types ¶

type DebugMonitor ¶ added in v1.3.1

type DebugMonitor struct{}

func (*DebugMonitor) IncrementJob ¶ added in v1.3.1

func (d *DebugMonitor) IncrementJob(id uuid.UUID, name string, tags []string, status gocron.JobStatus)

func (*DebugMonitor) RecordJobTiming ¶ added in v1.3.1

func (d *DebugMonitor) RecordJobTiming(startTime, endTime time.Time, id uuid.UUID, name string, tags []string)

func (*DebugMonitor) RecordJobTimingWithStatus ¶ added in v1.3.1

func (d *DebugMonitor) RecordJobTimingWithStatus(startTime, endTime time.Time, id uuid.UUID, name string, tags []string, status gocron.JobStatus, err error)

type PrometheusMonitor ¶ added in v1.3.0

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

func NewPrometheusMonitor ¶ added in v1.3.0

func NewPrometheusMonitor() *PrometheusMonitor

func (PrometheusMonitor) IncrementJob ¶ added in v1.3.0

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

func (PrometheusMonitor) RecordJobTiming ¶ added in v1.3.0

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
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
f5
as3
ni

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL