Versions in this module Expand all Collapse all v0 v0.2.2 Jan 15, 2025 Changes in this version + var ErrResultNotFound = errors.New("result not found") + func MustGetZbusClient(ctx context.Context) zbus.Client + func TryGetZbusClient(ctx context.Context) (zbus.Client, error) + func WithZbusClient(ctx context.Context, client zbus.Client) context.Context + type PerformanceMonitor struct + func NewPerformanceMonitor(redisAddr string) (*PerformanceMonitor, error) + func (pm *PerformanceMonitor) AddTask(task Task) + func (pm *PerformanceMonitor) Get(taskName string) (pkg.TaskResult, error) + func (pm *PerformanceMonitor) GetAll() ([]pkg.TaskResult, error) + func (pm *PerformanceMonitor) Run(ctx context.Context) error + type Task interface + Cron func() string + Description func() string + ID func() string + Jitter func() uint32 + Run func(ctx context.Context) (interface{}, error)
Go to main page