Versions in this module Expand all Collapse all v0 v0.4.1 Aug 30, 2025 Changes in this version + const EXECUTOR_PODMAN_NAME type Message + Async bool + type PodmanExecutor struct + ConnText context.Context + func NewPodmanExecutor(ctx context.Context, store msgstore.ScriptStore) (*PodmanExecutor, error) + func (pe *PodmanExecutor) HandleMessage(ctx context.Context, msg *Message, replyFunc ReplyFunc) + func (pe *PodmanExecutor) Stop() + type ReplyFunc func(r *Reply) v0.4.0 Jul 29, 2025 Changes in this version + const EXECUTOR_LUA_NAME + const EXECUTOR_WASM_NAME + const MAX_LUA_RUNNING_TIME + type Executor interface + HandleMessage func(context.Context, *Message, func(*Reply)) + Stop func() + func NewLuaExecutor(store msgstore.ScriptStore, plugins []msgplugins.PreloadFunc, nc *nats.Conn) Executor + func NewWasmExecutor(store msgstore.ScriptStore, plugins []msgplugins.PreloadFunc, nc *nats.Conn) Executor + type LuaExecutor struct + func (le *LuaExecutor) HandleMessage(ctx context.Context, msg *Message, replyFunc func(r *Reply)) + func (se *LuaExecutor) Stop() + type Message struct + Executor string + Method string + Payload []byte + Raw bool + Subject string + URL string + type NoScriptFoundError struct + func (e *NoScriptFoundError) Error() string + type Reply struct + AllResults map[string]*ScriptResult + Error string + HTML bool + Results sync.Map + func NewErrReply(err error) *Reply + func NewReply() *Reply + func (r *Reply) Bytes() []byte + func (r *Reply) JSON() ([]byte, error) + type ScriptResult struct + Code int + Error string + Headers map[string]string + IsHTML bool + Payload []byte + type WasmExecutor struct + func (we *WasmExecutor) HandleMessage(ctx context.Context, msg *Message, replyFunc func(r *Reply)) + func (we *WasmExecutor) Stop()
Go to main page