k8s

Documentation

Index

• type K8sCli
• type Workload
  • func (w *Workload) Create()
  • func (w *Workload) CreateCollector() (otalpha1.OpenTelemetryCollector, error)
  • func (w *Workload) CreateIngress() (*networkingv1.Ingress, error)
  • func (w *Workload) CreateOrUpdate()
  • func (w *Workload) CreateService() (*corev1.Service, error)
  • func (w *Workload) CreateWorkload() (*v1.Deployment, error)
  • func (w *Workload) Delete()
  • func (w *Workload) DeleteCollector() error
  • func (w *Workload) DeleteIngress() error
  • func (w *Workload) DeleteService() error
  • func (w *Workload) DeleteWorkload() error
  • func (w *Workload) GetCollector() (otalpha1.OpenTelemetryCollector, error)
  • func (w *Workload) GetDeployment() (*v1.Deployment, error)
  • func (w *Workload) GetIngress() (*networkingv1.Ingress, error)
  • func (w *Workload) GetOtCollectorResource() dynamic.NamespaceableResourceInterface
  • func (w *Workload) GetPodsList() (*corev1.PodList, error)
  • func (w *Workload) GetService() (*corev1.Service, error)
  • func (w *Workload) Update()
  • func (w *Workload) UpdateCollector() (otalpha1.OpenTelemetryCollector, error)
  • func (w *Workload) UpdateIngress() (*networkingv1.Ingress, error)
  • func (w *Workload) UpdateService() (*corev1.Service, error)
  • func (w *Workload) UpdateWorkload() (*v1.Deployment, error)

Types

type K8sCli

type K8sCli struct {
	K8sClient     *kubernetes.Clientset
	DynamicClient *dynamic.DynamicClient
	Ctx           context.Context
}

type Workload

type Workload struct {
	K8sCli *K8sCli
	Spec   *meta.TaskSpec
}

func (*Workload) Create

func (w *Workload) Create()

Create 1. create workload, 2. create ingress 3. create service

func (*Workload) CreateCollector

func (w *Workload) CreateCollector() (otalpha1.OpenTelemetryCollector, error)

func (*Workload) CreateIngress

func (w *Workload) CreateIngress() (*networkingv1.Ingress, error)

func (*Workload) CreateOrUpdate

func (w *Workload) CreateOrUpdate()

func (*Workload) CreateService

func (w *Workload) CreateService() (*corev1.Service, error)

func (*Workload) CreateWorkload

func (w *Workload) CreateWorkload() (*v1.Deployment, error)

func (*Workload) Delete

func (w *Workload) Delete()

func (*Workload) DeleteCollector

func (w *Workload) DeleteCollector() error

func (*Workload) DeleteIngress

func (w *Workload) DeleteIngress() error

func (*Workload) DeleteService

func (w *Workload) DeleteService() error

func (*Workload) DeleteWorkload

func (w *Workload) DeleteWorkload() error

func (*Workload) GetCollector

func (w *Workload) GetCollector() (otalpha1.OpenTelemetryCollector, error)

func (*Workload) GetDeployment

func (w *Workload) GetDeployment() (*v1.Deployment, error)

func (*Workload) GetIngress

func (w *Workload) GetIngress() (*networkingv1.Ingress, error)

func (*Workload) GetOtCollectorResource

func (w *Workload) GetOtCollectorResource() dynamic.NamespaceableResourceInterface

func (*Workload) GetPodsList

func (w *Workload) GetPodsList() (*corev1.PodList, error)

func (*Workload) GetService

func (w *Workload) GetService() (*corev1.Service, error)

func (*Workload) Update

func (w *Workload) Update()

func (*Workload) UpdateCollector

func (w *Workload) UpdateCollector() (otalpha1.OpenTelemetryCollector, error)

func (*Workload) UpdateIngress

func (w *Workload) UpdateIngress() (*networkingv1.Ingress, error)

func (*Workload) UpdateService

func (w *Workload) UpdateService() (*corev1.Service, error)

func (*Workload) UpdateWorkload

func (w *Workload) UpdateWorkload() (*v1.Deployment, error)