assetscanestimationwatcher

Documentation

Index

• Constants
• type AssetScanEstimationPoller
• type AssetScanEstimationQueue
• type AssetScanEstimationReconcileEvent
  • func (e AssetScanEstimationReconcileEvent) Hash() string
  • func (e AssetScanEstimationReconcileEvent) String() string
  • func (e AssetScanEstimationReconcileEvent) ToFields() log.Fields
• type AssetScanEstimationReconciler
• type Config
  • 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
  • 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)

Constants

const (
	DefaultPollInterval                  = 5 * time.Second
	DefaultReconcileTimeout              = 15 * time.Second
	DefaultAbortTimeout                  = 1 * time.Minute
	DefaultAssetScanEstimationTTLSeconds = 7200 // 2 hours
)

Types

type AssetScanEstimationPoller

type AssetScanEstimationPoller = common.Poller[AssetScanEstimationReconcileEvent]

type AssetScanEstimationQueue

type AssetScanEstimationQueue = common.Queue[AssetScanEstimationReconcileEvent]

type AssetScanEstimationReconcileEvent

type AssetScanEstimationReconcileEvent struct {
	AssetScanEstimationID models.AssetScanEstimationID
	ScanEstimationID      models.ScanEstimationID
	AssetID               models.AssetScanID
}

func (AssetScanEstimationReconcileEvent) Hash

func (e AssetScanEstimationReconcileEvent) Hash() string

func (AssetScanEstimationReconcileEvent) String

func (e AssetScanEstimationReconcileEvent) String() string

func (AssetScanEstimationReconcileEvent) ToFields

func (e AssetScanEstimationReconcileEvent) ToFields() log.Fields

type AssetScanEstimationReconciler

type AssetScanEstimationReconciler = common.Reconciler[AssetScanEstimationReconcileEvent]

type Config

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

func (Config) WithBackendClient

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

func (Config) WithPollPeriod

func (c Config) WithPollPeriod(t time.Duration) Config

func (Config) WithProviderClient

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

func (Config) WithReconcileTimeout

func (c Config) WithReconcileTimeout(t time.Duration) Config

type Watcher

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

func New

func New(c Config) *Watcher

func (*Watcher) GetAssetScanEstimations

func (w *Watcher) GetAssetScanEstimations(ctx context.Context) ([]AssetScanEstimationReconcileEvent, error)

nolint:cyclop

func (*Watcher) Reconcile

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

nolint:cyclop

func (*Watcher) Start

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