testutils

Documentation

Index

• func DestinationConfig(queueName string) config.Config
• func NewSQSClient(ctx context.Context, is *is.I) (*sqs.Client, func())
• func SourceConfig(queueName string) config.Config
• func StartDestination(ctx context.Context, is *is.I, d sdk.Destination, queueName string) (sdk.Destination, func())
• func StartSource(ctx context.Context, is *is.I, s sdk.Source, queueName string) (sdk.Source, func())
• func TestContext(t *testing.T) context.Context
• type TestQueue
  • func CreateTestFifoQueue(ctx context.Context, t *testing.T, is *is.I, client *sqs.Client) TestQueue
  • func CreateTestQueue(ctx context.Context, t *testing.T, is *is.I, client *sqs.Client) TestQueue

Functions

func DestinationConfig

func DestinationConfig(queueName string) config.Config

func NewSQSClient

func NewSQSClient(ctx context.Context, is *is.I) (*sqs.Client, func())

func SourceConfig

func SourceConfig(queueName string) config.Config

func StartDestination

func StartDestination(
	ctx context.Context,
	is *is.I,
	d sdk.Destination,
	queueName string,
) (sdk.Destination, func())

func StartSource

func StartSource(ctx context.Context, is *is.I, s sdk.Source, queueName string) (sdk.Source, func())

func TestContext

func TestContext(t *testing.T) context.Context

Types

type TestQueue

type TestQueue struct {
	Name string

	// pointer string makes it easier to work with the aws sdk
	URL *string
}

func CreateTestFifoQueue

func CreateTestFifoQueue(ctx context.Context, t *testing.T, is *is.I, client *sqs.Client) TestQueue

func CreateTestQueue

func CreateTestQueue(ctx context.Context, t *testing.T, is *is.I, client *sqs.Client) TestQueue