aws

package

v0.4.0 Latest Latest Go to latest Published: Apr 11, 2021 License: MIT Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

func CreateConfig(port int, region string) *aws.Config

type Container struct {
	SqsService *SqsService
	// contains filtered or unexported fields
}

Container metadata to load a container for aws environment

func NewContainer(p Params) *Container

NewContainer creates a new instance of Container

func (c *Container) AfterStart(ctx context.Context, r *dockertest.Resource) error

AfterStart will wait until the container is ready to be consumed

func (c *Container) Options() (*dockertest.RunOptions, error)

Options to start a localstack container accordingly to the params

type Params struct {
	goit.ContainerParams
	Region    string
	Port      int
	SqsQueues []SqsQueue
}

Params needed to start a aws container

type SqsQueue struct {
	Name string
}

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

func (s SqsService) Receive(qn string) ([]*sqs.Message, error)

func (s SqsService) Send(qn string, m *sqs.Message) error