Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Message ¶
type Message struct {
// contains filtered or unexported fields
}
Message abstraction for publishing.
func NewJSONMessage ¶
NewJSONMessage creates a new message with a JSON encoded body.
func NewMessage ¶
NewMessage creates a new message.
type Publisher ¶
type Publisher interface {
Publish(ctx context.Context, msg *Message) error
Close(ctx context.Context) error
}
Publisher interface of a RabbitMQ publisher.
type TracedPublisher ¶
type TracedPublisher struct {
// contains filtered or unexported fields
}
TracedPublisher defines a RabbitMQ publisher with tracing instrumentation.
func NewPublisher ¶
func NewPublisher(url, exc string) (*TracedPublisher, error)
NewPublisher creates a new publisher with the following defaults - exchange type: fanout - notifications are not handled at this point TBD.
Source Files
Click to show internal directories.
Click to hide internal directories.