workloads

Documentation

Index

• type ModificationResult
  • func NewHasBeenModifiedResult() ModificationResult
  • func NewIgnoredOnceResult() ModificationResult
  • func NewNotModifiedDueToErrorResult() ModificationResult
  • func NewNotModifiedImmutableWorkloadCannotBeInstrumentedResult() ModificationResult
  • func NewNotModifiedImmutableWorkloadCannotBeRevertedResult() ModificationResult
  • func NewNotModifiedNoChangesResult() ModificationResult
  • func NewNotModifiedOwnedByHigherOrderWorkloadResult() ModificationResult
  • func NewNotModifiedReasonUnknownResult() ModificationResult
• type NoModificationReasonMessage
• type ResourceModifier
  • func NewResourceModifier(instrumentationMetadata util.InstrumentationMetadata, logger *logr.Logger) *ResourceModifier
  • func (m *ResourceModifier) AddLabelsToImmutableJob(job *batchv1.Job) ModificationResult
  • func (m *ResourceModifier) ModifyCronJob(cronJob *batchv1.CronJob) ModificationResult
  • func (m *ResourceModifier) ModifyDaemonSet(daemonSet *appsv1.DaemonSet) ModificationResult
  • func (m *ResourceModifier) ModifyDeployment(deployment *appsv1.Deployment) ModificationResult
  • func (m *ResourceModifier) ModifyJob(job *batchv1.Job) ModificationResult
  • func (m *ResourceModifier) ModifyPod(pod *corev1.Pod) ModificationResult
  • func (m *ResourceModifier) ModifyReplicaSet(replicaSet *appsv1.ReplicaSet) ModificationResult
  • func (m *ResourceModifier) ModifyStatefulSet(statefulSet *appsv1.StatefulSet) ModificationResult
  • func (m *ResourceModifier) RemoveLabelsFromImmutableJob(job *batchv1.Job) ModificationResult
  • func (m *ResourceModifier) RevertCronJob(cronJob *batchv1.CronJob) ModificationResult
  • func (m *ResourceModifier) RevertDaemonSet(daemonSet *appsv1.DaemonSet) ModificationResult
  • func (m *ResourceModifier) RevertDeployment(deployment *appsv1.Deployment) ModificationResult
  • func (m *ResourceModifier) RevertReplicaSet(replicaSet *appsv1.ReplicaSet) ModificationResult
  • func (m *ResourceModifier) RevertStatefulSet(statefulSet *appsv1.StatefulSet) ModificationResult

Types

type ModificationResult

type ModificationResult struct {
	HasBeenModified     bool
	RenderReasonMessage NoModificationReasonMessage
	IgnoredOnce         bool
	ImmutableWorkload   bool
}

func NewHasBeenModifiedResult

func NewHasBeenModifiedResult() ModificationResult

func NewIgnoredOnceResult

func NewIgnoredOnceResult() ModificationResult

func NewNotModifiedDueToErrorResult

func NewNotModifiedDueToErrorResult() ModificationResult

func NewNotModifiedImmutableWorkloadCannotBeInstrumentedResult

func NewNotModifiedImmutableWorkloadCannotBeInstrumentedResult() ModificationResult

func NewNotModifiedImmutableWorkloadCannotBeRevertedResult

func NewNotModifiedImmutableWorkloadCannotBeRevertedResult() ModificationResult

func NewNotModifiedNoChangesResult

func NewNotModifiedNoChangesResult() ModificationResult

func NewNotModifiedOwnedByHigherOrderWorkloadResult

func NewNotModifiedOwnedByHigherOrderWorkloadResult() ModificationResult

func NewNotModifiedReasonUnknownResult

func NewNotModifiedReasonUnknownResult() ModificationResult

type NoModificationReasonMessage

type NoModificationReasonMessage func(actor util.WorkloadModifierActor) string

