backend

Documentation

Overview

Package backend forwards requests to SQS and HTTP.

Index

• func HTTPBackend(ctx context.Context, tracer trace.Tracer, backendURL string, body io.Reader) error
• func SqsListener(app *SqsApplication)
• func SqsSend(ctx context.Context, tracer trace.Tracer, queue SqsQueue, ...)
• type SqsApplication
• type SqsQueue
  • func NewSqsClient(caller, queueURL, roleArn, roleSessionName, endpointURL string) SqsQueue

Functions

func HTTPBackend

func HTTPBackend(ctx context.Context, tracer trace.Tracer, backendURL string, body io.Reader) error

HTTPBackend forwards body to http backend.

func SqsListener

func SqsListener(app *SqsApplication)

SqsListener runs sqs application.

func SqsSend

func SqsSend(ctx context.Context, tracer trace.Tracer, queue SqsQueue, sqsMessage types.Message)

SqsSend only submits message to SQS. attribute with traceID must have been set in sqsMessage.

Types

type SqsApplication

type SqsApplication struct {
	QueueInput  SqsQueue
	QueueOutput SqsQueue
	Tracer      trace.Tracer
	BackendURL  string
	Debug       bool
}

SqsApplication holds sqs application.

type SqsQueue

type SqsQueue struct {
	SqsClient *sqs.Client
	URL       string
}

SqsQueue holds sqs client.

func NewSqsClient

func NewSqsClient(caller, queueURL, roleArn, roleSessionName, endpointURL string) SqsQueue

NewSqsClient creates sqs client.