observing

Documentation

Index

• func NewImage(rawImage, containerName string) (image, error)
• func StartKubernetesObserverService(ctx context.Context, c kubernetes.Interface, informer cache.SharedInformer, ...) error
• type KubernetesAPPV1DaemonSetSerializer
  • func (daemonSetObjectSerializer KubernetesAPPV1DaemonSetSerializer) GetAPIVersion() string
  • func (daemonSetObjectSerializer KubernetesAPPV1DaemonSetSerializer) GetName() string
  • func (daemonSetObjectSerializer KubernetesAPPV1DaemonSetSerializer) GetNamespace() string
  • func (daemonSetObjectSerializer KubernetesAPPV1DaemonSetSerializer) GetObjectKind() string
  • func (daemonSetObjectSerializer KubernetesAPPV1DaemonSetSerializer) GetPodSpec() coreV1.PodSpec
  • func (daemonSetObjectSerializer KubernetesAPPV1DaemonSetSerializer) GetUID() string
• type KubernetesAPPV1DeploymentSerializer
  • func (deploymentObjectSerializer KubernetesAPPV1DeploymentSerializer) GetAPIVersion() string
  • func (deploymentObjectSerializer KubernetesAPPV1DeploymentSerializer) GetName() string
  • func (deploymentObjectSerializer KubernetesAPPV1DeploymentSerializer) GetNamespace() string
  • func (deploymentObjectSerializer KubernetesAPPV1DeploymentSerializer) GetObjectKind() string
  • func (deploymentObjectSerializer KubernetesAPPV1DeploymentSerializer) GetPodSpec() coreV1.PodSpec
  • func (deploymentObjectSerializer KubernetesAPPV1DeploymentSerializer) GetUID() string
• type KubernetesAPPV1StatefulSetSerializer
  • func (statefulSetObjectSerializer KubernetesAPPV1StatefulSetSerializer) GetAPIVersion() string
  • func (statefulSetObjectSerializer KubernetesAPPV1StatefulSetSerializer) GetName() string
  • func (statefulSetObjectSerializer KubernetesAPPV1StatefulSetSerializer) GetNamespace() string
  • func (statefulSetObjectSerializer KubernetesAPPV1StatefulSetSerializer) GetObjectKind() string
  • func (statefulSetObjectSerializer KubernetesAPPV1StatefulSetSerializer) GetPodSpec() coreV1.PodSpec
  • func (statefulSetObjectSerializer KubernetesAPPV1StatefulSetSerializer) GetUID() string
• type KubernetesObjectSerializer
  • func NewKubernetesAPPV1DaemonSetSerializer(kubernetesAPIObj interface{}) (KubernetesObjectSerializer, error)
  • func NewKubernetesAPPV1DeploymentSerializer(kubernetesAPIObj interface{}) (KubernetesObjectSerializer, error)
  • func NewKubernetesAPPV1StatefulSetSerializer(kubernetesAPIObj interface{}) (KubernetesObjectSerializer, error)
• type KubernetesObserverService
  • func (k *KubernetesObserverService) OnAdd(obj interface{})
  • func (k *KubernetesObserverService) OnDelete(obj interface{})
  • func (k *KubernetesObserverService) OnUpdate(_, newObj interface{})

Functions

func NewImage

func NewImage(rawImage, containerName string) (image, error)

func StartKubernetesObserverService

func StartKubernetesObserverService(ctx context.Context, c kubernetes.Interface, informer cache.SharedInformer, ns string, objSerializer func(obj interface{}) (KubernetesObjectSerializer, error), service differentiating.Service) error

Types

type KubernetesAPPV1DaemonSetSerializer

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

KubernetesAPPV1DaemonSetSerializer for kubernetes appV1/DaemonSet

func (KubernetesAPPV1DaemonSetSerializer) GetAPIVersion

func (daemonSetObjectSerializer KubernetesAPPV1DaemonSetSerializer) GetAPIVersion() string

func (KubernetesAPPV1DaemonSetSerializer) GetName

func (daemonSetObjectSerializer KubernetesAPPV1DaemonSetSerializer) GetName() string

func (KubernetesAPPV1DaemonSetSerializer) GetNamespace

func (daemonSetObjectSerializer KubernetesAPPV1DaemonSetSerializer) GetNamespace() string

func (KubernetesAPPV1DaemonSetSerializer) GetObjectKind

func (daemonSetObjectSerializer KubernetesAPPV1DaemonSetSerializer) GetObjectKind() string

