Versions in this module Expand all Collapse all v0 v0.1.0 Oct 2, 2026 Changes in this version + var ErrCleanup = errors.New("edge: request cleanup failure") + var ErrIdentity = errors.New("edge: identity failure") + var ErrInvalidEvent = errors.New("edge: invalid event") + var ErrInvalidInvocation = errors.New("edge: invalid invocation") + var ErrLimitExceeded = errors.New("edge: resource limit exceeded") + var ErrResponse = errors.New("edge: response failure") + var ErrStream = errors.New("edge: stream failure") + var ErrUnsupportedEvent = errors.New("edge: unsupported event") + type Adapter struct + func New(handler http.Handler, opts ...Option) (*Adapter, error) + func (a *Adapter) HandleV1(ctx context.Context, event events.APIGatewayProxyRequest) (events.APIGatewayProxyResponse, error) + func (a *Adapter) HandleV2(ctx context.Context, event events.APIGatewayV2HTTPRequest) (events.APIGatewayV2HTTPResponse, error) + func (a *Adapter) Invoke(ctx context.Context, payload []byte) ([]byte, error) + type InvocationError struct + func (e *InvocationError) Error() string + func (e *InvocationError) Limit() (resource Resource, maximum int64, ok bool) + func (e *InvocationError) Operation() Operation + func (e *InvocationError) Unwrap() error + type Operation string + const OperationCleanup + const OperationDecode + const OperationEncode + const OperationIdentity + const OperationRequest + const OperationResponse + const OperationStream + const OperationValidate + type Option func(*config) + func WithGatewayIdentity(enabled bool) Option + func WithIdentityClaimsBudget(bytes int) Option + func WithResponseHeaderBudget(bytes int) Option + func WithStreamErrorReporter(report func(context.Context, error)) Option + type Resource string + const ResourceBufferedBody + const ResourceBufferedEnvelope + const ResourceIdentityClaims + const ResourceResponseHeaders + const ResourceStreamMetadata + type StreamingAdapter struct + func NewStreaming(handler http.Handler, opts ...Option) (*StreamingAdapter, error) + func (a *StreamingAdapter) Handle(ctx context.Context, event jsontext.Value) (io.ReadCloser, error) + func (a *StreamingAdapter) HandleV1(ctx context.Context, event events.APIGatewayProxyRequest) (io.ReadCloser, error)
Go to main page