brokerconfig

Documentation

Index

• type BrokerConfigService
  • func New(ctx context.Context) *BrokerConfigService
  • func (r *BrokerConfigService) GetExchangeArgs(ctx context.Context, b *eventingv1.Broker) (*rabbit.ExchangeArgs, error)
  • func (r *BrokerConfigService) GetRabbitMQClusterRef(ctx context.Context, b *eventingv1.Broker) (*rabbitv1beta1.RabbitmqClusterReference, error)
  • func (r *BrokerConfigService) RabbitmqURL(ctx context.Context, clusterRef *rabbitv1beta1.RabbitmqClusterReference) (*url.URL, error)

Types

type BrokerConfigService

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

func New

func New(ctx context.Context) *BrokerConfigService

func (*BrokerConfigService) GetExchangeArgs

func (r *BrokerConfigService) GetExchangeArgs(ctx context.Context, b *eventingv1.Broker) (*rabbit.ExchangeArgs, error)

func (*BrokerConfigService) GetRabbitMQClusterRef

func (r *BrokerConfigService) GetRabbitMQClusterRef(ctx context.Context, b *eventingv1.Broker) (*rabbitv1beta1.RabbitmqClusterReference, error)

func (*BrokerConfigService) RabbitmqURL

func (r *BrokerConfigService) RabbitmqURL(ctx context.Context, clusterRef *rabbitv1beta1.RabbitmqClusterReference) (*url.URL, error)