Documentation
¶
Index ¶
- type Consumer
- type ConsumerSQS
- type Message
- type MessageHandler
- type Messaging
- type MessagingAWS
- type MessagingBuilder
- type MessagingConfig
- type MessagingFactory
- type Producer
- type ProducerSQS
- type QueueAttributes
- type QueueConfig
- type RabbitMQ
- type RabbitMQConsumer
- type RabbitMQObserver
- type RabbitMQProducer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer interface {
Listen(ctx context.Context, handler MessageHandler)
}
type ConsumerSQS ¶
type ConsumerSQS struct {
// contains filtered or unexported fields
}
func (*ConsumerSQS) Listen ¶
func (c *ConsumerSQS) Listen(ctx context.Context, handler MessageHandler)
type Message ¶
type Message struct { Id uuid.UUID `json:"id"` Type string `json:"type"` Action string `json:"action"` TenantId string `json:"tenant_id"` UserId string `json:"user_id"` Message interface{} `json:"message"` }
func NewMessage ¶
func (*Message) DecodeMessage ¶
type MessageHandler ¶
type Messaging ¶
type Messaging interface { NewProducer() Producer NewConsumer(att QueueAttributes) Consumer Close() error }
func FactoryMessaging ¶
func FactoryMessaging(provider env.MessagingProvider) (Messaging, error)
type MessagingAWS ¶
type MessagingAWS struct {
// contains filtered or unexported fields
}
func NewMessagingSQS ¶
func NewMessagingSQS() (*MessagingAWS, error)
func (*MessagingAWS) Close ¶
func (m *MessagingAWS) Close() error
func (*MessagingAWS) NewConsumer ¶
func (m *MessagingAWS) NewConsumer(att QueueAttributes) Consumer
func (*MessagingAWS) NewProducer ¶
func (m *MessagingAWS) NewProducer() Producer
type MessagingBuilder ¶
type MessagingBuilder struct {
// contains filtered or unexported fields
}
func New ¶
func New(provider env.MessagingProvider) *MessagingBuilder
func (*MessagingBuilder) Build ¶
func (b *MessagingBuilder) Build() Messaging
func (*MessagingBuilder) Close ¶
func (b *MessagingBuilder) Close()
func (*MessagingBuilder) DeclareExchange ¶
func (b *MessagingBuilder) DeclareExchange(exchangeName string) *MessagingBuilder
type MessagingConfig ¶
type MessagingConfig struct {
QueueName string
}
type MessagingFactory ¶
type MessagingFactory struct{}
type Producer ¶
type Producer interface {
SendToTopic(ctx context.Context, topic QueueAttributes, msg *Message) error
}
type ProducerSQS ¶
type ProducerSQS struct {
// contains filtered or unexported fields
}
func (*ProducerSQS) SendToTopic ¶
func (p *ProducerSQS) SendToTopic(ctx context.Context, topic QueueAttributes, msg *Message) error
type QueueAttributes ¶
type QueueConfig ¶
type RabbitMQ ¶
type RabbitMQ struct {
// contains filtered or unexported fields
}
func NewRabbitMQ ¶
func (*RabbitMQ) DeclareExchange ¶
func (*RabbitMQ) NewConsumer ¶
func (r *RabbitMQ) NewConsumer(att QueueAttributes) Consumer
func (*RabbitMQ) NewProducer ¶
type RabbitMQConsumer ¶
type RabbitMQConsumer struct {
// contains filtered or unexported fields
}
func (*RabbitMQConsumer) Listen ¶
func (c *RabbitMQConsumer) Listen(ctx context.Context, handler MessageHandler)
type RabbitMQObserver ¶
type RabbitMQObserver struct {
// contains filtered or unexported fields
}
func (RabbitMQObserver) Close ¶
func (o RabbitMQObserver) Close()
type RabbitMQProducer ¶
type RabbitMQProducer struct {
// contains filtered or unexported fields
}
func (*RabbitMQProducer) SendToTopic ¶
func (p *RabbitMQProducer) SendToTopic(ctx context.Context, topic QueueAttributes, msg *Message) error
Click to show internal directories.
Click to hide internal directories.