var (
	NoModificationReasonUnknown NoModificationReasonMessage = func(actor util.WorkloadModifierActor) string {
		return fmt.Sprintf("No modification by the %s occurred, reason unknown.", actor)
	}
	NoModificationReasonNoChanges NoModificationReasonMessage = func(actor util.WorkloadModifierActor) string {
		return fmt.Sprintf("Dash0 instrumentation was already present on this workload, no modification by the %s is necessary.", actor)
	}
	NoModificationReasonError NoModificationReasonMessage = func(actor util.WorkloadModifierActor) string {
		return fmt.Sprintf("Dash0 instrumentation by %s has not been successful.", actor)
	}
	NoModificationReasonOwnedByHigherOrderWorkload NoModificationReasonMessage = func(actor util.WorkloadModifierActor) string {
		return fmt.Sprintf("The workload is part of a higher order workload that will be instrumented by the webhook, no modification by the %s is necessary.", actor)
	}
	NoModificationReasonImmutableWorkloadCannotBeInstrumented NoModificationReasonMessage = func(actor util.WorkloadModifierActor) string {
		return "cannot instrumentation this workload, since this type of workload is immutable"
	}
	NoModificationReasonImmutableWorkloadCannotBeReverted NoModificationReasonMessage = func(actor util.WorkloadModifierActor) string {
		return "cannot remove the instrumentation from workload, since this type of workload is immutable"
	}
	NoModificationReasonIgnoreOnceLabel NoModificationReasonMessage = func(_ util.WorkloadModifierActor) string {
		return "Ignoring this admission request due to the presence of dash0.com/webhook-ignore-once."
	}
)

type ResourceModifier

type ResourceModifier struct {
	// contains filtered or unexported fields
}

func NewResourceModifier

func NewResourceModifier(
	instrumentationMetadata util.InstrumentationMetadata,
	logger *logr.Logger,
) *ResourceModifier

func (*ResourceModifier) AddLabelsToImmutableJob

func (m *ResourceModifier) AddLabelsToImmutableJob(job *batchv1.Job) ModificationResult

func (*ResourceModifier) ModifyCronJob

func (m *ResourceModifier) ModifyCronJob(cronJob *batchv1.CronJob) ModificationResult

func (*ResourceModifier) ModifyDaemonSet

func (m *ResourceModifier) ModifyDaemonSet(daemonSet *appsv1.DaemonSet) ModificationResult

func (*ResourceModifier) ModifyDeployment

func (m *ResourceModifier) ModifyDeployment(deployment *appsv1.Deployment) ModificationResult

func (*ResourceModifier) ModifyJob

func (m *ResourceModifier) ModifyJob(job *batchv1.Job) ModificationResult

func (*ResourceModifier) ModifyPod

func (m *ResourceModifier) ModifyPod(pod *corev1.Pod) ModificationResult

func (*ResourceModifier) ModifyReplicaSet

func (m *ResourceModifier) ModifyReplicaSet(replicaSet *appsv1.ReplicaSet) ModificationResult

func (*ResourceModifier) ModifyStatefulSet

func (m *ResourceModifier) ModifyStatefulSet(statefulSet *appsv1.StatefulSet) ModificationResult

func (*ResourceModifier) RemoveLabelsFromImmutableJob

func (m *ResourceModifier) RemoveLabelsFromImmutableJob(job *batchv1.Job) ModificationResult

func (*ResourceModifier) RevertCronJob

func (m *ResourceModifier) RevertCronJob(cronJob *batchv1.CronJob) ModificationResult

func (*ResourceModifier) RevertDaemonSet

func (m *ResourceModifier) RevertDaemonSet(daemonSet *appsv1.DaemonSet) ModificationResult

func (*ResourceModifier) RevertDeployment

func (m *ResourceModifier) RevertDeployment(deployment *appsv1.Deployment) ModificationResult

func (*ResourceModifier) RevertReplicaSet

func (m *ResourceModifier) RevertReplicaSet(replicaSet *appsv1.ReplicaSet) ModificationResult

func (*ResourceModifier) RevertStatefulSet

func (m *ResourceModifier) RevertStatefulSet(statefulSet *appsv1.StatefulSet) ModificationResult