core

Documentation

Index

• Constants
• func EnqueueRequestForWatcher(watcherList map[types.NamespacedName]map[types.NamespacedName]bool) handler.EventHandler
• func GetNamespacedName(name string, namespace string) types.NamespacedName
• func GetNamespacedNameFromObject(obj ObjectWithNameAndNamespace) types.NamespacedName
• type Handler
  • func NewHandler(c client.Client, r record.EventRecorder) *Handler
  • func (h *Handler) GetWatchedConfigmaps() map[types.NamespacedName]map[types.NamespacedName]bool
  • func (h *Handler) GetWatchedSecrets() map[types.NamespacedName]map[types.NamespacedName]bool
  • func (h *Handler) HandleDaemonSet(instance *appsv1.DaemonSet) (reconcile.Result, error)
  • func (h *Handler) HandleDaemonSetWebhook(instance *appsv1.DaemonSet, dryRun *bool, isCreate bool) error
  • func (h *Handler) HandleDeployment(instance *appsv1.Deployment) (reconcile.Result, error)
  • func (h *Handler) HandleDeploymentWebhook(instance *appsv1.Deployment, dryRun *bool, isCreate bool) error
  • func (h *Handler) HandleStatefulSet(instance *appsv1.StatefulSet) (reconcile.Result, error)
  • func (h *Handler) HandleStatefulSetWebhook(instance *appsv1.StatefulSet, dryRun *bool, isCreate bool) error
  • func (h *Handler) RemoveWatches(instanceName types.NamespacedName)
• type NotFoundError
  • func (e *NotFoundError) Error() string
• type Object
• type ObjectWithNameAndNamespace

Constants

const (
	// ConfigHashAnnotation is the key of the annotation on the PodTemplate that
	// holds the configuration hash
	ConfigHashAnnotation = "wave.pusher.com/config-hash"

	// FinalizerString is the finalizer added to deployments to allow Wave to
	// perform advanced deletion logic
	FinalizerString = "wave.pusher.com/finalizer"

	// SchedulingDisabledAnnotation is set on a deployment if scheduling has been disabled
	// due to missing children and contains the original scheduler
	SchedulingDisabledAnnotation = "wave.pusher.com/scheduling-disabled"

	// SchedulingDisabledSchedulerName is the dummy scheduler to disable scheduling of pods
	SchedulingDisabledSchedulerName = "wave.pusher.com/invalid"

	// RequiredAnnotation is the key of the annotation on the Deployment that Wave
	// checks for before processing the deployment
	RequiredAnnotation = "wave.pusher.com/update-on-config-change"
)

Functions

func EnqueueRequestForWatcher

func EnqueueRequestForWatcher(watcherList map[types.NamespacedName]map[types.NamespacedName]bool) handler.EventHandler

func GetNamespacedName

func GetNamespacedName(name string, namespace string) types.NamespacedName

func GetNamespacedNameFromObject

func GetNamespacedNameFromObject(obj ObjectWithNameAndNamespace) types.NamespacedName

Types

type Handler

type Handler struct {
	client.Client
	// contains filtered or unexported fields
}

Handler performs the main business logic of the Wave controller

func NewHandler

func NewHandler(c client.Client, r record.EventRecorder) *Handler

NewHandler constructs a new instance of Handler

func (*Handler) GetWatchedConfigmaps

func (h *Handler) GetWatchedConfigmaps() map[types.NamespacedName]map[types.NamespacedName]bool

func (*Handler) GetWatchedSecrets

func (h *Handler) GetWatchedSecrets() map[types.NamespacedName]map[types.NamespacedName]bool

func (*Handler) HandleDaemonSet

func (h *Handler) HandleDaemonSet(instance *appsv1.DaemonSet) (reconcile.Result, error)

HandleDaemonSet is called by the DaemonSet controller to reconcile DaemonSets

func (*Handler) HandleDaemonSetWebhook

func (h *Handler) HandleDaemonSetWebhook(instance *appsv1.DaemonSet, dryRun *bool, isCreate bool) error

HandleDaemonSetWebhook is called by the daemonset webhook

func (*Handler) HandleDeployment

func (h *Handler) HandleDeployment(instance *appsv1.Deployment) (reconcile.Result, error)

HandleDeployment is called by the deployment controller to reconcile deployments

func (*Handler) HandleDeploymentWebhook

func (h *Handler) HandleDeploymentWebhook(instance *appsv1.Deployment, dryRun *bool, isCreate bool) error

HandleDeploymentWebhook is called by the deployment webhook

func (*Handler) HandleStatefulSet

func (h *Handler) HandleStatefulSet(instance *appsv1.StatefulSet) (reconcile.Result, error)

HandleStatefulSet is called by the StatefulSet controller to reconcile StatefulSets

func (*Handler) HandleStatefulSetWebhook

func (h *Handler) HandleStatefulSetWebhook(instance *appsv1.StatefulSet, dryRun *bool, isCreate bool) error

HandleStatefulSetWebhook is called by the statefulset webhook

func (*Handler) RemoveWatches

func (h *Handler) RemoveWatches(instanceName types.NamespacedName)

type NotFoundError

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

func (*NotFoundError) Error

func (e *NotFoundError) Error() string

type Object

type Object interface {
	client.Object
	metav1.Object
}

Object is used as a helper interface when passing Kubernetes resources between methods. Adjusted to satisfy client.Object directly.

type ObjectWithNameAndNamespace

type ObjectWithNameAndNamespace interface {
	GetNamespace() string
	GetName() string
}