Documentation
¶
Index ¶
- type Coordinator
- func (c *Coordinator) ReconcileAdvisoryRevision(ctx context.Context, result advisory.MaterializationResult) error
- func (c *Coordinator) ReconcileSBOM(ctx context.Context, publication sbom.InventoryPublication) error
- func (c *Coordinator) RecoverAdvisoryWork(ctx context.Context, limit int) (int, error)
- func (c *Coordinator) RecoverInventoryWork(ctx context.Context, tenantID shared.ID, owner string, lease time.Duration, ...) (int, error)
- func (c *Coordinator) SetAdvisoryRunStarter(starter advisoryRunStarter)
- func (c *Coordinator) SetInventoryWorkStore(store ports.InventoryWorkStore)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Coordinator ¶
type Coordinator struct {
// contains filtered or unexported fields
}
func NewCoordinator ¶
func NewCoordinator(tenants ports.VulnerabilityReconciliationTenantStore, engagements ports.EngagementRepository, advisories *vulnerabilitycorrelation.Service, sboms *vulnerabilitycorrelation.SBOMReconciler, checkpoints ports.AdvisoryEvaluationCheckpointStore, clock ports.Clock) (*Coordinator, error)
func (*Coordinator) ReconcileAdvisoryRevision ¶
func (c *Coordinator) ReconcileAdvisoryRevision(ctx context.Context, result advisory.MaterializationResult) error
func (*Coordinator) ReconcileSBOM ¶
func (c *Coordinator) ReconcileSBOM(ctx context.Context, publication sbom.InventoryPublication) error
func (*Coordinator) RecoverAdvisoryWork ¶ added in v0.2.0
RecoverAdvisoryWork dispatches committed-but-unevaluated revisions without fetching providers again. Each tenant is isolated so one poison scope cannot suppress progress for the rest of the fleet.
func (*Coordinator) RecoverInventoryWork ¶ added in v0.2.0
func (c *Coordinator) RecoverInventoryWork(ctx context.Context, tenantID shared.ID, owner string, lease time.Duration, limit int) (int, error)
RecoverInventoryWork leases committed current generations and correlates them independently. A failed row is retried with bounded backoff and eventually poisoned; subsequent rows are always attempted.
func (*Coordinator) SetAdvisoryRunStarter ¶ added in v0.2.0
func (c *Coordinator) SetAdvisoryRunStarter(starter advisoryRunStarter)
func (*Coordinator) SetInventoryWorkStore ¶ added in v0.2.0
func (c *Coordinator) SetInventoryWorkStore(store ports.InventoryWorkStore)
Source Files
Click to show internal directories.
Click to hide internal directories.