Documentation
¶
Index ¶
- func AddRequestIDToHeaders(requestID *string, headers map[string]string, requestIDHeaderKey string)
- func GetRecord(s3Session *s3.SessionWithHelpers, bucket string, message events.SQSMessage, ...) (interface{}, error)
- func RequestIDFromHeaders(headers map[string]string, requestIDHeaderKey string) *string
- func RequestIDFromLambdaContext(ctx context.Context) *string
- 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)
- type Handler
- type IValidator
- type SQSHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddRequestIDToHeaders ¶
func GetRecord ¶
func GetRecord(s3Session *s3.SessionWithHelpers, bucket string, message events.SQSMessage, recordType reflect.Type) (interface{}, error)
func RequestIDFromHeaders ¶
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 ¶
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 ValidateSQSEndpoints ¶
ValidateSQSEndpoints checks that all SQS endpoints are correctly defined using one of the supported handler types return 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 ¶
type IValidator ¶
type IValidator interface {
Validate() error
}
type SQSHandler ¶
func NewSQSHandler ¶
func NewSQSHandler(fnc interface{}) (SQSHandler, error)
Source Files
Click to show internal directories.
Click to hide internal directories.