setup

Documentation

Index

• func QueueMessageInput(log *log.Logger, client *sqs.SQS, queueURL *string)
• type SQS
  • func NewEnv(region, queueName string) (env *SQS, teardown func() error, err error)

Functions

func QueueMessageInput

func QueueMessageInput(log *log.Logger, client *sqs.SQS, queueURL *string)

QueueMessageInput listens to text on stdin and sends it to the SQS queue for the poller to receive.

Types

type SQS

type SQS struct {
	Client *sqs.SQS
	Queue  *string
}

SQS contains the SQS resources needed to set up a Poller.

func NewEnv

func NewEnv(region, queueName string) (env *SQS, teardown func() error, err error)

NewEnv will set up the a new environment for the playground, a local SQS instance will be returned when it is ready to be interacted with. A teardown function is also returned, which should be executed once the caller is done with the SQS instance.