scanestimationwatcher

Documentation

Index

• Constants
• type Config
  • func (c Config) WithBackendClient(b *backendclient.BackendClient) Config
  • func (c Config) WithProviderClient(p provider.Provider) Config
• type ScanEstimationPoller
• type ScanEstimationQueue
• type ScanEstimationReconcileEvent
  • func (e ScanEstimationReconcileEvent) Hash() string
  • func (e ScanEstimationReconcileEvent) String() string
  • func (e ScanEstimationReconcileEvent) ToFields() log.Fields
• type ScanEstimationReconciler
• type Watcher
  • func New(c Config) *Watcher
  • func (w *Watcher) GetScanEstimations(ctx context.Context) ([]ScanEstimationReconcileEvent, error)
  • func (w *Watcher) Reconcile(ctx context.Context, event ScanEstimationReconcileEvent) error
  • func (w *Watcher) Start(ctx context.Context)

Constants

const (
	DefaultPollInterval             = 5 * time.Second
	DefaultReconcileTimeout         = 2 * time.Minute
	DefaultScanEstimationTimeout    = 48 * time.Hour
	DefaultScanEstimationTTLSeconds = 7200 // // 2 hours
)

Types

type Config

type Config struct {
	Backend               *backendclient.BackendClient
	Provider              provider.Provider
	PollPeriod            time.Duration `mapstructure:"poll_period"`
	ReconcileTimeout      time.Duration `mapstructure:"reconcile_timeout"`
	ScanEstimationTimeout time.Duration `mapstructure:"estimation_timeout"`
}

func (Config) WithBackendClient

func (c Config) WithBackendClient(b *backendclient.BackendClient) Config

func (Config) WithProviderClient

func (c Config) WithProviderClient(p provider.Provider) Config

type ScanEstimationPoller

type ScanEstimationPoller = common.Poller[ScanEstimationReconcileEvent]

type ScanEstimationQueue

type ScanEstimationQueue = common.Queue[ScanEstimationReconcileEvent]

type ScanEstimationReconcileEvent

type ScanEstimationReconcileEvent struct {
	ScanEstimationID models.ScanEstimationID
}

func (ScanEstimationReconcileEvent) Hash

func (e ScanEstimationReconcileEvent) Hash() string

func (ScanEstimationReconcileEvent) String

func (e ScanEstimationReconcileEvent) String() string

func (ScanEstimationReconcileEvent) ToFields

func (e ScanEstimationReconcileEvent) ToFields() log.Fields

type ScanEstimationReconciler

type ScanEstimationReconciler = common.Reconciler[ScanEstimationReconcileEvent]

type Watcher

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

func New

func New(c Config) *Watcher

func (*Watcher) GetScanEstimations

func (w *Watcher) GetScanEstimations(ctx context.Context) ([]ScanEstimationReconcileEvent, error)

func (*Watcher) Reconcile

func (w *Watcher) Reconcile(ctx context.Context, event ScanEstimationReconcileEvent) error

nolint:cyclop

func (*Watcher) Start

func (w *Watcher) Start(ctx context.Context)