k8s

Documentation

Index

• Variables
• func DeleteInstanceFromConfigMap(key string)
• type ConfigMapOperator
  • func NewConfigMapOperator() ConfigMapOperator
• type ConfigMapOperatorImpl
  • func (c *ConfigMapOperatorImpl) CreateConfigMap(dto *entity.SaveConfigDTO) (*v1.ConfigMap, error)
  • func (c *ConfigMapOperatorImpl) QueryConfigMap(name string, namespace string) *v1.ConfigMap
  • func (c *ConfigMapOperatorImpl) QueryConfigMapAndNamespaceByName(name string) (*v1.ConfigMap, string)
  • func (c *ConfigMapOperatorImpl) QueryConfigMapByName(name string) *v1.ConfigMap
  • func (c *ConfigMapOperatorImpl) StartMonitor(stopCh <-chan struct{})
  • func (c *ConfigMapOperatorImpl) UpdateConfigMap(dto *entity.SaveConfigDTO) (*v1.ConfigMap, error)
• type PodOperator
  • func (c *PodOperator) StartMonitor(stopCh <-chan struct{})
• type PodOperatorInterface
  • func NewPodAgent() PodOperatorInterface

Variables

var (
	KubeClient          kubernetes.Interface
	KubeInformerFactory kubeInformers.SharedInformerFactory
	AppRepo             *repository.ApplicationRepository
)

Functions

func DeleteInstanceFromConfigMap

func DeleteInstanceFromConfigMap(key string)

Types

type ConfigMapOperator

type ConfigMapOperator interface {
	QueryConfigMapByName(name string) *v1.ConfigMap
	QueryConfigMapAndNamespaceByName(name string) (*v1.ConfigMap, string)
	CreateConfigMap(dto *entity.SaveConfigDTO) (*v1.ConfigMap, error)
	UpdateConfigMap(dto *entity.SaveConfigDTO) (*v1.ConfigMap, error)
	QueryConfigMap(name string, namespace string) *v1.ConfigMap
	StartMonitor(stopCh <-chan struct{})
}

func NewConfigMapOperator

func NewConfigMapOperator() ConfigMapOperator

type ConfigMapOperatorImpl

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

var ConfigMapClient *ConfigMapOperatorImpl

func (*ConfigMapOperatorImpl) CreateConfigMap

func (c *ConfigMapOperatorImpl) CreateConfigMap(dto *entity.SaveConfigDTO) (*v1.ConfigMap, error)

func (*ConfigMapOperatorImpl) QueryConfigMap

func (c *ConfigMapOperatorImpl) QueryConfigMap(name string, namespace string) *v1.ConfigMap

func (*ConfigMapOperatorImpl) QueryConfigMapAndNamespaceByName

func (c *ConfigMapOperatorImpl) QueryConfigMapAndNamespaceByName(name string) (*v1.ConfigMap, string)

func (*ConfigMapOperatorImpl) QueryConfigMapByName

func (c *ConfigMapOperatorImpl) QueryConfigMapByName(name string) *v1.ConfigMap

func (*ConfigMapOperatorImpl) StartMonitor

func (c *ConfigMapOperatorImpl) StartMonitor(stopCh <-chan struct{})

func (*ConfigMapOperatorImpl) UpdateConfigMap

func (c *ConfigMapOperatorImpl) UpdateConfigMap(dto *entity.SaveConfigDTO) (*v1.ConfigMap, error)

type PodOperator

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

var PodClient *PodOperator

func (*PodOperator) StartMonitor

func (c *PodOperator) StartMonitor(stopCh <-chan struct{})

type PodOperatorInterface

type PodOperatorInterface interface {
	StartMonitor(stopCh <-chan struct{})
}

func NewPodAgent

func NewPodAgent() PodOperatorInterface