handler_utils

Documentation

Index

• Constants
• func AddRequestIDToHeaders(requestID *string, responseHeaders map[string]string, ...)
• func FindHeaderValue(headers map[string]string, key string) string
• func GetRecord(s3Client *s3.ClientWithHelpers, bucket string, message events.SQSMessage, ...) (interface{}, error)
• func RequestIDFromHeaders(headers map[string]string, requestIDHeaderKey string) *string
• func RequestIDFromLambdaContext(ctx context.Context) *string
• func ServeHTTPFunctions(ctx context.Context, lambdaHandler lambda.Handler, w http.ResponseWriter, ...)
• func ServeSQSFunctions(ctx context.Context, lambdaHandler lambda.Handler, w http.ResponseWriter, ...)
• func SignAWSHttpRequest(request *http.Request, accessKeyID, secretAccessKey string, ...) error
• func SignAWSRestyClient(client *resty.Client, accessKeyID, secretAccessKey string, bodyBytes []byte) error
• func ValidateAPIEndpoints(endpoints map[string]map[string]interface{}) (map[string]map[string]interface{}, error)
• func ValidateCronHandlers(handlers map[string]func() error) (map[string]func() error, error)
• func ValidateRequestParams(request *events.APIGatewayProxyRequest, paramsStructType reflect.Type) (reflect.Value, error)
• func ValidateSQSEndpoints(endpoints map[string]interface{}) (map[string]interface{}, error)
• func ValidateWebsocketEndpoints(endpoints map[string]interface{}) (map[string]interface{}, error)
• type Handler
  • func NewHandler(handlerFunction interface{}) (Handler, error)
• type IValidator
• type SQSHandler
  • func NewSQSHandler(fnc interface{}) (SQSHandler, error)

Constants

const HTTPXRequestIDHeaderKey = "X-Request-ID"

Functions

func AddRequestIDToHeaders

func AddRequestIDToHeaders(requestID *string, responseHeaders map[string]string, requestIDHeaderKey string, requestHeaders map[string]string)

func FindHeaderValue

func FindHeaderValue(headers map[string]string, key string) string

func GetRecord

func GetRecord(s3Client *s3.ClientWithHelpers, bucket string, message events.SQSMessage, recordType reflect.Type) (interface{}, error)

func RequestIDFromHeaders

func RequestIDFromHeaders(headers map[string]string, requestIDHeaderKey string) *string

func RequestIDFromLambdaContext

func RequestIDFromLambdaContext(ctx context.Context) *string

func ServeHTTPFunctions

func ServeHTTPFunctions(ctx context.Context, lambdaHandler lambda.Handler, w http.ResponseWriter, req *http.Request)

func ServeSQSFunctions

func ServeSQSFunctions(ctx context.Context, lambdaHandler lambda.Handler, w http.ResponseWriter, req *http.Request)

func SignAWSHttpRequest

func SignAWSHttpRequest(request *http.Request, accessKeyID, secretAccessKey string, bodySeeker io.ReadSeeker) error

SignAWSRequest wraps and executes http.NewRequest and adds a sig version 4 signature for AWS API Gateway

func SignAWSRestyClient

func SignAWSRestyClient(client *resty.Client, accessKeyID, secretAccessKey string, bodyBytes []byte) error

func ValidateAPIEndpoints

func ValidateAPIEndpoints(endpoints map[string]map[string]interface{}) (map[string]map[string]interface{}, error)

ValidateAPIEndpoints checks that all API endpoints are correctly defined using one of the supported handler types return updated endpoints with additional information

func ValidateCronHandlers

func ValidateCronHandlers(handlers map[string]func() error) (map[string]func() error, error)

ValidateCronHandlers checks that all handlers are correctly defined using one of the supported handler types return updated handlers (with additional information -> N/A for cron)

func ValidateRequestParams

func ValidateRequestParams(request *events.APIGatewayProxyRequest, paramsStructType reflect.Type) (reflect.Value, error)

func ValidateSQSEndpoints

func ValidateSQSEndpoints(endpoints map[string]interface{}) (map[string]interface{}, error)

ValidateSQSEndpoints checks that all SQS endpoints are correctly defined using one of the supported handler types return updated endpoints with additional information

func ValidateWebsocketEndpoints

func ValidateWebsocketEndpoints(endpoints map[string]interface{}) (map[string]interface{}, error)

ValidateWebsocketEndpoints checks that all websocket endpoints are correctly defined using one of the supported handler types and returns updated endpoints with additional information

Types

type Handler

type Handler struct {
	RequestParamsType reflect.Type
	RequestBodyType   reflect.Type
	ResponseType      reflect.Type
	FuncValue         reflect.Value
}

func NewHandler

func NewHandler(handlerFunction interface{}) (Handler, error)

type IValidator

type IValidator interface {
	Validate() error
}

type SQSHandler

type SQSHandler struct {
	RecordType reflect.Type
	FuncValue  reflect.Value
}

func NewSQSHandler

func NewSQSHandler(fnc interface{}) (SQSHandler, error)