injector

Documentation

Index

• type KumaInjector
  • func New(cfg runtime_k8s.Injector, controlPlaneURL string, client kube_client.Client, ...) (*KumaInjector, error)
  • func (i *KumaInjector) FindServiceAccountToken(podSpec *kube_core.PodSpec) *kube_core.VolumeMount
  • func (i *KumaInjector) InjectKuma(ctx context.Context, pod *kube_core.Pod) error
  • func (i *KumaInjector) NewAnnotations(pod *kube_core.Pod, mesh string) (map[string]string, error)
  • func (i *KumaInjector) NewInitContainer(pod *kube_core.Pod) (kube_core.Container, error)
  • func (i *KumaInjector) NewSidecarContainer(pod *kube_core.Pod, mesh string) (kube_core.Container, error)
  • func (i *KumaInjector) NewVolumeMounts(pod *kube_core.Pod) ([]kube_core.VolumeMount, error)

Types

type KumaInjector

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

func New

func New(
	cfg runtime_k8s.Injector,
	controlPlaneURL string,
	client kube_client.Client,
	converter k8s_common.Converter,
	envoyAdminPort uint32,
	systemNamespace string,
) (*KumaInjector, error)

func (*KumaInjector) FindServiceAccountToken

func (i *KumaInjector) FindServiceAccountToken(podSpec *kube_core.PodSpec) *kube_core.VolumeMount

func (*KumaInjector) InjectKuma

func (i *KumaInjector) InjectKuma(ctx context.Context, pod *kube_core.Pod) error

func (*KumaInjector) NewAnnotations

func (i *KumaInjector) NewAnnotations(pod *kube_core.Pod, mesh string) (map[string]string, error)

func (*KumaInjector) NewInitContainer

func (i *KumaInjector) NewInitContainer(pod *kube_core.Pod) (kube_core.Container, error)

func (*KumaInjector) NewSidecarContainer

func (i *KumaInjector) NewSidecarContainer(
	pod *kube_core.Pod,
	mesh string,
) (kube_core.Container, error)

func (*KumaInjector) NewVolumeMounts

func (i *KumaInjector) NewVolumeMounts(pod *kube_core.Pod) ([]kube_core.VolumeMount, error)