core

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 24, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package core provides utility methods that help convert proxy events into an http.Request and http.ResponseWriter

Package core provides utility methods that help convert proxy events into an http.Request and http.ResponseWriter

Index

Constants

View Source
const APIGwContextHeader = "X-GoLambdaProxy-ApiGw-Context"

APIGwContextHeader is the custom header key used to store the API Gateway context. To access the Context properties use the GetAPIGatewayContext method of the RequestAccessor object.

View Source
const CustomHostVariable = "GO_API_HOST"

CustomHostVariable is the name of the environment variable that contains the custom hostname for the request. If this variable is not set the framework reverts to `DefaultServerAddress`. The value for a custom host should include a protocol: http://my-custom.host.com

View Source
const DefaultServerAddress = "https://tencent-serverless-go-api.com"

DefaultServerAddress is prepended to the path of each incoming reuqest

Variables

This section is empty.

Functions

func GatewayTimeout

func GatewayTimeout() events.APIGatewayResponse

GatewayTimeout returns a dafault Gateway Timeout (504) response

func GetAPIGatewayContextFromContext

func GetAPIGatewayContextFromContext(ctx context.Context) (events.APIGatewayRequestContext, bool)

GetAPIGatewayContextFromContext retrieve APIGatewayProxyRequestContext from context.Context

func GetRuntimeContextFromContext

func GetRuntimeContextFromContext(ctx context.Context) (*functioncontext.FunctionContext, bool)

GetRuntimeContextFromContext retrieve Lambda Runtime Context from context.Context

func NewLoggedError

func NewLoggedError(format string, a ...interface{}) error

NewLoggedError generates a new error and logs it to stdout

Types

type ProxyResponseWriter

type ProxyResponseWriter struct {
	// contains filtered or unexported fields
}

ProxyResponseWriter implements http.ResponseWriter and adds the method necessary to return an events.APIGatewayProxyResponse object

func NewProxyResponseWriter

func NewProxyResponseWriter() *ProxyResponseWriter

NewProxyResponseWriter returns a new ProxyResponseWriter object. The object is initialized with an empty map of headers and a status code of -1

func (*ProxyResponseWriter) Flush

func (r *ProxyResponseWriter) Flush()

Flush flush

func (*ProxyResponseWriter) GetProxyResponse

func (r *ProxyResponseWriter) GetProxyResponse() (events.APIGatewayResponse, error)

GetProxyResponse converts the data passed to the response writer into an events.APIGatewayProxyResponse object. Returns a populated proxy response object. If the response is invalid, for example has no headers or an invalid status code returns an error.

func (*ProxyResponseWriter) Header

func (r *ProxyResponseWriter) Header() http.Header

Header implementation from the http.ResponseWriter interface.

func (*ProxyResponseWriter) Write

func (r *ProxyResponseWriter) Write(body []byte) (int, error)

Write sets the response body in the object. If no status code was set before with the WriteHeader method it sets the status for the response to 200 OK.

func (*ProxyResponseWriter) WriteHeader

func (r *ProxyResponseWriter) WriteHeader(status int)

WriteHeader sets a status code for the response. This method is used for error responses.

type RequestAccessor

type RequestAccessor struct {
	// contains filtered or unexported fields
}

RequestAccessor objects give access to custom API Gateway properties in the request.

func (*RequestAccessor) EventToRequest

func (r *RequestAccessor) EventToRequest(req events.APIGatewayRequest) (*http.Request, error)

EventToRequest converts an API Gateway proxy event into an http.Request object. Returns the populated request maintaining headers

func (*RequestAccessor) EventToRequestWithContext

func (r *RequestAccessor) EventToRequestWithContext(ctx context.Context, req events.APIGatewayRequest) (*http.Request, error)

EventToRequestWithContext converts an API Gateway proxy event and context into an http.Request object. Returns the populated http request with lambda context, stage variables and APIGatewayProxyRequestContext as part of its context. Access those using GetAPIGatewayContextFromContext, GetStageVarsFromContext and GetRuntimeContextFromContext functions in this package.

func (*RequestAccessor) GetAPIGatewayContext

func (r *RequestAccessor) GetAPIGatewayContext(req *http.Request) (events.APIGatewayRequestContext, error)

GetAPIGatewayContext extracts the API Gateway context object from a request's custom header. Returns a populated events.APIGatewayProxyRequestContext object from the request.

func (*RequestAccessor) ProxyEventToHTTPRequest

func (r *RequestAccessor) ProxyEventToHTTPRequest(req events.APIGatewayRequest) (*http.Request, error)

ProxyEventToHTTPRequest converts an API Gateway proxy event into a http.Request object. Returns the populated http request with additional two custom headers for the stage variables and API Gateway context. To access these properties use the GetAPIGatewayStageVars and GetAPIGatewayContext method of the RequestAccessor object.

func (*RequestAccessor) StripBasePath

func (r *RequestAccessor) StripBasePath(basePath string) string

StripBasePath instructs the RequestAccessor object that the given base path should be removed from the request path before sending it to the framework for routing. This is used when API Gateway is configured with base path mappings in custom domain names.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL