unifrost: github.com/unifrost/unifrost/drivers/sqsdriver Index | Files

package sqsdriver

import "github.com/unifrost/unifrost/drivers/sqsdriver"

Index

Package Files

sqs.go

type Client Uses

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

Client handles the communicating with SQS. This holds the config provider needed to make the request.

func NewClient Uses

func NewClient(ctx context.Context, session *session.Session, opts ...Option) (*Client, error)

NewClient returns *sqsdriver.Client, establishes session to the AWS cloud service.

Additional configuration options can be added with sqsdriver.Option functions.

func (*Client) Close Uses

func (client *Client) Close(ctx context.Context) error

Close is just a placeholder to close the subscription or topic, `subscription.Shutdown(ctx)` should be called

func (*Client) Subscribe Uses

func (client *Client) Subscribe(ctx context.Context, url string) (*pubsub.Subscription, error)

Subscribe subscribes to the given SQS url

https://docs.aws.amazon.com/sdk-for-net/v2/developer-guide/QueueURL.html

type Option Uses

type Option func(*Client) error

Option is a self-refrential function for configuration parameters

Package sqsdriver imports 5 packages (graph). Updated 2020-01-31. Refresh now. Tools for package owners.