app

Documentation

Index

• Constants
• func GetMessages(c context.Context, api SQSReceiveMessageAPI, input *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)
• func GetQueueURL(c context.Context, api SQSReceiveMessageAPI, input *sqs.GetQueueUrlInput) (*sqs.GetQueueUrlOutput, error)
• func StartServer(serviceConfig *ServiceConfig) *http.Server
• type Application
• type EnvConfig
• type SQSReceiveMessageAPI
• type SQSReceiveMessageImpl
• type ServiceConfig

Constants

const QueueName = "thing-payloads"

const Version = "0.0.1"

Functions

func GetMessages

func GetMessages(c context.Context, api SQSReceiveMessageAPI, input *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)

func GetQueueURL

func GetQueueURL(c context.Context, api SQSReceiveMessageAPI, input *sqs.GetQueueUrlInput) (*sqs.GetQueueUrlOutput, error)

func StartServer

func StartServer(serviceConfig *ServiceConfig) *http.Server

Types

type Application

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

type EnvConfig

type EnvConfig struct {
	Port int
	Env  string
	Dsn  string
}

type SQSReceiveMessageAPI

type SQSReceiveMessageAPI interface {
	GetQueueUrl(ctx context.Context,
		params *sqs.GetQueueUrlInput,
		optFns ...func(*sqs.Options)) (*sqs.GetQueueUrlOutput, error)

	ReceiveMessage(ctx context.Context,
		params *sqs.ReceiveMessageInput,
		optFns ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)
}

type SQSReceiveMessageImpl

type SQSReceiveMessageImpl struct{}

type ServiceConfig

type ServiceConfig struct {
	EnvConfig              EnvConfig
	SqsReceiveMessageInput *sqs.ReceiveMessageInput
	SqsClient              SQSReceiveMessageAPI
	DbClient               *sql.DB
	Logger                 *log.Logger
	Models                 data.Models
}