queue

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

type Processor interface {
	ProcessMessage(mssg string) error
}

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"`
}

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

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