sqs

package

v0.2.0 Latest Latest Go to latest Published: Jun 24, 2026 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/zloevil/jet

Links

Open Source Insights

Documentation ¶

Overview ¶

Package sqs provides a client and a message subscriber for Amazon SQS queues.

Index ¶

Constants
Variables
type Client
- func NewClient(awsCfg *jetaws.Config, logger jet.CLoggerFunc) *Client
type Config
type Subscriber
- func NewSubscriber(client *Client, cfg *Config, queueName string, receiver chan types.Message, ...) *Subscriber
- func (s *Subscriber) Run(ctx context.Context) error

Constants ¶

View Source

const (
	ErrCodeSQSGetUrl        = "SQS-001"
	ErrCodeSQSGetMessages   = "SQS-002"
	ErrCodeSQSSubGetMessage = "SQS-003"
)

Variables ¶

View Source

var (
	ErrSQSGetUrl = func(ctx context.Context, cause error) error {
		return jet.NewAppErrBuilder(ErrCodeSQSGetUrl, "get url").C(ctx).Wrap(cause).Err()
	}
	ErrSQSGetMessages = func(ctx context.Context, cause error) error {
		return jet.NewAppErrBuilder(ErrCodeSQSGetMessages, "get messages").C(ctx).Wrap(cause).Err()
	}
	ErrSQSSubGetMessage = func(ctx context.Context, cause error) error {
		return jet.NewAppErrBuilder(ErrCodeSQSSubGetMessage, "subscriber: get message").C(ctx).Wrap(cause).Err()
	}
)

Functions ¶

This section is empty.

Types ¶

type Client ¶

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

func NewClient ¶

func NewClient(awsCfg *jetaws.Config, logger jet.CLoggerFunc) *Client

func (*Client) GetMessages ¶

func (c *Client) GetMessages(ctx context.Context, input *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)

func (*Client) GetQueueURL ¶

func (c *Client) GetQueueURL(ctx context.Context, input *sqs.GetQueueUrlInput) (*sqs.GetQueueUrlOutput, error)

func (*Client) Init ¶

func (c *Client) Init(ctx context.Context) error

type Config ¶

type Config struct {
	FetchInterval     int64 `mapstructure:"fetch_interval"`
	MaxMessages       int32 `mapstructure:"max_messages"`
	VisibilityTimeout int32 `mapstructure:"visibility_timeout"`
}

type Subscriber ¶

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

func NewSubscriber ¶

func NewSubscriber(client *Client, cfg *Config, queueName string, receiver chan types.Message, logger jet.CLoggerFunc) *Subscriber

func (*Subscriber) Run ¶

func (s *Subscriber) Run(ctx context.Context) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL