appstate

Documentation

Index

• Constants
• Variables
• func CalculateDaemonSetState(clientset kubernetes.Interface, targetNamespace string, r *appsv1.DaemonSet) types.State
• func CalculateDeploymentState(r *appsv1.Deployment) types.State
• func CalculateIngressState(clientset kubernetes.Interface, r *networkingv1.Ingress) types.State
• func CalculatePersistentVolumeClaimState(r *corev1.PersistentVolumeClaim) types.State
• func CalculateServiceState(clientset kubernetes.Interface, r *corev1.Service) types.State
• func CalculateStatefulSetState(clientset kubernetes.Interface, targetNamespace string, r *appsv1.StatefulSet) types.State
• func NewDeploymentEventHandler(informers []types.StatusInformer, resourceStateCh chan<- types.ResourceState) *deploymentEventHandler
• func NewIngressEventHandler(clientset kubernetes.Interface, informers []types.StatusInformer, ...) *ingressEventHandler
• func NewPersistentVolumeClaimEventHandler(informers []types.StatusInformer, resourceStateCh chan<- types.ResourceState) *persistentVolumeClaimEventHandler
• func NewServiceEventHandler(clientset kubernetes.Interface, informers []types.StatusInformer, ...) *serviceEventHandler
• func WaitForDaemonSetToBeReady(clientset kubernetes.Interface, namespace, name string) error
• func WaitForDeploymentToBeReady(clientset kubernetes.Interface, namespace, name string) error
• func WaitForGenericResourceToBeReady(dr dynamic.ResourceInterface, name string) (err error)
• func WaitForIngressToBeReady(clientset kubernetes.Interface, namespace, name string) error
• func WaitForPersistentVolumeClaimToBeReady(clientset kubernetes.Interface, namespace, name string) error
• func WaitForProperty(namespace, name string, gvk *schema.GroupVersionKind, ...) error
• func WaitForResourceToBeReady(namespace, name string, gvk *schema.GroupVersionKind) error
• func WaitForServiceToBeReady(clientset kubernetes.Interface, namespace, name string) error
• func WaitForStatefulSetToBeReady(clientset kubernetes.Interface, namespace, name string) error
• type AppMonitor
  • func NewAppMonitor(clientset kubernetes.Interface, targetNamespace, appID string, sequence int64) *AppMonitor
  • func (m *AppMonitor) AppStatusChan() <-chan types.AppStatus
  • func (m *AppMonitor) Apply(informers []types.StatusInformer)
  • func (m *AppMonitor) Shutdown()
• type EventHandler
• type Monitor
  • func NewMonitor(clientset kubernetes.Interface, targetNamespace string) *Monitor
  • func (m *Monitor) AppStatusChan() <-chan types.AppStatus
  • func (m *Monitor) Apply(appID string, sequence int64, informers []types.StatusInformer)
  • func (m *Monitor) Shutdown()

Constants

const (
	DaemonSetResourceKind    = "daemonset"
	DaemonSetPodVersionLabel = "controller-revision-hash"
	DaemonSetOwnerKind       = "DaemonSet"
)

const (
	StatefulSetResourceKind    = "statefulset"
	StatefulSetPodVersionLabel = "controller-revision-hash"
	StatefulSetOwnerKind       = "StatefulSet"
)

const (
	DeploymentResourceKind = "deployment"
)

const (
	IngressResourceKind = "ingress"
)

const (
	PersistentVolumeClaimResourceKind = "persistentvolumeclaim"
)

const (
	ServiceResourceKind = "service"
)

Variables

var (
	WaitForResourceFns = map[string]func(clientset kubernetes.Interface, namespace, name string) error{
		DaemonSetResourceKind:             WaitForDaemonSetToBeReady,
		DeploymentResourceKind:            WaitForDeploymentToBeReady,
		IngressResourceKind:               WaitForIngressToBeReady,
		PersistentVolumeClaimResourceKind: WaitForPersistentVolumeClaimToBeReady,
		ServiceResourceKind:               WaitForServiceToBeReady,
		StatefulSetResourceKind:           WaitForStatefulSetToBeReady,
	}

	WaitForResourceInterval = time.Second * 2
)

