assetscanprocessor

Documentation

Index

• Constants
• type AssetScanProcessor
  • func New(config Config) *AssetScanProcessor
  • func (asp *AssetScanProcessor) GetItems(ctx context.Context) ([]AssetScanReconcileEvent, error)
  • func (asp *AssetScanProcessor) Reconcile(ctx context.Context, event AssetScanReconcileEvent) error
  • func (asp *AssetScanProcessor) Start(ctx context.Context)
• type AssetScanReconcileEvent
  • func (e AssetScanReconcileEvent) Hash() string
  • func (e AssetScanReconcileEvent) String() string
  • func (e AssetScanReconcileEvent) ToFields() logrus.Fields
• type Config
  • func (c Config) WithBackendClient(b *backendclient.BackendClient) Config
  • func (c Config) WithPollPeriod(t time.Duration) Config
  • func (c Config) WithReconcileTimeout(t time.Duration) Config

Constants

const (
	DefaultPollInterval     = 2 * time.Minute
	DefaultReconcileTimeout = 5 * time.Minute
)

Types

type AssetScanProcessor

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

func New

func New(config Config) *AssetScanProcessor

func (*AssetScanProcessor) GetItems

func (asp *AssetScanProcessor) GetItems(ctx context.Context) ([]AssetScanReconcileEvent, error)

func (*AssetScanProcessor) Reconcile

func (asp *AssetScanProcessor) Reconcile(ctx context.Context, event AssetScanReconcileEvent) error

nolint:cyclop

func (*AssetScanProcessor) Start

func (asp *AssetScanProcessor) Start(ctx context.Context)

type AssetScanReconcileEvent

type AssetScanReconcileEvent struct {
	AssetScanID models.AssetScanID
}

func (AssetScanReconcileEvent) Hash

func (e AssetScanReconcileEvent) Hash() string

func (AssetScanReconcileEvent) String

func (e AssetScanReconcileEvent) String() string

func (AssetScanReconcileEvent) ToFields

func (e AssetScanReconcileEvent) ToFields() logrus.Fields

type Config

type Config struct {
	Backend          *backendclient.BackendClient
	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) WithReconcileTimeout

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