sqsexporter

Documentation

Index

• type Exporter
  • func (f *Exporter) Export(ctx context.Context, _ *fflog.FFLogger, events []exporter.ExportableEvent) error
  • func (f *Exporter) IsBulk() bool
• type SQSSendMessageAPI

Types

type Exporter

type Exporter struct {
	// QueueURL is the URL of your SQS queue
	// (mandatory)
	QueueURL string

	// AwsConfig is the AWS SDK configuration object we will use to
	// upload your exported data files.
	AwsConfig *aws.Config
	// contains filtered or unexported fields
}

func (*Exporter) Export

func (f *Exporter) Export(
	ctx context.Context,
	_ *fflog.FFLogger,
	events []exporter.ExportableEvent,
) error

Export is sending SQS event for each events received.

func (*Exporter) IsBulk

func (f *Exporter) IsBulk() bool

type SQSSendMessageAPI

type SQSSendMessageAPI interface {
	SendMessage(ctx context.Context,
		params *sqs.SendMessageInput,
		optFns ...func(*sqs.Options)) (*sqs.SendMessageOutput, error)
}

SQSSendMessageAPI defines the interface for the GetQueueUrl and SendMessage functions. We use this interface to test the functions using a mocked service.