rabbitmqclient

type ClientInfo struct {
	BaseURL   string
	Username  string
	Password  string
	Transport *http.Transport
}

type DefaultRabbitmqClientFactory struct{}

type RabbitmqClient interface {
	Overview() (*rabbithole.Overview, error)
	HealthCheckNodeIsQuorumCritical() (rabbithole.HealthCheckStatus, error)
}

type RabbitmqClientFactory interface {
	GetClientForPod(ctx context.Context, k8sClient client.Reader, rmq *rabbitmqv1beta1.RabbitmqCluster, podName string) (RabbitmqClient, error)
}