mutation

Documentation

Index

• func MutatePodByInjectingContainers(pod *corev1.Pod, image string, preSynchronizeFromRemoteOnStart bool, ...) error
• func ResolvePod(a *admissionv1.AdmissionRequest) (*corev1.Pod, error)
• func ResolvePodFilesystemSync(a *admissionv1.AdmissionRequest) (*v1alpha1.PodFilesystemSync, bool, error)
• func ResolveTemplatedEnvironment(pod *corev1.Pod, syncDefinition *v1alpha1.PodFilesystemSync) (map[string]string, error)
• func VerifySecrets(syncDefinition *v1alpha1.PodFilesystemSync, namespace string) error
• type PodMutationController
  • func NewPodMutator(cache *cache.Cache, r versioned.Interface, k kubernetes.Interface) PodMutationController
  • func (m *PodMutationController) ProcessAdmissionRequest(review *admissionv1.AdmissionReview, image string) (corev1.Pod, corev1.Pod, error)

Functions

func MutatePodByInjectingContainers

func MutatePodByInjectingContainers(pod *corev1.Pod, image string, preSynchronizeFromRemoteOnStart bool, canSynchronizeToRemote bool, params context.SynchronizationParameters) error

MutatePodByInjectingContainers returns a new mutated pod according to set env rules

func ResolvePod

func ResolvePod(a *admissionv1.AdmissionRequest) (*corev1.Pod, error)

func ResolvePodFilesystemSync

func ResolvePodFilesystemSync(a *admissionv1.AdmissionRequest) (*v1alpha1.PodFilesystemSync, bool, error)

func ResolveTemplatedEnvironment

func ResolveTemplatedEnvironment(pod *corev1.Pod, syncDefinition *v1alpha1.PodFilesystemSync) (map[string]string, error)

ResolveTemplatedEnvironment is creating a map of environment variables with addition of template parsing

func VerifySecrets

func VerifySecrets(syncDefinition *v1alpha1.PodFilesystemSync, namespace string) error

VerifySecrets is performing basic checks on `kind: Secret` - it does not check existence of a `kind: Secret` so this could be delegated to API server

Types

type PodMutationController

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

func NewPodMutator

func NewPodMutator(cache *cache.Cache, r versioned.Interface, k kubernetes.Interface) PodMutationController

func (*PodMutationController) ProcessAdmissionRequest

func (m *PodMutationController) ProcessAdmissionRequest(review *admissionv1.AdmissionReview, image string) (corev1.Pod, corev1.Pod, error)

ProcessAdmissionRequest is retrieving all the required data, calling to resolve, then calling a mutation action