appstate

Documentation

Index

• Constants
• 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 GenerateStatusInformersForManifest(manifest string) []types.StatusInformerString
• 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
• type AppMonitor
  • func NewAppMonitor(clientset kubernetes.Interface, targetNamespace, appSlug string, ...) *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(appSlug string, sequence int64, informers []types.StatusInformer)
  • func (m *Monitor) Shutdown()
• type Operator
  • func InitOperator(clientset kubernetes.Interface, targetNamespace string) *Operator
  • func MustGetOperator() *Operator
  • func (o *Operator) ApplyAppInformers(args types.AppInformersArgs)
  • func (o *Operator) Shutdown()
  • func (o *Operator) Start()

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"
)

Functions

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 GenerateStatusInformersForManifest

func GenerateStatusInformersForManifest(manifest string) []types.StatusInformerString

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

Types

type AppMonitor

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

func NewAppMonitor

func NewAppMonitor(clientset kubernetes.Interface, targetNamespace, appSlug 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(appSlug string, sequence int64, informers []types.StatusInformer)

func (*Monitor) Shutdown

func (m *Monitor) Shutdown()

type Operator

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

func InitOperator

func InitOperator(clientset kubernetes.Interface, targetNamespace string) *Operator

NewOperator creates and initializes a new Operator.

func MustGetOperator

func MustGetOperator() *Operator

func (*Operator) ApplyAppInformers

func (o *Operator) ApplyAppInformers(args types.AppInformersArgs)

func (*Operator) Shutdown

func (o *Operator) Shutdown()

func (*Operator) Start

func (o *Operator) Start()