controller

Documentation

Overview

Copyright 2024 iLogtail Authors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• type BootController
  • func (c *BootController) Clean()
  • func (c *BootController) Init() error
  • func (c *BootController) Start(ctx context.Context) error
• type ContainerFilter
• type DaemonSetController
  • func NewDaemonSetController(k8sClient *kubernetes.Clientset) *DaemonSetController
  • func (c *DaemonSetController) GetDaemonSetPods(dsName, dsNamespace string) (*corev1.PodList, error)
• type DeploymentController
  • func NewDeploymentController(k8sClient *kubernetes.Clientset) *DeploymentController
  • func (c *DeploymentController) AddFilter(deploymentName string, filter ContainerFilter) error
  • func (c *DeploymentController) DeleteDeployment(deploymentName, deploymentNamespace string) error
  • func (c *DeploymentController) GetDeploymentPods(deploymentName, deploymentNamespace string) (*corev1.PodList, error)
  • func (c *DeploymentController) RemoveFilter(deploymentName string, filter ContainerFilter) error

Types

type BootController

type BootController struct {
}

func (*BootController) Clean

func (c *BootController) Clean()

func (*BootController) Init

func (c *BootController) Init() error

func (*BootController) Start

func (c *BootController) Start(ctx context.Context) error

type ContainerFilter

type ContainerFilter struct {
	K8sLabel       map[string]string
	ContainerLabel map[string]string
	Env            map[string]string
	K8sNamespace   string
	K8sPod         string
	K8sContainer   string
}

type DaemonSetController

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

func NewDaemonSetController

func NewDaemonSetController(k8sClient *kubernetes.Clientset) *DaemonSetController

func (*DaemonSetController) GetDaemonSetPods

func (c *DaemonSetController) GetDaemonSetPods(dsName, dsNamespace string) (*corev1.PodList, error)

type DeploymentController

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

func NewDeploymentController

func NewDeploymentController(k8sClient *kubernetes.Clientset) *DeploymentController

func (*DeploymentController) AddFilter

func (c *DeploymentController) AddFilter(deploymentName string, filter ContainerFilter) error

func (*DeploymentController) DeleteDeployment

func (c *DeploymentController) DeleteDeployment(deploymentName, deploymentNamespace string) error

func (*DeploymentController) GetDeploymentPods

func (c *DeploymentController) GetDeploymentPods(deploymentName, deploymentNamespace string) (*corev1.PodList, error)

func (*DeploymentController) RemoveFilter

func (c *DeploymentController) RemoveFilter(deploymentName string, filter ContainerFilter) error