sns

Documentation

Index

• Variables
• func MustNewConsumer(config *ConsumerConfig) messaging.Consumer
• func MustNewProducer(config ProducerConfig) messaging.Producer
• func NewConsumer(config *ConsumerConfig) (messaging.Consumer, error)
• func NewProducer(config ProducerConfig) (messaging.Producer, error)
• func PriorityConsume(consumers []messaging.Consumer)
• type ConsumerConfig
• type ProducerConfig

Variables

var (
	ErrEmptyConfig    = errors.New("empty config")
	ErrEmptyAccessKey = errors.New("empty access key")
	ErrEmptySecretKey = errors.New("empty secret key")
)

Functions

func MustNewConsumer

func MustNewConsumer(config *ConsumerConfig) messaging.Consumer

func MustNewProducer

func MustNewProducer(config ProducerConfig) messaging.Producer

func NewConsumer

func NewConsumer(config *ConsumerConfig) (messaging.Consumer, error)

func NewProducer

func NewProducer(config ProducerConfig) (messaging.Producer, error)

func PriorityConsume

func PriorityConsume(consumers []messaging.Consumer)

PriorityConsume function takes a list of consumer objects and starts consuming them in a loop. The consumers are processed according to their priority. The process is stopped if the stop signal is received. The function exits when all consumers are stopped.

Types

type ConsumerConfig

type ConsumerConfig struct {
	AccessKey           string
	SecretKey           string
	Region              string
	VisibilityTimeout   int64
	WaitTimeSeconds     int64
	MaxNumberOfMessages int64
	QueueUrl            string
}

type ProducerConfig

type ProducerConfig struct {
	AccessKey       string
	SecretKey       string
	Region          string
	PublishInterval time.Duration
}