Versions in this module Expand all Collapse all v1 v1.0.0 Nov 25, 2019 Changes in this version + func NewMessageSink(config MessageSinkConfig) (pubsub.MessageSink, error) + func NewMessageSource(config MessageSourceConfig) (pubsub.MessageSource, error) + type ConsumerError struct + MsgID string + Value error + func (e *ConsumerError) Error() string + type MessageSinkConfig struct + Client Queue + QueueURL *string + type MessageSourceConfig struct + Client Queue + QueueURL string + WaitSeconds time.Duration + type Queue interface + DeleteMessage func(*awsSQS.DeleteMessageInput) (*awsSQS.DeleteMessageOutput, error) + ReceiveMessage func(*awsSQS.ReceiveMessageInput) (*awsSQS.ReceiveMessageOutput, error) + SendMessage func(*awsSQS.SendMessageInput) (*awsSQS.SendMessageOutput, error)
Go to main page