Documentation
¶
Index ¶
- func GenerateDecouplingSubscriptionName(b *brokerv1beta1.Broker) string
- func GenerateDecouplingTopicName(b *brokerv1beta1.Broker) string
- func GenerateRetrySubscriptionName(t *brokerv1beta1.Trigger) string
- func GenerateRetryTopicName(t *brokerv1beta1.Trigger) string
- func UpdateVolumeGeneration(kubeClientSet kubernetes.Interface, p *corev1.Pod) error
- func UpdateVolumeGenerationForDeployment(kubeClient kubernetes.Interface, dl appsv1listers.DeploymentLister, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GenerateDecouplingSubscriptionName ¶
func GenerateDecouplingSubscriptionName(b *brokerv1beta1.Broker) string
GenerateDecouplingSubscriptionName generates a deterministic subscription name for a Broker. If the subscription name would be longer than allowed by PubSub, the Broker name is truncated to fit.
func GenerateDecouplingTopicName ¶
func GenerateDecouplingTopicName(b *brokerv1beta1.Broker) string
GenerateDecouplingTopicName generates a deterministic topic name for a Broker. If the topic name would be longer than allowed by PubSub, the Broker name is truncated to fit.
func GenerateRetrySubscriptionName ¶
func GenerateRetrySubscriptionName(t *brokerv1beta1.Trigger) string
GenerateRetrySubscriptionName generates a deterministic subscription name for a Trigger. If the subscription name would be longer than allowed by PubSub, the Trigger name is truncated to fit.
func GenerateRetryTopicName ¶
func GenerateRetryTopicName(t *brokerv1beta1.Trigger) string
GenerateRetryTopicName generates a deterministic topic name for a Trigger. If the topic name would be longer than allowed by PubSub, the Trigger name is truncated to fit.
func UpdateVolumeGeneration ¶
func UpdateVolumeGeneration(kubeClientSet kubernetes.Interface, p *corev1.Pod) error
UpdateVolumeGeneration updates the volume generation annotation on the pod to trigger volume mount refresh (for configmap).
func UpdateVolumeGenerationForDeployment ¶
func UpdateVolumeGenerationForDeployment(kubeClient kubernetes.Interface, dl appsv1listers.DeploymentLister, pl corev1listers.PodLister, ns, name string) error
UpdateVolumeGenerationForDeployment updates the volume generation annotation for all pods in this deployment. This technique is used to trigger immediate configmap volume refresh without restarting the pod, see https://kubernetes.io/docs/tasks/configure-pod-container/configure-pod-configmap/#mounted-configmaps-are-updated-automatically NOTE: update spec.template.metadata.annotations on the deployment resource causes pods to be recreated.
Types ¶
This section is empty.
Source Files