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 ¶
View Source
const QueueName = "thing-payloads"
View Source
const Version = "0.0.1"
Variables ¶
This section is empty.
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 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 }
Click to show internal directories.
Click to hide internal directories.