controllers

Documentation

Index

• func GetHashFromRepoDigest(repoDigests []string, imageName string) string
• type ScanJobController
  • func (r *ScanJobController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ScanJobController) SetupWithManager(mgr ctrl.Manager) error
• type ScanJobRequest
• type ScanJobResult
• type WorkloadController
  • func (r *WorkloadController) ProcessScanJob()
  • func (r *WorkloadController) SetupWithManager(mgr ctrl.Manager) error

Functions

func GetHashFromRepoDigest

func GetHashFromRepoDigest(repoDigests []string, imageName string) string

GetHashFromRepoDigest implements same logic as kubeclarity https://github.com/openclarity/kubeclarity/blob/main/shared/pkg/utils/image_helper/image_helper.go#L43

Types

type ScanJobController

type ScanJobController struct {
	client.Client
	trivyoperator.ConfigData
	etc.Config
	kube.LogsReader
	kube.ObjectResolver
	DepService dependencies.Service
}

func (*ScanJobController) Reconcile

func (r *ScanJobController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ScanJobController) SetupWithManager

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 WorkloadController

type WorkloadController struct {
	logr.Logger
	etc.Config
	kube.ObjectResolver
	client.Client
	jobs.LimitChecker
	vulnerabilityreport.Plugin
	trivyoperator.PluginContext
	kube.SecretsReader
	trivyoperator.ConfigData
	ServerHealthChecker vcontroller.ServerHealthChecker
	SubmitScanJobChan   chan ScanJobRequest
	ResultScanJobChan   chan ScanJobResult
	CacheSyncTimeout    time.Duration
	DepService          dependencies.Service
}

WorkloadController watches Kubernetes workloads and fires off scan jobs

func (*WorkloadController) ProcessScanJob

func (r *WorkloadController) ProcessScanJob()

func (*WorkloadController) SetupWithManager

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