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() <-chan uuid.UUID
- 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(forceAll bool)
- func (runner *DaemonRunner) RunDaemonPipelineForAsset(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()
- 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
- 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, ) *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() <-chan uuid.UUID
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(forceAll bool)
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) SetDebugOptions ¶
func (runner *DaemonRunner) SetDebugOptions(options DebugOptions)
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
type DebugOptions ¶
type DebugOptions struct {
LimitToAssetVersionSlug string
}
Source Files
Click to show internal directories.
Click to hide internal directories.