Documentation
¶
Index ¶
- Variables
- type DaemonRunner
- func (runner *DaemonRunner) AutoReopenTickets(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
- func (runner *DaemonRunner) CollectStats(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
- func (runner *DaemonRunner) DebugMode() bool
- func (runner *DaemonRunner) DeleteOldAssetVersions(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
- func (runner *DaemonRunner) FetchAllAssetIDs(ctx context.Context) <-chan uuid.UUID
- func (runner *DaemonRunner) FetchAssetDetails(pipelineCtx context.Context, input <-chan uuid.UUID, ...) <-chan assetWithProjectAndOrg
- func (runner *DaemonRunner) FetchAssetIDs(ctx context.Context) <-chan uuid.UUID
- func (runner *DaemonRunner) RecalculateRiskForVulnerabilities(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
- func (runner *DaemonRunner) ResolveDifferencesInTicketState(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
- func (runner *DaemonRunner) RunAssetPipeline(ctx context.Context, forceAll bool)
- func (runner *DaemonRunner) RunDaemonPipelineForAsset(ctx context.Context, assetID uuid.UUID) error
- func (runner *DaemonRunner) ScanAsset(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
- func (runner *DaemonRunner) SetDebugOptions(options DebugOptions)
- func (runner *DaemonRunner) Start(ctx context.Context)
- func (runner *DaemonRunner) SyncTickets(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
- func (runner *DaemonRunner) SyncUpstream(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
- func (runner *DaemonRunner) UpdateFixedVersions(ctx context.Context) error
- func (runner *DaemonRunner) UpdateOpenSourceInsightInformation(ctx context.Context) error
- func (runner *DaemonRunner) UpdateVulnDB(ctx context.Context) error
- type DebugOptions
Constants ¶
This section is empty.
Variables ¶
View Source
var Module = fx.Module("daemons", fx.Provide(fx.Annotate(NewDaemonRunner, fx.As(new(shared.DaemonRunner)))), )
Functions ¶
This section is empty.
Types ¶
type DaemonRunner ¶
type DaemonRunner struct {
// contains filtered or unexported fields
}
DaemonRunner encapsulates daemon dependencies and lifecycle
func NewDaemonRunner ¶
func NewDaemonRunner( db shared.DB, broker shared.PubSubBroker, configService shared.ConfigService, rbacProvider shared.RBACProvider, integrationAggregate shared.IntegrationAggregate, assetVersionService shared.AssetVersionService, assetVersionRepository shared.AssetVersionRepository, assetRepository shared.AssetRepository, projectRepository shared.ProjectRepository, orgRepository shared.OrganizationRepository, artifactService shared.ArtifactService, componentRepository shared.ComponentRepository, componentService shared.ComponentService, dependencyVulnService shared.DependencyVulnService, dependencyVulnRepository shared.DependencyVulnRepository, componentProjectRepository shared.ComponentProjectRepository, vulnEventRepository shared.VulnEventRepository, statisticsService shared.StatisticsService, artifactRepository shared.ArtifactRepository, cveRepository shared.CveRepository, cweRepository shared.CweRepository, exploitsRepository shared.ExploitRepository, affectedComponentsRepository shared.AffectedComponentRepository, scanService shared.ScanService, leaderElector shared.LeaderElector, maliciousPackageChecker shared.MaliciousPackageChecker, vulnDBImportService shared.VulnDBImportService, vexRuleService shared.VEXRuleService, ) *DaemonRunner
NewDaemonRunner creates a new daemon runner with injected dependencies
func (*DaemonRunner) AutoReopenTickets ¶
func (runner *DaemonRunner) AutoReopenTickets(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
func (*DaemonRunner) CollectStats ¶
func (runner *DaemonRunner) CollectStats(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
func (*DaemonRunner) DebugMode ¶
func (runner *DaemonRunner) DebugMode() bool
func (*DaemonRunner) DeleteOldAssetVersions ¶
func (runner *DaemonRunner) DeleteOldAssetVersions(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
func (*DaemonRunner) FetchAllAssetIDs ¶
func (runner *DaemonRunner) FetchAllAssetIDs(ctx context.Context) <-chan uuid.UUID
func (*DaemonRunner) FetchAssetDetails ¶
func (runner *DaemonRunner) FetchAssetDetails(pipelineCtx context.Context, input <-chan uuid.UUID, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
fetches the asset details for each element in the input channel This approach is intended to avoid overloading the database with large queries or too many concurrent requests.
func (*DaemonRunner) FetchAssetIDs ¶
func (runner *DaemonRunner) FetchAssetIDs(ctx context.Context) <-chan uuid.UUID
func (*DaemonRunner) RecalculateRiskForVulnerabilities ¶
func (runner *DaemonRunner) RecalculateRiskForVulnerabilities(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
func (*DaemonRunner) ResolveDifferencesInTicketState ¶
func (runner *DaemonRunner) ResolveDifferencesInTicketState(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
func (*DaemonRunner) RunAssetPipeline ¶
func (runner *DaemonRunner) RunAssetPipeline(ctx context.Context, forceAll bool)
this creates a channel which will be used to pipeline asset processing in daemons
func (*DaemonRunner) RunDaemonPipelineForAsset ¶
func (*DaemonRunner) ScanAsset ¶
func (runner *DaemonRunner) ScanAsset(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
func (*DaemonRunner) SetDebugOptions ¶
func (runner *DaemonRunner) SetDebugOptions(options DebugOptions)
func (*DaemonRunner) Start ¶
func (runner *DaemonRunner) Start(ctx context.Context)
Start initiates all background daemons
func (*DaemonRunner) SyncTickets ¶
func (runner *DaemonRunner) SyncTickets(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
func (*DaemonRunner) SyncUpstream ¶
func (runner *DaemonRunner) SyncUpstream(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
func (*DaemonRunner) UpdateFixedVersions ¶
func (runner *DaemonRunner) UpdateFixedVersions(ctx context.Context) error
func (*DaemonRunner) UpdateOpenSourceInsightInformation ¶
func (runner *DaemonRunner) UpdateOpenSourceInsightInformation(ctx context.Context) error
func (*DaemonRunner) UpdateVulnDB ¶
func (runner *DaemonRunner) UpdateVulnDB(ctx context.Context) error
type DebugOptions ¶
type DebugOptions struct {
LimitToAssetVersionSlug string
}
Source Files
Click to show internal directories.
Click to hide internal directories.