rabbitmq

Documentation

Index

• Constants
• func AddReadyCheck(cw *template.ConditionWaiter, instance *openstackv1beta1.RabbitMQ)
• func ClusterHeadlessService(instance *openstackv1beta1.RabbitMQ) *corev1.Service
• func ClusterManagementIngress(instance *openstackv1beta1.RabbitMQ) *netv1.Ingress
• func ClusterService(instance *openstackv1beta1.RabbitMQ) *corev1.Service
• func ClusterServiceMonitor(instance *openstackv1beta1.RabbitMQ) *unstructured.Unstructured
• func ClusterStatefulSet(instance *openstackv1beta1.RabbitMQ, configHash string) *appsv1.StatefulSet
• func ConfigMap(instance *openstackv1beta1.RabbitMQ) *corev1.ConfigMap
• func EnsureCluster(ctx context.Context, c client.Client, intended *openstackv1beta1.RabbitMQ, ...) error
• func ReadyCondition(instance *openstackv1beta1.RabbitMQ) *metav1.Condition
• func Secret(instance *openstackv1beta1.RabbitMQ) *corev1.Secret
• func SetCondition(instance *openstackv1beta1.RabbitMQ, conditionType string, ...)
• type Reporter
  • func NewReporter(recorder record.EventRecorder) *Reporter
  • func (r *Reporter) Pending(instance *openstackv1beta1.RabbitMQ, err error, eventReason, message string)
  • func (r *Reporter) Running(instance *openstackv1beta1.RabbitMQ)

Constants

const (
	AppLabel = "rabbitmq"
)

const (
	ClusterComponentLabel = "cluster"
)

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 EnsureCluster

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

func ReadyCondition

func ReadyCondition(instance *openstackv1beta1.RabbitMQ) *metav1.Condition

func Secret

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

func SetCondition

func SetCondition(instance *openstackv1beta1.RabbitMQ, conditionType string, status metav1.ConditionStatus, reason, message string)

Types

type Reporter

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

func NewReporter

func NewReporter(recorder record.EventRecorder) *Reporter

func (*Reporter) Pending

func (r *Reporter) Pending(instance *openstackv1beta1.RabbitMQ, err error, eventReason, message string)

func (*Reporter) Running

func (r *Reporter) Running(instance *openstackv1beta1.RabbitMQ)