Versions in this module Expand all Collapse all v0 v0.6.0 Nov 8, 2023 Changes in this version + const DefaultAbortTimeout + const DefaultAssetScanEstimationTTLSeconds + const DefaultPollInterval + const DefaultReconcileTimeout + type AssetScanEstimationPoller = common.Poller[AssetScanEstimationReconcileEvent] + type AssetScanEstimationQueue = common.Queue[AssetScanEstimationReconcileEvent] + type AssetScanEstimationReconcileEvent struct + AssetID models.AssetScanID + AssetScanEstimationID models.AssetScanEstimationID + ScanEstimationID models.ScanEstimationID + func (e AssetScanEstimationReconcileEvent) Hash() string + func (e AssetScanEstimationReconcileEvent) String() string + func (e AssetScanEstimationReconcileEvent) ToFields() log.Fields + type AssetScanEstimationReconciler = common.Reconciler[AssetScanEstimationReconcileEvent] + type Config struct + Backend *backendclient.BackendClient + PollPeriod time.Duration + Provider provider.Provider + ReconcileTimeout time.Duration + func (c Config) WithBackendClient(b *backendclient.BackendClient) Config + func (c Config) WithPollPeriod(t time.Duration) Config + func (c Config) WithProviderClient(p provider.Provider) Config + func (c Config) WithReconcileTimeout(t time.Duration) Config + type Watcher struct + func New(c Config) *Watcher + func (w *Watcher) GetAssetScanEstimations(ctx context.Context) ([]AssetScanEstimationReconcileEvent, error) + func (w *Watcher) Reconcile(ctx context.Context, event AssetScanEstimationReconcileEvent) error + func (w *Watcher) Start(ctx context.Context)
Go to main page