handler

Documentation

Index

• type DBClient
• type SQS
  • func NewSQS(sqsClient SQSClient, dbClient DBClient) SQS
  • func (h SQS) Run() error
• type SQSClient

Types

type DBClient

type DBClient interface {
	Save(item domain.Event) error
}

type SQS

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

func NewSQS

func NewSQS(sqsClient SQSClient, dbClient DBClient) SQS

func (SQS) Run

func (h SQS) Run() error

type SQSClient

type SQSClient interface {
	Receive() (*sqs.ReceiveMessageOutput, error)
	Delete(receiptHandle string) error
}