Documentation ¶
Index ¶
- func GetSourceEvent(ctx context.Context) any
- func NewAPIGatewayV1Handler(delegate AdapterFunc) ...
- func NewAPIGatewayV2Handler(delegate AdapterFunc) ...
- func NewBase64WriteCloser(field *string) io.WriteCloser
- func NewFunctionURLHandler(delegate AdapterFunc) ...
- func WithSourceEvent(ctx context.Context, event any) context.Context
- type APIGwV1RequestAdapter
- func (adapter APIGwV1RequestAdapter) ConsumeHeader(consumer HeaderConsumer)
- func (adapter APIGwV1RequestAdapter) ConsumeTrailer(consumer HeaderConsumer)
- func (adapter APIGwV1RequestAdapter) GetBody() io.ReadCloser
- func (adapter APIGwV1RequestAdapter) GetMethod() string
- func (adapter APIGwV1RequestAdapter) GetProto() string
- func (adapter APIGwV1RequestAdapter) GetRemoteAddr() string
- func (adapter APIGwV1RequestAdapter) GetURI() string
- type APIGwV1ResponseAdapter
- func (adapter *APIGwV1ResponseAdapter) AddHeader(k string, v string)
- func (adapter *APIGwV1ResponseAdapter) AddTrailer(k string, v string)
- func (adapter *APIGwV1ResponseAdapter) GetBodyWriter() io.WriteCloser
- func (adapter *APIGwV1ResponseAdapter) SetHeader(k string, v []string)
- func (adapter *APIGwV1ResponseAdapter) SetStatusCode(status int)
- func (adapter *APIGwV1ResponseAdapter) SetTrailer(k string, v []string)
- type APIGwV2RequestAdapter
- func (adapter APIGwV2RequestAdapter) ConsumeHeader(consumer HeaderConsumer)
- func (adapter APIGwV2RequestAdapter) ConsumeTrailer(consumer HeaderConsumer)
- func (adapter APIGwV2RequestAdapter) GetBody() io.ReadCloser
- func (adapter APIGwV2RequestAdapter) GetMethod() string
- func (adapter APIGwV2RequestAdapter) GetProto() string
- func (adapter APIGwV2RequestAdapter) GetRemoteAddr() string
- func (adapter APIGwV2RequestAdapter) GetURI() string
- type APIGwV2ResponseAdapter
- func (adapter *APIGwV2ResponseAdapter) AddHeader(k string, v string)
- func (adapter *APIGwV2ResponseAdapter) AddTrailer(k string, v string)
- func (adapter *APIGwV2ResponseAdapter) GetBodyWriter() io.WriteCloser
- func (adapter *APIGwV2ResponseAdapter) SetHeader(k string, v []string)
- func (adapter *APIGwV2ResponseAdapter) SetStatusCode(status int)
- func (adapter *APIGwV2ResponseAdapter) SetTrailer(k string, v []string)
- type AdapterFunc
- type FunctionURLRequestAdapter
- func (adapter FunctionURLRequestAdapter) ConsumeHeader(consumer HeaderConsumer)
- func (adapter FunctionURLRequestAdapter) ConsumeTrailer(consumer HeaderConsumer)
- func (adapter FunctionURLRequestAdapter) GetBody() io.ReadCloser
- func (adapter FunctionURLRequestAdapter) GetMethod() string
- func (adapter FunctionURLRequestAdapter) GetProto() string
- func (adapter FunctionURLRequestAdapter) GetRemoteAddr() string
- func (adapter FunctionURLRequestAdapter) GetURI() string
- type FunctionURLResponseAdapter
- func (adapter *FunctionURLResponseAdapter) AddHeader(k string, v string)
- func (adapter *FunctionURLResponseAdapter) AddTrailer(k string, v string)
- func (adapter *FunctionURLResponseAdapter) GetBodyWriter() io.WriteCloser
- func (adapter *FunctionURLResponseAdapter) SetHeader(k string, v []string)
- func (adapter *FunctionURLResponseAdapter) SetStatusCode(status int)
- func (adapter *FunctionURLResponseAdapter) SetTrailer(k string, v []string)
- type HeaderConsumer
- type RequestAdapter
- type ResponseAdapter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetSourceEvent ¶
func NewAPIGatewayV1Handler ¶
func NewAPIGatewayV1Handler(delegate AdapterFunc) func(context.Context, events.APIGatewayProxyRequest) (events.APIGatewayProxyResponse, error)
func NewAPIGatewayV2Handler ¶
func NewAPIGatewayV2Handler(delegate AdapterFunc) func(context.Context, events.APIGatewayV2HTTPRequest) (events.APIGatewayV2HTTPResponse, error)
func NewBase64WriteCloser ¶
func NewBase64WriteCloser(field *string) io.WriteCloser
func NewFunctionURLHandler ¶
func NewFunctionURLHandler(delegate AdapterFunc) func(context.Context, events.LambdaFunctionURLRequest) (events.LambdaFunctionURLResponse, error)
Types ¶
type APIGwV1RequestAdapter ¶
type APIGwV1RequestAdapter events.APIGatewayProxyRequest
func (APIGwV1RequestAdapter) ConsumeHeader ¶
func (adapter APIGwV1RequestAdapter) ConsumeHeader(consumer HeaderConsumer)
func (APIGwV1RequestAdapter) ConsumeTrailer ¶
func (adapter APIGwV1RequestAdapter) ConsumeTrailer(consumer HeaderConsumer)
func (APIGwV1RequestAdapter) GetBody ¶
func (adapter APIGwV1RequestAdapter) GetBody() io.ReadCloser
func (APIGwV1RequestAdapter) GetMethod ¶
func (adapter APIGwV1RequestAdapter) GetMethod() string
func (APIGwV1RequestAdapter) GetProto ¶
func (adapter APIGwV1RequestAdapter) GetProto() string
func (APIGwV1RequestAdapter) GetRemoteAddr ¶
func (adapter APIGwV1RequestAdapter) GetRemoteAddr() string
func (APIGwV1RequestAdapter) GetURI ¶
func (adapter APIGwV1RequestAdapter) GetURI() string
type APIGwV1ResponseAdapter ¶
type APIGwV1ResponseAdapter events.APIGatewayProxyResponse
func (*APIGwV1ResponseAdapter) AddHeader ¶
func (adapter *APIGwV1ResponseAdapter) AddHeader(k string, v string)
func (*APIGwV1ResponseAdapter) AddTrailer ¶
func (adapter *APIGwV1ResponseAdapter) AddTrailer(k string, v string)
func (*APIGwV1ResponseAdapter) GetBodyWriter ¶
func (adapter *APIGwV1ResponseAdapter) GetBodyWriter() io.WriteCloser
func (*APIGwV1ResponseAdapter) SetHeader ¶
func (adapter *APIGwV1ResponseAdapter) SetHeader(k string, v []string)
func (*APIGwV1ResponseAdapter) SetStatusCode ¶
func (adapter *APIGwV1ResponseAdapter) SetStatusCode(status int)
func (*APIGwV1ResponseAdapter) SetTrailer ¶
func (adapter *APIGwV1ResponseAdapter) SetTrailer(k string, v []string)
type APIGwV2RequestAdapter ¶
type APIGwV2RequestAdapter events.APIGatewayV2HTTPRequest
func (APIGwV2RequestAdapter) ConsumeHeader ¶
func (adapter APIGwV2RequestAdapter) ConsumeHeader(consumer HeaderConsumer)
func (APIGwV2RequestAdapter) ConsumeTrailer ¶
func (adapter APIGwV2RequestAdapter) ConsumeTrailer(consumer HeaderConsumer)
func (APIGwV2RequestAdapter) GetBody ¶
func (adapter APIGwV2RequestAdapter) GetBody() io.ReadCloser
func (APIGwV2RequestAdapter) GetMethod ¶
func (adapter APIGwV2RequestAdapter) GetMethod() string
func (APIGwV2RequestAdapter) GetProto ¶
func (adapter APIGwV2RequestAdapter) GetProto() string
func (APIGwV2RequestAdapter) GetRemoteAddr ¶
func (adapter APIGwV2RequestAdapter) GetRemoteAddr() string
func (APIGwV2RequestAdapter) GetURI ¶
func (adapter APIGwV2RequestAdapter) GetURI() string
type APIGwV2ResponseAdapter ¶
type APIGwV2ResponseAdapter events.APIGatewayV2HTTPResponse
func (*APIGwV2ResponseAdapter) AddHeader ¶
func (adapter *APIGwV2ResponseAdapter) AddHeader(k string, v string)
func (*APIGwV2ResponseAdapter) AddTrailer ¶
func (adapter *APIGwV2ResponseAdapter) AddTrailer(k string, v string)
func (*APIGwV2ResponseAdapter) GetBodyWriter ¶
func (adapter *APIGwV2ResponseAdapter) GetBodyWriter() io.WriteCloser
func (*APIGwV2ResponseAdapter) SetHeader ¶
func (adapter *APIGwV2ResponseAdapter) SetHeader(k string, v []string)
func (*APIGwV2ResponseAdapter) SetStatusCode ¶
func (adapter *APIGwV2ResponseAdapter) SetStatusCode(status int)
func (*APIGwV2ResponseAdapter) SetTrailer ¶
func (adapter *APIGwV2ResponseAdapter) SetTrailer(k string, v []string)
type AdapterFunc ¶
type AdapterFunc func(ctx context.Context, req RequestAdapter, res ResponseAdapter) error
func NewVanillaAdapter ¶
func NewVanillaAdapter(delegate http.Handler) AdapterFunc
type FunctionURLRequestAdapter ¶
type FunctionURLRequestAdapter events.LambdaFunctionURLRequest
func (FunctionURLRequestAdapter) ConsumeHeader ¶
func (adapter FunctionURLRequestAdapter) ConsumeHeader(consumer HeaderConsumer)
func (FunctionURLRequestAdapter) ConsumeTrailer ¶
func (adapter FunctionURLRequestAdapter) ConsumeTrailer(consumer HeaderConsumer)
func (FunctionURLRequestAdapter) GetBody ¶
func (adapter FunctionURLRequestAdapter) GetBody() io.ReadCloser
func (FunctionURLRequestAdapter) GetMethod ¶
func (adapter FunctionURLRequestAdapter) GetMethod() string
func (FunctionURLRequestAdapter) GetProto ¶
func (adapter FunctionURLRequestAdapter) GetProto() string
func (FunctionURLRequestAdapter) GetRemoteAddr ¶
func (adapter FunctionURLRequestAdapter) GetRemoteAddr() string
func (FunctionURLRequestAdapter) GetURI ¶
func (adapter FunctionURLRequestAdapter) GetURI() string
type FunctionURLResponseAdapter ¶
type FunctionURLResponseAdapter events.LambdaFunctionURLResponse
func (*FunctionURLResponseAdapter) AddHeader ¶
func (adapter *FunctionURLResponseAdapter) AddHeader(k string, v string)
func (*FunctionURLResponseAdapter) AddTrailer ¶
func (adapter *FunctionURLResponseAdapter) AddTrailer(k string, v string)
func (*FunctionURLResponseAdapter) GetBodyWriter ¶
func (adapter *FunctionURLResponseAdapter) GetBodyWriter() io.WriteCloser
func (*FunctionURLResponseAdapter) SetHeader ¶
func (adapter *FunctionURLResponseAdapter) SetHeader(k string, v []string)
func (*FunctionURLResponseAdapter) SetStatusCode ¶
func (adapter *FunctionURLResponseAdapter) SetStatusCode(status int)
func (*FunctionURLResponseAdapter) SetTrailer ¶
func (adapter *FunctionURLResponseAdapter) SetTrailer(k string, v []string)
type RequestAdapter ¶
type RequestAdapter interface { GetMethod() string GetURI() string GetProto() string GetRemoteAddr() string ConsumeHeader(consumer HeaderConsumer) ConsumeTrailer(consumer HeaderConsumer) GetBody() io.ReadCloser }
Click to show internal directories.
Click to hide internal directories.