Documentation
¶
Index ¶
- type Client
- func (client *Client) Close() error
- func (client *Client) Consume(ctx context.Context, visibilitySeconds int32) (<-chan types.Message, error)
- func (client *Client) Push(ctx context.Context, record queues.Record) error
- func (client *Client) PushBatch(ctx context.Context, recordchan <-chan queues.Record) error
- func (client *Client) PushDeadRecord(ctx context.Context, record types.Message) error
- func (client *Client) RemoveMessage(ctx context.Context, msg types.Message) error
- func (client *Client) SetMessageVisibility(ctx context.Context, msg types.Message, seconds int32) error
- type SQSError
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
DeadLetterQueueURL string
QueueName string
QueueURL *string
// desired / default delay durations
MaxDelay time.Duration
ReconnectDelay time.Duration
ResendDelay time.Duration
RoutingKey string
// contains filtered or unexported fields
}
func (*Client) Consume ¶
func (client *Client) Consume(ctx context.Context, visibilitySeconds int32) (<-chan types.Message, error)
Consume will continuously put queue messages on the channel.
func (*Client) Push ¶
Push will push data onto the queue and wait for a response. TODO: work on resend with delay...
func (*Client) PushBatch ¶
Push will push data onto the queue and wait for a response. TODO: work on resend with delay????
func (*Client) PushDeadRecord ¶
PushDeadRecord will push an erroneous record onto the DLQ. TODO: work on resend with delay...
func (*Client) RemoveMessage ¶
Remove a message from the SQS queue
Source Files
Click to show internal directories.
Click to hide internal directories.