user

Documentation

Index

• func AddReadyCheck(cw *template.ConditionWaiter, instance *openstackv1beta1.RabbitMQUser)
• func Ensure(ctx context.Context, c client.Client, instance *openstackv1beta1.RabbitMQUser, ...) error
• func ReadyCondition(instance *openstackv1beta1.RabbitMQUser) *metav1.Condition
• func Secret(instance *openstackv1beta1.RabbitMQUser) *corev1.Secret
• func SetCondition(instance *openstackv1beta1.RabbitMQUser, conditionType string, ...)
• func SetupJob(instance *openstackv1beta1.RabbitMQUser, ...) *batchv1.Job
• type Reporter
  • func NewReporter(recorder record.EventRecorder) *Reporter
  • func (r *Reporter) Pending(instance *openstackv1beta1.RabbitMQUser, err error, ...)
  • func (r *Reporter) Succeeded(instance *openstackv1beta1.RabbitMQUser)

Functions

func AddReadyCheck

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

func Ensure

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

func ReadyCondition

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

func Secret

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

func SetCondition

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

func SetupJob

func SetupJob(instance *openstackv1beta1.RabbitMQUser, containerImage, databaseHostName, adminSecret string) *batchv1.Job

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.RabbitMQUser, err error, eventReason, message string)

func (*Reporter) Succeeded

func (r *Reporter) Succeeded(instance *openstackv1beta1.RabbitMQUser)