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) GetQueueType(ctx context.Context, b *eventingv1.Broker) (v1alpha1.QueueType, error)
  • func (r *BrokerConfigService) GetRabbitMQClusterRef(ctx context.Context, b *eventingv1.Broker) (*rabbitv1beta1.RabbitmqClusterReference, error)
  • func (r *BrokerConfigService) GetRabbitMQVhost(ctx context.Context, b *eventingv1.Broker) (string, 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) GetQueueType

func (r *BrokerConfigService) GetQueueType(ctx context.Context, b *eventingv1.Broker) (v1alpha1.QueueType, error)

func (*BrokerConfigService) GetRabbitMQClusterRef

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

func (*BrokerConfigService) GetRabbitMQVhost

func (r *BrokerConfigService) GetRabbitMQVhost(ctx context.Context, b *eventingv1.Broker) (string, error)