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) DeleteOldAssetVersions() error
- func (runner DaemonRunner) FetchAssetDetails(input <-chan uuid.UUID, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
- func (runner DaemonRunner) FetchAssetIDs() <-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()
- func (runner DaemonRunner) RunDaemonPipelineForAsset(assetID uuid.UUID) error
- func (runner DaemonRunner) ScanAsset(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
- func (runner DaemonRunner) Start()
- 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() error
- func (runner DaemonRunner) UpdateOpenSourceInsightInformation() error
- func (runner DaemonRunner) UpdateVulnDB() error
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 database.Broker, 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, ) 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) DeleteOldAssetVersions ¶
func (runner DaemonRunner) DeleteOldAssetVersions() error
func (DaemonRunner) FetchAssetDetails ¶
func (runner DaemonRunner) FetchAssetDetails(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() <-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()
this creates a channel which will be used to pipeline asset processing in daemons
func (DaemonRunner) RunDaemonPipelineForAsset ¶
func (runner DaemonRunner) RunDaemonPipelineForAsset(assetID uuid.UUID) error
func (DaemonRunner) ScanAsset ¶
func (runner DaemonRunner) ScanAsset(input <-chan assetWithProjectAndOrg, errChan chan<- pipelineError) <-chan assetWithProjectAndOrg
func (DaemonRunner) Start ¶
func (runner DaemonRunner) Start()
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() error
func (DaemonRunner) UpdateOpenSourceInsightInformation ¶
func (runner DaemonRunner) UpdateOpenSourceInsightInformation() error
func (DaemonRunner) UpdateVulnDB ¶
func (runner DaemonRunner) UpdateVulnDB() error
Source Files
Click to show internal directories.
Click to hide internal directories.