appstate

Documentation

Index

• Constants
• 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 NewStatefulSetEventHandler(informers []types.StatusInformer, resourceStateCh chan<- types.ResourceState) *statefulSetEventHandler
• 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 (
	DeploymentResourceKind = "deployment"
)

const (
	IngressResourceKind = "ingress"
)

const (
	PersistentVolumeClaimResourceKind = "persistentvolumeclaim"
)

const (
	ServiceResourceKind = "service"
)

const (
	StatefulSetResourceKind = "statefulset"
)

Functions

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 NewStatefulSetEventHandler

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

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