sns

Documentation

Index

• type Config
• type Publisher
  • func New(cfg Config) *Publisher
  • func (p *Publisher) Publish(ctx context.Context, msg json.Marshaler) error

Types

type Config

type Config struct {

	// AWS session
	AWSSession *session.Session

	// SQS queue where the publisher is going to push messages to
	QueueURL string
}

Config holds the info required to work with AWS SQS to publish a message

type Publisher

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

Publisher is the AWS SNS message publisher

func New

func New(cfg Config) *Publisher

New creates a new AWS SQS publisher

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, msg json.Marshaler) error

Publish allows SQS Publisher to implement the publisher.Publisher interface and publish messages to an AWS SQS backend