cron

Documentation

Overview

Package cron defines the service's cron job.

Index

• Constants
• func Cleanup(ctx context.Context, r *regulator.RegulatorOptions) error
• func Migrate(ctx context.Context, r *regulator.RegulatorOptions, l *LastSeenConfig) error
• func Regulate(ctx context.Context, opts *regulator.RegulatorOptions) error
• type LastSeenConfig
  • func (l *LastSeenConfig) IsExpired() bool
  • func (l *LastSeenConfig) MarkAsSeen(digest []byte)
  • func (l *LastSeenConfig) WasSeen(digest []byte) bool

Constants

const TTL = time.Hour

TTL is the time before a config expires.

Functions

func Cleanup

func Cleanup(ctx context.Context, r *regulator.RegulatorOptions) error

Cleanup flow rolls back excluded DUTs from Cloudbots to Drone. Excluded DUTs are determined by the config migration file.

func Migrate

func Migrate(ctx context.Context, r *regulator.RegulatorOptions, l *LastSeenConfig) error

Migrate flow migrates and rolls back DUTs based on a config migration file.

func Regulate

func Regulate(ctx context.Context, opts *regulator.RegulatorOptions) error

Regulate is BotsRegulator main flow. It fetches available DUTs from UFS based on specific filters and sends out the result to a predefined Bots Provider Interface.

Types

type LastSeenConfig

type LastSeenConfig struct {
	Digest []byte
	Exp    time.Time
}

LastSeenConfig is a simple cache to avoid unnecessary cron runs.

func (*LastSeenConfig) IsExpired

func (l *LastSeenConfig) IsExpired() bool

func (*LastSeenConfig) MarkAsSeen

func (l *LastSeenConfig) MarkAsSeen(digest []byte)

func (*LastSeenConfig) WasSeen

func (l *LastSeenConfig) WasSeen(digest []byte) bool