Documentation ¶
Overview ¶
Package pubsub contains various implementation for event dispatcher.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dispatcher ¶
type Dispatcher interface { // Dispatch sends the outbox rows to the underlying queuing system. Dispatch(ctx context.Context, rows []event.OutboxRow) error io.Closer }
Dispatcher should be implemented by client which dispatches the outbox rows to its Queuing Server.
type RabbitMQ ¶
type RabbitMQ struct {
// contains filtered or unexported fields
}
RabbitMQ represents the RabbitMQ specific Dispatcher.
func NewRabbitMQ ¶
NewRabbitMQ creates a RabbitMQ dispatcher.
type SimpleQueueService ¶
type SimpleQueueService struct {
// contains filtered or unexported fields
}
SimpleQueueService represents the SimpleQueueService specific Dispatcher.
func NewSimpleQueueService ¶
func NewSimpleQueueService(sqsConn *sqs.SQS, sw Sweeper, logger *zap.Logger) (*SimpleQueueService, error)
NewSimpleQueueService creates a SimpleQueueService dispatcher.
func (*SimpleQueueService) Close ¶
func (s *SimpleQueueService) Close() error
Close Not implemented yet. No documentation found for closing AWS session.
Click to show internal directories.
Click to hide internal directories.