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 (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
- type Object
- type ObjectWithNameAndNamespace
Constants ¶
View Source
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"
)
Variables ¶
This section is empty.
Functions ¶
func EnqueueRequestForWatcher ¶ added in v0.7.0
func EnqueueRequestForWatcher(watcherList map[types.NamespacedName]map[types.NamespacedName]bool) handler.EventHandler
func GetNamespacedName ¶ added in v0.7.0
func GetNamespacedName(name string, namespace string) types.NamespacedName
func GetNamespacedNameFromObject ¶ added in v0.7.0
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 ¶ added in v0.7.0
func (h *Handler) GetWatchedConfigmaps() map[types.NamespacedName]map[types.NamespacedName]bool
func (*Handler) GetWatchedSecrets ¶ added in v0.7.0
func (h *Handler) GetWatchedSecrets() map[types.NamespacedName]map[types.NamespacedName]bool
func (*Handler) HandleDaemonSet ¶ added in v0.3.0
func (h *Handler) HandleDaemonSet(instance *appsv1.DaemonSet) (reconcile.Result, error)
HandleDaemonSet is called by the DaemonSet controller to reconcile DaemonSets
func (*Handler) HandleDaemonSetWebhook ¶ added in v0.7.0
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 ¶ added in v0.7.0
func (h *Handler) HandleDeploymentWebhook(instance *appsv1.Deployment, dryRun *bool, isCreate bool) error
HandleDeploymentWebhook is called by the deployment webhook
func (*Handler) HandleStatefulSet ¶ added in v0.3.0
func (h *Handler) HandleStatefulSet(instance *appsv1.StatefulSet) (reconcile.Result, error)
HandleStatefulSet is called by the StatefulSet controller to reconcile StatefulSets
func (*Handler) HandleStatefulSetWebhook ¶ added in v0.7.0
func (h *Handler) HandleStatefulSetWebhook(instance *appsv1.StatefulSet, dryRun *bool, isCreate bool) error
HandleStatefulSetWebhook is called by the statefulset webhook
func (*Handler) RemoveWatches ¶ added in v0.7.0
func (h *Handler) RemoveWatches(instanceName types.NamespacedName)
type NotFoundError ¶ added in v0.7.0
type NotFoundError struct {
// contains filtered or unexported fields
}
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 ¶ added in v0.7.0
type ObjectWithNameAndNamespace interface {
GetNamespace() string
GetName() string
}
Source Files
Click to show internal directories.
Click to hide internal directories.