controller

type HttpChecker ¶

type HttpChecker interface {
	ServerHealthy(serverURL string) error
}

HttpChecker check health with http server

func NewHttpChecker() HttpChecker

type ScanJobController ¶

type ScanJobController struct {
	logr.Logger
	etc.Config
	kube.ObjectResolver
	kube.LogsReader
	vulnerabilityreport.Plugin
	vuloperator.PluginContext
	vuloperator.ConfigData
	SbomReadWriter          sbomreport.ReadWriter
	VulnerabilityReadWriter vulnerabilityreport.ReadWriter
	ExposedSecretReadWriter exposedsecretreport.ReadWriter
}

ScanJobController watches Kubernetes workloads and generates v1alpha1.VulnerabilityReport instances using vulnerability scanner that that implements the Plugin interface.

func (r *ScanJobController) SetupWithManager(mgr ctrl.Manager) error

type ScanJobRequest ¶

type ScanJobRequest struct {
	Workload client.Object
	Context  context.Context
}

ScanJobRequest encapsulate workload and context for processing

type ScanJobResult ¶

type ScanJobResult struct {
	Result ctrl.Result
	Error  error
}

ScanJobResult encapsulate processing result and error

type ServerHealthChecker ¶

type ServerHealthChecker interface {
	VulServerAvaliable(serverURL string) (bool, error)
}

func NewVulServerChecker(expiration *time.Duration, cache gcache.Cache, httpChecker HttpChecker) ServerHealthChecker

type WorkloadController ¶

type WorkloadController struct {
	logr.Logger
	etc.Config
	kube.ObjectResolver
	client.Client
	jobs.LimitChecker
	vulnerabilityreport.Plugin
	vuloperator.PluginContext
	kube.SecretsReader
	vuloperator.ConfigData
	ServerHealthChecker     ServerHealthChecker
	VulnerabilityReadWriter vulnerabilityreport.ReadWriter
	ExposedSecretReadWriter exposedsecretreport.ReadWriter
	SbomReadWriter          sbomreport.ReadWriter
	SubmitScanJobChan       chan ScanJobRequest
	ResultScanJobChan       chan ScanJobResult
	CacheSyncTimeout        time.Duration
}

WorkloadController watches Kubernetes workloads and generates v1alpha1.VulnerabilityReport instances using vulnerability scanner that that implements the Plugin interface.

func (r *WorkloadController) ProcessScanJob()

func (r *WorkloadController) SetupWithManager(mgr ctrl.Manager) error