rabbitmq

package
v0.0.0-...-3e7746c Latest Latest
Warning

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

Go to latest
Published: Aug 7, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	AppLabel = "rabbitmq"
)
View Source
const (
	ClusterComponentLabel = "cluster"
)

Variables

This section is empty.

Functions

func AddReadyCheck

func AddReadyCheck(cw *template.ConditionWaiter, instance *openstackv1beta1.RabbitMQ)

func ClusterHeadlessService

func ClusterHeadlessService(instance *openstackv1beta1.RabbitMQ) *corev1.Service

func ClusterManagementIngress

func ClusterManagementIngress(instance *openstackv1beta1.RabbitMQ) *netv1.Ingress

func ClusterService

func ClusterService(instance *openstackv1beta1.RabbitMQ) *corev1.Service

func ClusterServiceMonitor

func ClusterServiceMonitor(instance *openstackv1beta1.RabbitMQ) *unstructured.Unstructured

func ClusterStatefulSet

func ClusterStatefulSet(instance *openstackv1beta1.RabbitMQ, configHash string) *appsv1.StatefulSet

func ConfigMap

func ConfigMap(instance *openstackv1beta1.RabbitMQ) *corev1.ConfigMap

func Ensure

func Ensure(ctx context.Context, c client.Client, instance *openstackv1beta1.RabbitMQ, log logr.Logger) error

func ErlangCookieFromSecret

func ErlangCookieFromSecret(secret *corev1.Secret) string

func PKIResources

func PKIResources(instance *openstackv1beta1.RabbitMQ) []*unstructured.Unstructured

func PasswordFromSecret

func PasswordFromSecret(secret *corev1.Secret) string

func Secret

func Secret(instance *openstackv1beta1.RabbitMQ, erlangCookie, password string) *corev1.Secret

func ServerCertificate

func ServerCertificate(instance *openstackv1beta1.RabbitMQ) *unstructured.Unstructured

Types

type Reporter

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

func NewReporter

func NewReporter(instance *openstackv1beta1.RabbitMQ, k8sClient client.Client, recorder record.EventRecorder) *Reporter

func (*Reporter) Pending

func (r *Reporter) Pending(ctx context.Context, message string, args ...any) error

func (*Reporter) Running

func (r *Reporter) Running(ctx context.Context) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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