jobs

Mar 19, 2024

Changes in this version

type JobOption

+ func WithReplaceResourceReq(replaceResourceReq bool) JobOption

Mar 19, 2024

Changes in this version

type CollectorOption

+ func WithJobAffinity(affinity *corev1.Affinity) CollectorOption

type JobOption

+ func WithAffinity(affinity *corev1.Affinity) JobOption

+ func WithNodeName(nodeName string) JobOption

+ func WithUseNodeSelectorParam(useNodeSelector bool) JobOption

Jan 17, 2024

Changes in this version

type CollectorOption

+ func WithUseNodeSelector(useNodeSelector bool) CollectorOption

Jan 14, 2024

Changes in this version

type CollectorOption

+ func WithNodeConfig(nodeConfig bool) CollectorOption

type JobOption

+ func WithNodeConfiguration(nodeConfig bool) JobOption

Dec 25, 2023

Changes in this version

+ func GetAuth(opts ...AuthOption) (*rbacv1.ClusterRole, *rbacv1.ClusterRoleBinding, *corev1.ServiceAccount, error)

+ type AuthBuilder struct

+ type AuthOption func(*AuthBuilder)

+ func WithServiceAccountNamespace(namespace string) AuthOption

type CollectorOption

+ func WithCollectorTimeout(timeout time.Duration) CollectorOption

+ func WithContainerResourceRequirements(rr *corev1.ResourceRequirements) CollectorOption

type JobOption

+ func WithJobTimeout(timeout time.Duration) JobOption

+ func WithResourceRequirements(rr *corev1.ResourceRequirements) JobOption

Oct 4, 2023

Changes in this version

type CollectorOption

+ func WithPodPriorityClassName(priorityClassName string) CollectorOption

type JobOption

+ func WithPriorityClassName(priorityClassName string) JobOption

Jun 11, 2023

Changes in this version

type CollectorOption

+ func WithJobAnnotation(annotation map[string]string) CollectorOption

May 10, 2023

Changes in this version

type CollectorOption

+ func WithContainerSecurityContext(securityContext *corev1.SecurityContext) CollectorOption

+ func WithPodImagePullSecrets(imagePullSecrets []corev1.LocalObjectReference) CollectorOption

+ func WithPodSpecSecurityContext(podSecurityContext *corev1.PodSecurityContext) CollectorOption

+ func WithVolumes(volumes []corev1.Volume) CollectorOption

+ func WithVolumesMount(volumesMount []corev1.VolumeMount) CollectorOption

type JobOption

+ func WithContainerVolumeMounts(volumeMounts []corev1.VolumeMount) JobOption

+ func WithImagePullSecrets(imagePullSecrets []corev1.LocalObjectReference) JobOption

+ func WithPodVolumes(volumes []corev1.Volume) JobOption

Mar 4, 2023

Changes in this version

+ const NodeCollectorName

+ const TrivyAutoCreated

+ const TrivyCollectorName

+ const TrivyNamespace

+ const TrivyResourceKind

+ const TrivyResourceName

+ var ErrTimeout = errors.New("runner received timeout")

+ func ComputeHash(obj interface{}) string

+ func GetActiveDeadlineSeconds(d time.Duration) *int64

+ func GetJob(opts ...JobOption) (*batchv1.Job, error)

+ func GetTerminatedContainersStatusesByPod(pod *corev1.Pod) map[string]*corev1.ContainerStateTerminated

+ func IsPodControlledByJobNotFound(err error) bool

+ type Collector interface

+ AppendLabels func(opts ...CollectorOption)

+ Apply func(ctx context.Context, nodeName string) (*batchv1.Job, error)

+ ApplyAndCollect func(ctx context.Context, nodeName string) (string, error)

+ Cleanup func(ctx context.Context)

+ func NewCollector(cluster k8s.Cluster, opts ...CollectorOption) Collector

+ type CollectorOption func(*jobCollector)

+ func WithImageRef(imageRef string) CollectorOption

+ func WithJoAnnotation(annotation map[string]string) CollectorOption

+ func WithJobLabels(labels map[string]string) CollectorOption

+ func WithJobNamespace(namespace string) CollectorOption

+ func WithJobTemplateName(name string) CollectorOption

+ func WithJobTolerations(tolerations []corev1.Toleration) CollectorOption

+ func WithName(name string) CollectorOption

+ func WithServiceAccount(sa string) CollectorOption

+ func WithTimetout(timeout time.Duration) CollectorOption

+ type JobBuilder struct

+ type JobOption func(*JobBuilder)

+ func WithAnnotation(annotations map[string]string) JobOption

+ func WithJobName(name string) JobOption

+ func WithJobServiceAccount(sa string) JobOption

+ func WithLabels(labels map[string]string) JobOption

+ func WithNamespace(namespace string) JobOption

+ func WithNodeCollectorImageRef(imageRef string) JobOption

+ func WithNodeSelector(nodeSelector string) JobOption

+ func WithTemplate(template string) JobOption

+ func WithTolerations(tolerations []corev1.Toleration) JobOption

+ type LogsReader interface

+ GetLogsByJobAndContainerName func(ctx context.Context, job *batchv1.Job, containerName string) (io.ReadCloser, error)

+ GetTerminatedContainersStatusesByJob func(ctx context.Context, job *batchv1.Job) (map[string]*corev1.ContainerStateTerminated, error)

+ func NewLogsReader(clientset kubernetes.Interface) LogsReader

+ type ObjectRef struct

+ Kind string

+ Name string

+ Namespace string

+ type Runnable interface

+ Run func(ctx context.Context) error

+ func NewRunnableJob(clientset kubernetes.Interface, job *batchv1.Job) Runnable

+ type RunnableFunc func(ctx context.Context) error

+ func (f RunnableFunc) Run(ctx context.Context) error

+ type Runner interface

+ Run func(ctx context.Context, task Runnable) error

+ func New(opts ...RunnerOption) Runner

+ type RunnerOption func(*runner)

+ func WithTimeout(timeout time.Duration) RunnerOption