Versions in this module Expand all Collapse all v0 v0.2.1 Oct 9, 2026 v0.2.0 Oct 8, 2026 Changes in this version + const FunctionNameEnvVar + const HandlerKindEnvVar + const Name + const SplitHeadersEnvVar + var SplitHeaders = []string + func ManagementEndpoint(payload []byte) (string, error) + type Adapter struct + func New() *Adapter + func (a *Adapter) AcknowledgeReceipt(ctx context.Context, msg *handler.WebSocketMessage) error + func (a *Adapter) Detect() bool + func (a *Adapter) Mapper() serverless.EventMapper + func (a *Adapter) Name() string + func (a *Adapter) Start(ctx context.Context, invoke serverless.Invoker) error + func (a *Adapter) WebSocketSender(_ context.Context, payload []byte) (handler.WebSocketSender, error) + type Mapper struct + func NewMapper() Mapper + func (m Mapper) Detect(payload []byte) (handler.Kind, error) + func (m Mapper) FromBatchResult(res *handler.BatchResult) (any, error) + func (m Mapper) FromCustomResult(res *handler.CustomInvokeResult) (any, error) + func (m Mapper) FromResponse(res *handler.Response) (any, error) + func (m Mapper) ToConsumerBatch(payload []byte, tag string) (*handler.ConsumerBatch, error) + func (m Mapper) ToCustomInvoke(payload []byte) (*handler.CustomInvoke, error) + func (m Mapper) ToRequest(payload []byte) (*handler.Request, error) + func (m Mapper) ToScheduleTrigger(payload []byte, tag string) (*handler.ScheduleTrigger, error) + func (m Mapper) ToWebSocketMessage(payload []byte) (*handler.WebSocketMessage, error)
Go to main page