Documentation ¶
Index ¶
Constants ¶
View Source
const (
StreamAmqp = iota
)
Variables ¶
View Source
var Streams = make(map[int]Stream, 1)
Functions ¶
This section is empty.
Types ¶
type AmqpStream ¶
type AmqpStream struct { URI *amqp.URI Connection *amqp.Connection Channel *amqp.Channel Config *config.Configuration }
func (*AmqpStream) Connect ¶
func (s *AmqpStream) Connect() error
Connect connects to the AMQP server. The credentials are received by the AmqpInstance struct
func (*AmqpStream) DeclareAndBind ¶
func (s *AmqpStream) DeclareAndBind(config *config.AmqpConfiguration) error
DeclareAndBind defines the exchange and queue at the AMQP server. We declare our topology on both the publisher and consumer to ensure they are the same. This is part of AMQP being a programmable messaging model. After declaring we are binding it to be able to receive messages in the queue by the exchange.
func (*AmqpStream) Initialize ¶
func (s *AmqpStream) Initialize(config *config.Configuration)
func (*AmqpStream) Start ¶
func (s *AmqpStream) Start() error
type Gotrap ¶
func (*Gotrap) IsBranchConfigured ¶
func (*Gotrap) IsProjectConfigured ¶
func (*Gotrap) IsSubjectExcludedByPattern ¶
func (*Gotrap) TakeAction ¶
func (trap *Gotrap) TakeAction()
Click to show internal directories.
Click to hide internal directories.