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 HandlerIDEnvVar + const HandlerTagEnvVar + var ErrNoHandler = errors.New("celerity: no handler for event") + func Register(adapter Adapter) + func Registered() []string + func Serve(ctx context.Context, adapter Adapter, resolver Resolver) error + func WebSocketSenderFrom(ctx context.Context) (handler.WebSocketSender, bool) + func WithWebSocketSender(ctx context.Context, s handler.WebSocketSender) context.Context + type Adapter interface + Detect func() bool + Mapper func() EventMapper + Name func() string + Start func(ctx context.Context, invoke Invoker) error + func Detected() (Adapter, bool) + type EventMapper interface + Detect func(payload []byte) (handler.Kind, error) + FromBatchResult func(res *handler.BatchResult) (any, error) + FromCustomResult func(res *handler.CustomInvokeResult) (any, error) + FromResponse func(res *handler.Response) (any, error) + ToConsumerBatch func(payload []byte, tag string) (*handler.ConsumerBatch, error) + ToCustomInvoke func(payload []byte) (*handler.CustomInvoke, error) + ToRequest func(payload []byte) (*handler.Request, error) + ToScheduleTrigger func(payload []byte, tag string) (*handler.ScheduleTrigger, error) + ToWebSocketMessage func(payload []byte) (*handler.WebSocketMessage, error) + type Handler struct + Invoke layer.Next + Kind handler.Kind + Name string + Tag string + type Invoker func(ctx context.Context, payload []byte) (any, error) + func NewInvoker(adapter Adapter, resolver Resolver) Invoker + type MissingAdapterError struct + Linked []string + func (e *MissingAdapterError) Error() string + type ReceiptAcknowledger interface + AcknowledgeReceipt func(ctx context.Context, msg *handler.WebSocketMessage) error + type Resolver interface + ByName func(name string) (*Handler, bool) + ByTag func(tag string) (*Handler, bool) + Only func(kind handler.Kind) (*Handler, bool) + type WebSocketSenderProvider interface + WebSocketSender func(ctx context.Context, payload []byte) (handler.WebSocketSender, error)
Go to main page