Functions

func CalculateDaemonSetState

func CalculateDaemonSetState(clientset kubernetes.Interface, targetNamespace string, r *appsv1.DaemonSet) types.State

The pods in a daemonset can be identified by the match label set in the daemonset and the "controller-revision-hash" can be used to determine if they are all the in the same daemonset version.

func CalculateDeploymentState

func CalculateDeploymentState(r *appsv1.Deployment) types.State

func CalculateIngressState

func CalculateIngressState(clientset kubernetes.Interface, r *networkingv1.Ingress) types.State

func CalculatePersistentVolumeClaimState

func CalculatePersistentVolumeClaimState(r *corev1.PersistentVolumeClaim) types.State

func CalculateServiceState

func CalculateServiceState(clientset kubernetes.Interface, r *corev1.Service) types.State

func CalculateStatefulSetState

func CalculateStatefulSetState(clientset kubernetes.Interface, targetNamespace string, r *appsv1.StatefulSet) types.State

func NewDeploymentEventHandler

func NewDeploymentEventHandler(informers []types.StatusInformer, resourceStateCh chan<- types.ResourceState) *deploymentEventHandler

func NewIngressEventHandler

func NewIngressEventHandler(clientset kubernetes.Interface, informers []types.StatusInformer, resourceStateCh chan<- types.ResourceState) *ingressEventHandler

func NewPersistentVolumeClaimEventHandler

func NewPersistentVolumeClaimEventHandler(informers []types.StatusInformer, resourceStateCh chan<- types.ResourceState) *persistentVolumeClaimEventHandler

func NewServiceEventHandler

func NewServiceEventHandler(clientset kubernetes.Interface, informers []types.StatusInformer, resourceStateCh chan<- types.ResourceState) *serviceEventHandler

func WaitForDaemonSetToBeReady

func WaitForDaemonSetToBeReady(clientset kubernetes.Interface, namespace, name string) error

func WaitForDeploymentToBeReady

func WaitForDeploymentToBeReady(clientset kubernetes.Interface, namespace, name string) error

func WaitForGenericResourceToBeReady

func WaitForGenericResourceToBeReady(dr dynamic.ResourceInterface, name string) (err error)

func WaitForIngressToBeReady

func WaitForIngressToBeReady(clientset kubernetes.Interface, namespace, name string) error

func WaitForPersistentVolumeClaimToBeReady

func WaitForPersistentVolumeClaimToBeReady(clientset kubernetes.Interface, namespace, name string) error

func WaitForProperty

func WaitForProperty(namespace, name string, gvk *schema.GroupVersionKind, path, desiredValue string) error

func WaitForResourceToBeReady

func WaitForResourceToBeReady(namespace, name string, gvk *schema.GroupVersionKind) error

func WaitForServiceToBeReady

func WaitForServiceToBeReady(clientset kubernetes.Interface, namespace, name string) error

func WaitForStatefulSetToBeReady

func WaitForStatefulSetToBeReady(clientset kubernetes.Interface, namespace, name string) error

Types

type AppMonitor

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

func NewAppMonitor

func NewAppMonitor(clientset kubernetes.Interface, targetNamespace, appID string, sequence int64) *AppMonitor

func (*AppMonitor) AppStatusChan

func (m *AppMonitor) AppStatusChan() <-chan types.AppStatus

func (*AppMonitor) Apply

func (m *AppMonitor) Apply(informers []types.StatusInformer)

func (*AppMonitor) Shutdown

func (m *AppMonitor) Shutdown()

type EventHandler

type EventHandler interface {
	ObjectCreated(obj interface{})
	ObjectUpdated(obj interface{})
	ObjectDeleted(obj interface{})
}

type Monitor

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

func NewMonitor

func NewMonitor(clientset kubernetes.Interface, targetNamespace string) *Monitor

func (*Monitor) AppStatusChan

func (m *Monitor) AppStatusChan() <-chan types.AppStatus

func (*Monitor) Apply

func (m *Monitor) Apply(appID string, sequence int64, informers []types.StatusInformer)

func (*Monitor) Shutdown

func (m *Monitor) Shutdown()