Versions in this module Expand all Collapse all v0 v0.0.3 Jun 1, 2023 Changes in this version + type GooglePubSubPublisher struct + func NewGooglePubSubPublisher(cfg *config.Config) (*GooglePubSubPublisher, error) + func (p *GooglePubSubPublisher) Send(destination string, msg service.Message) error + func (p *GooglePubSubPublisher) Shutdown() v0.0.2 May 31, 2023 Changes in this version + type DestinationType string + const DestinationTypeExchange + const DestinationTypeQueue + type NatsPublisher struct + func NewNatsPublisher(cfg *config.Config) (*NatsPublisher, error) + func (p *NatsPublisher) Send(destination string, msg service.Message) error + func (p *NatsPublisher) Shutdown() + type RabbitPublisher struct + func NewRabbitPublisher(cfg *config.Config) (*RabbitPublisher, error) + func (r *RabbitPublisher) Send(destinationName string, msg service.Message) error + func (r *RabbitPublisher) Shutdown() + type RedisPublisher struct + func NewRedisPublisher(cfg *config.Config) (*RedisPublisher, error) + func (p *RedisPublisher) Send(destination string, msg service.Message) error + func (p *RedisPublisher) Shutdown()