Documentation
¶
Overview ¶
Copyright © 2023 NAME HERE <EMAIL ADDRESS>
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type QueueData ¶
type QueueData struct {
Bindings []rabbithole.BindingInfo
Queue amqp.Queue
Channel *amqp.Channel
}
type RecordingDevice ¶
type RecordingDevice struct {
*rabbithole.Client
*amqp.Connection
}
func (*RecordingDevice) BindQueuesAndRecord ¶
func (rd *RecordingDevice) BindQueuesAndRecord(data []QueueData)
func (*RecordingDevice) SetupQueues ¶
func (rd *RecordingDevice) SetupQueues(queuesToRecord []string) ([]QueueData, error)
Source Files
Click to show internal directories.
Click to hide internal directories.