Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AmqpConnection ¶
type AmqpConnection struct {
Endpoint string
SubscriptionName string
SubscriptionAmqpPath string
TopicName string
AccessKeys servicebus.AccessKeys
AMQPConnectionString string
Session *amqp.Session
Receiver *amqp.Receiver
// contains filtered or unexported fields
}
AmqpConnection provides a connection to service bus and methods for creating required subscriptions and topics
func NewAmqpConnection ¶
func NewAmqpConnection(ctx context.Context, config *types.Configuration) *AmqpConnection
NewAmqpConnection initilises a servicebus lister from configuration
func (*AmqpConnection) CreateAmqpSender ¶
func (l *AmqpConnection) CreateAmqpSender(topic string) (*amqp.Sender, error)
CreateAmqpSender exists for e2e testing.
func (*AmqpConnection) GetQueueDepth ¶
func (l *AmqpConnection) GetQueueDepth() (int64, error)
GetQueueDepth returns the current length of the sb queue
Source Files
Click to show internal directories.
Click to hide internal directories.