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)
• 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)

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
}