utils

Jan 7, 2025

Changes in this version

+ func WithError(err error) func(*patchStatus)

+ func WithMultipleErrors(errors []error) func(*patchStatus)

+ func WithPayload(payload []byte) func(*patchStatus)

+ func WithSuccess() func(*patchStatus)

+ type OperatorCommandDetails struct

+ Client *k8sinterface.KubernetesApi

+ Command *v1alpha1.OperatorCommand

+ StartedAt time.Time

type SessionObj

+ CustomerGUID string

+ JobID string

+ ParentCommandDetails *OperatorCommandDetails

+ ParentJobID string

+ Timestamp time.Time

+ func (s *SessionObj) SetOperatorCommandDetails(opcmd *OperatorCommandDetails)

+ func (s *SessionObj) SetOperatorCommandStatus(ctx context.Context, options ...func(*patchStatus))

Dec 24, 2024

Changes in this version

+ func GetApplicationProfileForRelevancyScan(ctx context.Context, storageClient kssc.Interface, slug, namespace string) *v1beta1.ApplicationProfile

+ func GetApplicationProfileScanCommand(appProfile *v1beta1.ApplicationProfile) *apis.Command

+ func SkipApplicationProfile(annotations map[string]string) (bool, error)

Dec 16, 2024

Changes in this version

+ const ArgsName

+ const ArgsNamespace

+ const CommandScanApplicationProfile

type ContainerData

+ InstanceID string

Feb 6, 2024

Changes in this version

+ const ArgdContainerToImageIds

+ const ArgsContainerData

+ const ArgsPod

+ const CommandScanFilteredSBOM

+ type ContainerData struct

+ ContainerName string

+ ContainerType string

+ ImageID string

+ ImageTag string

+ Slug string

+ Wlid string

+ func PodToContainerData(k8sAPI *k8sinterface.KubernetesApi, pod *core1.Pod, ...) (*ContainerData, error)

Dec 30, 2023

Changes in this version

+ func GetRequestHeaders(accessKey string) map[string]string

+ func InitHttpClient(url string) httputils.IHttpClient

Aug 14, 2023

Changes in this version

+ const ConcurrencyEnvironmentVariable

+ const TriggerSecurityFrameworkEnvironmentVariable

+ var ConcurrencyWorkers int = 3

+ var TriggerSecurityFramework bool = false

+ type Job struct

+ func (j *Job) Context() context.Context

+ func (j *Job) Obj() SessionObj

+ func (j *Job) SetContext(ctx context.Context)

+ func (j *Job) SetObj(sessionObj SessionObj)

May 31, 2023

Changes in this version

+ const CleanUpDelayEnvironmentVariable

+ const ContainerToImageIdsArg

+ var CleanUpRoutineInterval time.Duration = 10 * time.Minute

+ func AddCommandToChannel(ctx context.Context, cmd *apis.Command, channel *chan SessionObj)

+ func ExtractContainersToImageIDsFromPod(pod *core1.Pod) map[string]string

+ func ExtractImageID(imageID string) string

+ func NewK8sInterfaceFake(k8sClient k8s.Interface) *k8sinterface.KubernetesApi

Sep 5, 2022

Changes in this version

+ const ConfigEnvironmentVariable

+ const KubescapeRequestPathV1

+ const KubescapeRequestStatusV1

+ const KubescapeScanV1

+ const NamespaceEnvironmentVariable

+ const PortEnvironmentVariable

+ const ReleaseBuildTagEnvironmentVariable

+ var ClusterConfig = &utilsmetadata.ClusterConfig

+ var Namespace string = "default"

+ var ReporterHttpClient httputils.IHttpClient

+ var RestAPIPort string = "4002"

+ func InitKubescapeHttpClient() httputils.IHttpClient

+ func InitReporterHttpClient() httputils.IHttpClient

+ func InitVulnScanHttpClient() httputils.IHttpClient

+ func LoadEnvironmentVariables() (err error)

+ func MapToString(m map[string]interface{}) []string

+ func NewJobTracking(reporter reporterlib.IReporter) *apis.JobTracking

+ type ClientMock struct

+ func (c *ClientMock) Do(req *http.Request) (*http.Response, error)

+ type CredStruct struct

+ Customer string

+ Password string

+ User string

+ type SessionObj struct

+ Command apis.Command

+ ErrChan chan error

+ Reporter reporterlib.IReporter

+ func NewSessionObj(command *apis.Command, message, parentID, jobID string, actionNumber int) *SessionObj

+ func (sessionObj *SessionObj) WatchErrors()