Documentation ¶
Index ¶
- Constants
- type BrokerPeer
- type Peer
- func (p *Peer) DoneChannel()
- func (p *Peer) ErrorChannel() <-chan error
- func (p *Peer) ReceiveMessage() ([]byte, error)
- func (p *Peer) SendChannel() chan<- []byte
- func (p *Peer) SetupPublishRoutine()
- func (p *Peer) SetupPublisherConnection(connectionURL string) error
- func (p *Peer) SetupSubscriberConnection(connectionURL, queueType string) error
Constants ¶
View Source
const ( QUOROM_QUEUE = "QUORUM" CLASSIC_QUEUE = "CLASSIC" MAX_QUEUE_LENGTH_BYTES = 1024 * 1024 * 20 // 20MB )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BrokerPeer ¶
type BrokerPeer struct {
// contains filtered or unexported fields
}
BrokerPeer implements the peer interface for AMQP brokers
func NewBrokerPeer ¶
func NewBrokerPeer(settings broker.MQSettings) *BrokerPeer
NewBrokerPeer creates and returns a new Peer for communicating with AMQP
func (*BrokerPeer) GetResults ¶
func (bp *BrokerPeer) GetResults() *broker.Results
func (*BrokerPeer) SetupPublishers ¶
func (bp *BrokerPeer) SetupPublishers() error
func (*BrokerPeer) SetupSubscribers ¶
func (bp *BrokerPeer) SetupSubscribers() error
func (*BrokerPeer) StartPublishers ¶
func (bp *BrokerPeer) StartPublishers()
func (*BrokerPeer) StartSubscribers ¶
func (bp *BrokerPeer) StartSubscribers()
func (*BrokerPeer) Teardown ¶
func (bp *BrokerPeer) Teardown()
Performs any broker-connection cleanup after test is done
type Peer ¶
type Peer struct {
// contains filtered or unexported fields
}
Peer stores specific AMQP broker connection information
func (*Peer) DoneChannel ¶
func (p *Peer) DoneChannel()
Done signals to the peer that message publishing has completed.
func (*Peer) ErrorChannel ¶
Errors returns the channel on which the peer sends publish errors.
func (*Peer) ReceiveMessage ¶
func (*Peer) SendChannel ¶
Send returns a channel on which messages can be sent for publishing.
func (*Peer) SetupPublishRoutine ¶
func (p *Peer) SetupPublishRoutine()
Goroutine which fetch messages from send-channel and publish them
func (*Peer) SetupPublisherConnection ¶
func (*Peer) SetupSubscriberConnection ¶
Click to show internal directories.
Click to hide internal directories.