queue

Documentation

Index

• type Consumer
• type Processor
• type SQSConfig
• type SQSConsumer
• type SQSConsumerGroup
  • func NewSQSConsumerGroup(nConsumers uint8, config SQSConfig, processor Processor, logger *log.Logger) (*SQSConsumerGroup, error)
  • func (g *SQSConsumerGroup) Start(ctx context.Context, wg *sync.WaitGroup)

Types

type Consumer

type Consumer interface {
	Start(ctx context.Context, wg *sync.WaitGroup, processor Processor)
}

Consumer represents a consumer for a queue.

type Processor

type Processor interface {
	ProcessMessage(mssg string) error
}

Processor represents a queue message processor.

type SQSConfig

type SQSConfig struct {
	QueueArn    string `toml:"queue_arn"`
	Timeout     int64  `toml:"timeout"`
	MaxWaitTime int64  `toml:"wait_time"`
	QueueName   string `toml:"queue_name"`
	Endpoint    string `toml:"endpoint"`
}

SQSConfig is the configuration required for an SQSConsumer.

type SQSConsumer

type SQSConsumer struct {
	// contains filtered or unexported fields
}

SQSConsumer is the SQS implementation of the QueueConsumer interface.

type SQSConsumerGroup

type SQSConsumerGroup struct {
	// contains filtered or unexported fields
}

SQSConsumerGroup is a group of SQSConsumers.

func NewSQSConsumerGroup

func NewSQSConsumerGroup(nConsumers uint8, config SQSConfig, processor Processor, logger *log.Logger) (*SQSConsumerGroup, error)

NewSQSConsumerGroup creates a new SQSConsumerGroup.

func (*SQSConsumerGroup) Start

func (g *SQSConsumerGroup) Start(ctx context.Context, wg *sync.WaitGroup)

Start makes the consumer group start reading and processing messages from the queue.