k8s

Documentation

Index

• Variables
• func AreCronJobsEqual(a, b batchv1.CronJob) bool
• func AreCronJobsSuccessful(cs []batchv1.CronJob) bool
• func AreDeploymentsEqual(a, b appsv1.Deployment) bool
• func AreResouceRequirementsEqual(x corev1.ResourceRequirements, y corev1.ResourceRequirements) bool
• func AreServicesEqual(a, b corev1.Service) bool
• func CheckIfExists(ctx context.Context, kubeClient client.Client, ...) (bool, error)
• func CreateIfNotExist(ctx context.Context, kubeClient client.Client, ...) (bool, error)
• func DeleteIfExists(ctx context.Context, kubeClient client.Client, obj client.Object) error
• func GetRunningNamespace() (string, error)
• func ResourcesRequirementsWithDefaults(m corev1.ResourceRequirements) corev1.ResourceRequirements
• func TaintToToleration(t corev1.Taint) corev1.Toleration
• func TaintsToTolerations(taints []corev1.Taint) []corev1.Toleration
• func UpdateDeployment(current *appsv1.Deployment, desired appsv1.Deployment)
• func UpdateService(current *corev1.Service, desired corev1.Service)
• type IgnoreGenericEventsPredicate
  • func (p IgnoreGenericEventsPredicate) Create(e event.CreateEvent) bool
  • func (p IgnoreGenericEventsPredicate) Delete(e event.DeleteEvent) bool
  • func (p IgnoreGenericEventsPredicate) Generic(e event.GenericEvent) bool
  • func (p IgnoreGenericEventsPredicate) Update(e event.UpdateEvent) bool

Variables

var DefaultMondooClientResources corev1.ResourceRequirements = corev1.ResourceRequirements{
	Limits: corev1.ResourceList{
		corev1.ResourceMemory: resource.MustParse("1G"),
		corev1.ResourceCPU:    resource.MustParse("500m"),
	},

	Requests: corev1.ResourceList{
		corev1.ResourceMemory: resource.MustParse("500M"),
		corev1.ResourceCPU:    resource.MustParse("50m"),
	},
}

defaultMondooClientResources for Mondoo Client container

Functions

func AreCronJobsEqual

func AreCronJobsEqual(a, b batchv1.CronJob) bool

AreCronJobsEqual returns a value indicating whether 2 cron jobs are equal. Note that it does not perform a full comparison but checks just some of the properties of a deployment (only the ones we are currently interested at).

func AreCronJobsSuccessful

func AreCronJobsSuccessful(cs []batchv1.CronJob) bool

AreCronJobsSuccessful returns true if the latest runs of all of the provided CronJobs has been successful.

func AreDeploymentsEqual

func AreDeploymentsEqual(a, b appsv1.Deployment) bool

AreDeploymentsEqual returns a value indicating whether 2 deployments are equal. Note that it does not perform a full comparison but checks just some of the properties of a deployment (only the ones we are currently interested at).

func AreResouceRequirementsEqual

func AreResouceRequirementsEqual(x corev1.ResourceRequirements, y corev1.ResourceRequirements) bool

AreResouceRequirementsEqual returns a value indicating whether 2 resource requirements are equal.

func AreServicesEqual

func AreServicesEqual(a, b corev1.Service) bool

AreServicesEqual return a value indicating whether 2 services are equal. Note that it does not perform a full comparison but checks just some of the properties of a deployment (only the ones we are currently interested at).

func CheckIfExists

func CheckIfExists(ctx context.Context, kubeClient client.Client, retrieveObj, checkObj client.Object) (bool, error)

CheckIfExists will attempt to Get() the object, and report whether or not the object was found to exist.

func CreateIfNotExist

func CreateIfNotExist(ctx context.Context, kubeClient client.Client, retrieveObj, createObj client.Object) (bool, error)

CreateIfNotExist creates an object if it doesn't already exist. The returned boolean indicates whether the object has been created. If the object already existed or an error occurred, then "false" is returned. If the object exists, no AlreadyExists error is returned.

func DeleteIfExists

func DeleteIfExists(ctx context.Context, kubeClient client.Client, obj client.Object) error

DeleteIfExists deletes a Kubernetes object if it exists. Any errors that might pop up because the object does not exist are ignored.

func GetRunningNamespace

func GetRunningNamespace() (string, error)

GetRunningNamespace will return the namespace the Pod is running under Can fake the returned value (useful for local testing) by setting MONDOO_NAMESPACE_OVERRIDE

func ResourcesRequirementsWithDefaults

func ResourcesRequirementsWithDefaults(m corev1.ResourceRequirements) corev1.ResourceRequirements

ResourcesRequirementsWithDefaults will return the resource requirements from the parameter if such are specified. If not requirements are specified, default values will be returned.

func TaintToToleration

func TaintToToleration(t corev1.Taint) corev1.Toleration

func TaintsToTolerations

func TaintsToTolerations(taints []corev1.Taint) []corev1.Toleration

func UpdateDeployment

func UpdateDeployment(current *appsv1.Deployment, desired appsv1.Deployment)

UpdateDeployment updates a deployment such that it matches a desired state. The function does not replace all fields but only a set of fields that we are interested at.

func UpdateService

func UpdateService(current *corev1.Service, desired corev1.Service)

UpdateService updates a service such that it matches a desired state. The function does not replace all fields but only a set of fields that we are interested at.

Types

type IgnoreGenericEventsPredicate

type IgnoreGenericEventsPredicate struct{}

CreateOrDeletePredicate will completely generic events.

func (IgnoreGenericEventsPredicate) Create

func (p IgnoreGenericEventsPredicate) Create(e event.CreateEvent) bool

func (IgnoreGenericEventsPredicate) Delete

func (p IgnoreGenericEventsPredicate) Delete(e event.DeleteEvent) bool

func (IgnoreGenericEventsPredicate) Generic

func (p IgnoreGenericEventsPredicate) Generic(e event.GenericEvent) bool

func (IgnoreGenericEventsPredicate) Update

func (p IgnoreGenericEventsPredicate) Update(e event.UpdateEvent) bool