func (KubernetesAPPV1DaemonSetSerializer) GetPodSpec

func (daemonSetObjectSerializer KubernetesAPPV1DaemonSetSerializer) GetPodSpec() coreV1.PodSpec

GetPodSpec from appV1/DaemonSet Object

func (KubernetesAPPV1DaemonSetSerializer) GetUID

func (daemonSetObjectSerializer KubernetesAPPV1DaemonSetSerializer) GetUID() string

type KubernetesAPPV1DeploymentSerializer

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

KubernetesAPPV1DeploymentSerializer for kubernetes appV1/Deployment

func (KubernetesAPPV1DeploymentSerializer) GetAPIVersion

func (deploymentObjectSerializer KubernetesAPPV1DeploymentSerializer) GetAPIVersion() string

func (KubernetesAPPV1DeploymentSerializer) GetName

func (deploymentObjectSerializer KubernetesAPPV1DeploymentSerializer) GetName() string

func (KubernetesAPPV1DeploymentSerializer) GetNamespace

func (deploymentObjectSerializer KubernetesAPPV1DeploymentSerializer) GetNamespace() string

func (KubernetesAPPV1DeploymentSerializer) GetObjectKind

func (deploymentObjectSerializer KubernetesAPPV1DeploymentSerializer) GetObjectKind() string

func (KubernetesAPPV1DeploymentSerializer) GetPodSpec

func (deploymentObjectSerializer KubernetesAPPV1DeploymentSerializer) GetPodSpec() coreV1.PodSpec

GetPodSpec from appV1/Deployment Object

func (KubernetesAPPV1DeploymentSerializer) GetUID

func (deploymentObjectSerializer KubernetesAPPV1DeploymentSerializer) GetUID() string

GetUID from appV1/Deployment Object

type KubernetesAPPV1StatefulSetSerializer

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

KubernetesAPPV1StatefulSetSerializer for kubernetes appV1/StatefulSet

func (KubernetesAPPV1StatefulSetSerializer) GetAPIVersion

func (statefulSetObjectSerializer KubernetesAPPV1StatefulSetSerializer) GetAPIVersion() string

func (KubernetesAPPV1StatefulSetSerializer) GetName

func (statefulSetObjectSerializer KubernetesAPPV1StatefulSetSerializer) GetName() string

func (KubernetesAPPV1StatefulSetSerializer) GetNamespace

func (statefulSetObjectSerializer KubernetesAPPV1StatefulSetSerializer) GetNamespace() string

func (KubernetesAPPV1StatefulSetSerializer) GetObjectKind

func (statefulSetObjectSerializer KubernetesAPPV1StatefulSetSerializer) GetObjectKind() string

func (KubernetesAPPV1StatefulSetSerializer) GetPodSpec

func (statefulSetObjectSerializer KubernetesAPPV1StatefulSetSerializer) GetPodSpec() coreV1.PodSpec

GetPodSpec from appV1/StatefulSet Object

func (KubernetesAPPV1StatefulSetSerializer) GetUID

func (statefulSetObjectSerializer KubernetesAPPV1StatefulSetSerializer) GetUID() string

GetUID from appV1/StatefulSet Object

type KubernetesObjectSerializer

type KubernetesObjectSerializer interface {
	GetPodSpec() v1.PodSpec
	GetObjectKind() string
	GetName() string
	GetUID() string
	GetAPIVersion() string
	GetNamespace() string
}

func NewKubernetesAPPV1DaemonSetSerializer

func NewKubernetesAPPV1DaemonSetSerializer(kubernetesAPIObj interface{}) (KubernetesObjectSerializer, error)

func NewKubernetesAPPV1DeploymentSerializer

func NewKubernetesAPPV1DeploymentSerializer(kubernetesAPIObj interface{}) (KubernetesObjectSerializer, error)

func NewKubernetesAPPV1StatefulSetSerializer

func NewKubernetesAPPV1StatefulSetSerializer(kubernetesAPIObj interface{}) (KubernetesObjectSerializer, error)

NewHandler try's to convert the kubernetes API Object to an *appsV1.StatefulSet. If conversion is not successful will return error.

type KubernetesObserverService

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

func (*KubernetesObserverService) OnAdd

func (k *KubernetesObserverService) OnAdd(obj interface{})

func (*KubernetesObserverService) OnDelete

func (k *KubernetesObserverService) OnDelete(obj interface{})

func (*KubernetesObserverService) OnUpdate

func (k *KubernetesObserverService) OnUpdate(_, newObj interface{})