aws

Nov 6, 2024

Changes in this version

+ var DEBUGDumpPayload = os.Getenv("DEBUG_DUMP_PAYLOAD")

+ var LambdaInvokeMode = os.Getenv("LAMBDA_INVOKE_MODE")

+ var WebsocketResponseMode = os.Getenv("WEBSOCKET_RESPONSE_MODE")

+ type HandlerFunc func(ctx context.Context, payload json.RawMessage) (res any, err error)

type LambdaIntegrationType

+ const LambdaFunctionURLIntegration

Oct 31, 2024

Changes in this version

+ const DefaultNonHTTPEventPath

+ func NewLambdaPassthroughRequest(ctx context.Context, payload []byte, eventPath string, contentType string) (r *http.Request, err error)

type LambdaHandler

+ func (l *LambdaHandler) HandleNonHTTPEvent(ctx context.Context, event []byte, contentType string) ([]byte, error)

type LambdaHandlerOption

+ func WithNonHTTPEventPath(path string) LambdaHandlerOption

+ func WithoutNonHTTPEventPassThrough() LambdaHandlerOption

Oct 7, 2021

Changes in this version

+ func GetStageVariables(ctx context.Context) map[string]string

Oct 5, 2021

Changes in this version

+ func ExpandPathParameters(s string, parameters map[string]string) string

+ func StripBasePath(next http.Handler) http.Handler

Sep 14, 2021

Changes in this version

+ type APIGatewayManagementAPI interface

+ PostToConnection func(ctx context.Context, connectionID string, data []byte) (err error)

+ func NewAPIGatewayManagementClientV1(sess *session.Session, domain, stage string) APIGatewayManagementAPI

+ func NewAPIGatewayManagementClientV2(conf *aws.Config, domain, stage string) APIGatewayManagementAPI

type LambdaHandler

+ func (l *LambdaHandler) ProvideAPIGatewayClient(ctx context.Context, request *events.APIGatewayWebsocketProxyRequest) (client APIGatewayManagementAPI, err error)

type LambdaHandlerOption

+ func WithAWSConfigProvider(sp SDKConfigProvider) LambdaHandlerOption

+ type SDKConfigProvider func(ctx context.Context) (aws.Config, error)

Feb 28, 2021

Changes in this version

+ var DefaultRouteSelectionExpression = "$request.body.action"

+ var DefaultWebsocketPathPrefix = "websocket"

+ func ExpandJSONPath(s string, obj interface{}) string

+ func GetWebsocketRequestContext(ctx context.Context) (req *events.APIGatewayWebsocketProxyRequestContext, ok bool)

+ func NewAPIGatewayManagementClient(sess *session.Session, domain, stage string) *apigatewaymanagementapi.ApiGatewayManagementApi

+ func NewLambdaHandlerWithOption(h http.Handler, options []interface{}) lambda.Handler

+ func NewWebsocketRequest(ctx context.Context, e *events.APIGatewayWebsocketProxyRequest, ...) (r *http.Request, multiValue bool, err error)

+ func RouteSelector(req *events.APIGatewayWebsocketProxyRequest, expression string) (route string, err error)

+ func StripStageVar(next http.Handler) http.Handler

+ func WebsocketResponse(w *WebsocketResponseWriter, multiValue bool) (r *events.APIGatewayProxyResponse, err error)

+ func WebsocketRouter(next http.Handler, routeExpression string) http.Handler

type LambdaHandler

+ func (l *LambdaHandler) InvokeWebsocketAPI(ctx context.Context, request *events.APIGatewayWebsocketProxyRequest) (r *events.APIGatewayProxyResponse, err error)

+ type LambdaHandlerOption func(handler *LambdaHandler)

+ func WithAWSSessionProvider(sp SDKSessionProvider) LambdaHandlerOption

type LambdaIntegrationType

+ const APIGatewayWebsocketIntegration

+ type SDKSessionProvider func() (*session.Session, error)

+ type WebsocketResponseWriter struct

+ func NewWebsocketResponseWriter(ctx context.Context, client *apigatewaymanagementapi.ApiGatewayManagementApi, ...) *WebsocketResponseWriter

+ func (w *WebsocketResponseWriter) CloseNotify() <-chan bool

+ func (w *WebsocketResponseWriter) Done()

+ func (w *WebsocketResponseWriter) Header() http.Header

+ func (w *WebsocketResponseWriter) Write(i []byte) (int, error)

+ func (w *WebsocketResponseWriter) WriteHeader(statusCode int)

Feb 17, 2021

Changes in this version

+ func GetALBTargetGroupRequestContext(ctx context.Context) *events.ALBTargetGroupRequestContext

+ func GetProxyRequestContext(ctx context.Context) *events.APIGatewayProxyRequestContext

+ func GetRawRequestContext(ctx context.Context) interface

+ func GetV2HTTPRequestContext(ctx context.Context) *events.APIGatewayV2HTTPRequestContext

Apr 30, 2020

Changes in this version

+ func ALBTargetResponse(w *ResponseWriter, multiValue bool) (r *events.ALBTargetGroupResponse, err error)

+ func LambdaDetector() bool

+ func NewALBTargetGroupRequest(ctx context.Context, e *events.ALBTargetGroupRequest) (r *http.Request, multiValue bool, err error)

+ func NewHTTPAPIRequest(ctx context.Context, e *events.APIGatewayV2HTTPRequest) (r *http.Request, err error)

+ func NewLambdaAdaptor(addr string, h http.Handler) types.Adaptor

+ func NewLambdaHandler(h http.Handler) lambda.Handler

+ func NewRESTAPIRequest(ctx context.Context, e *events.APIGatewayProxyRequest) (r *http.Request, multiValue bool, err error)

+ func RESTAPITargetResponse(w *ResponseWriter, multiValue bool) (r *events.APIGatewayProxyResponse, err error)

+ type APIGatewayV2HTTPResponse struct

+ Body string

+ Headers map[string]string

+ IsBase64Encoded bool

+ StatusCode int

+ func HTTPAPIResponse(w *ResponseWriter) (r *APIGatewayV2HTTPResponse, err error)

+ type LambdaAdaptor struct

+ func (l LambdaAdaptor) ListenAndServe() error

+ func (l LambdaAdaptor) Shutdown(ctx context.Context) error

+ type LambdaHandler struct

+ func (l LambdaHandler) Invoke(ctx context.Context, payload []byte) ([]byte, error)

+ func (l LambdaHandler) InvokeALBTargetGroup(ctx context.Context, request *events.ALBTargetGroupRequest) (r *events.ALBTargetGroupResponse, err error)

+ func (l LambdaHandler) InvokeHTTPAPI(ctx context.Context, e *events.APIGatewayV2HTTPRequest) (r *APIGatewayV2HTTPResponse, err error)

+ func (l LambdaHandler) InvokeRESTAPI(ctx context.Context, e *events.APIGatewayProxyRequest) (r *events.APIGatewayProxyResponse, err error)

+ type LambdaIntegrationType int

+ const ALBTargetGroupIntegration

+ const APIGatewayHTTPIntegration

+ const APIGatewayRESTIntegration

+ const UnknownLambdaIntegrationType

+ type ResponseWriter struct

+ func NewResponseWriter() *ResponseWriter

+ func (r *ResponseWriter) CloseNotify() <-chan bool

+ func (r *ResponseWriter) Done()

+ func (r *ResponseWriter) Header() http.Header

+ func (r *ResponseWriter) Write(i []byte) (int, error)

+ func (r *ResponseWriter) WriteHeader(statusCode int)