appstate

package
v1.0.0-beta.18 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 26, 2024 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DaemonSetResourceKind    = "daemonset"
	DaemonSetPodVersionLabel = "controller-revision-hash"
	DaemonSetOwnerKind       = "DaemonSet"
)
View Source
const (
	StatefulSetResourceKind    = "statefulset"
	StatefulSetPodVersionLabel = "controller-revision-hash"
	StatefulSetOwnerKind       = "StatefulSet"
)
View Source
const (
	DeploymentResourceKind = "deployment"
)
View Source
const (
	IngressResourceKind = "ingress"
)
View Source
const (
	PersistentVolumeClaimResourceKind = "persistentvolumeclaim"
)
View Source
const (
	ServiceResourceKind = "service"
)

Variables

This section is empty.

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL