executor

package

v0.8.2 Latest Latest Go to latest Published: Oct 25, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/numkem/msgscript

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func StartAllExecutors(ctx context.Context, scriptStore store.ScriptStore, ...) map[string]Executor
func StopAllExecutors(executors map[string]Executor)
type Executor
type LuaExecutor
- func (le *LuaExecutor) HandleMessage(ctx context.Context, msg *Message, scr *script.Script) *ScriptResult
- func (se *LuaExecutor) Stop()
type Message
type NoScriptFoundError
- func (e *NoScriptFoundError) Error() string
type ScriptResult
- func ScriptResultWithError(err error) *ScriptResult

Constants ¶

View Source

const (
	MAX_LUA_RUNNING_TIME = 2 * time.Minute
	EXECUTOR_LUA_NAME    = "lua"
	EXECUTOR_WASM_NAME   = "wasm"
	EXECUTOR_PODMAN_NAME = "podman"
)

Variables ¶

This section is empty.

Functions ¶

func StartAllExecutors ¶ added in v0.5.0

func StartAllExecutors(ctx context.Context, scriptStore store.ScriptStore, plugins []plugins.PreloadFunc, nc *nats.Conn) map[string]Executor

func StopAllExecutors ¶ added in v0.5.0

func StopAllExecutors(executors map[string]Executor)

Types ¶

type Executor ¶

type Executor interface {
	HandleMessage(context.Context, *Message, *script.Script) *ScriptResult
	Stop()
}

func ExecutorByName ¶ added in v0.5.0

func ExecutorByName(name string, executors map[string]Executor) (Executor, error)

func NewLuaExecutor ¶

func NewLuaExecutor(c context.Context, store msgstore.ScriptStore, plugins []msgplugins.PreloadFunc, nc *nats.Conn) Executor

NewLuaExecutor creates a new ScriptExecutor using the provided ScriptStore

func NewPodmanExecutor ¶ added in v0.4.1

func NewPodmanExecutor(c context.Context, store msgstore.ScriptStore) (Executor, error)

func NewWasmExecutor ¶

func NewWasmExecutor(c context.Context, store msgstore.ScriptStore, plugins []msgplugins.PreloadFunc, nc *nats.Conn) Executor

type LuaExecutor ¶

type LuaExecutor struct {
	// contains filtered or unexported fields
}

LuaExecutor defines the structure responsible for managing Lua script execution

func (*LuaExecutor) HandleMessage ¶

func (le *LuaExecutor) HandleMessage(ctx context.Context, msg *Message, scr *script.Script) *ScriptResult

HandleMessage receives a message, matches it to a Lua script, and executes the script in a new goroutine Run the Lua script in a separate goroutine to handle the message for each script

func (*LuaExecutor) Stop ¶

func (se *LuaExecutor) Stop()

Stop gracefully shuts down the ScriptExecutor and stops watching for messages

type Message ¶

type Message struct {
	Async    bool   `json:"async"`
	Executor string `json:"executor"`
	Method   string `json:"method"`
	Payload  []byte `json:"payload"`
	Raw      bool   `json:"raw"`
	Subject  string `json:"subject"`
	URL      string `json:"url"`
}

type NoScriptFoundError ¶

type NoScriptFoundError struct{}

func (*NoScriptFoundError) Error ¶

func (e *NoScriptFoundError) Error() string

type ScriptResult ¶

type ScriptResult struct {
	Code    int               `json:"http_code"`
	Error   string            `json:"error"`
	Headers map[string]string `json:"http_headers"`
	IsHTML  bool              `json:"is_html"`
	Payload []byte            `json:"payload"`
}

func ScriptResultWithError ¶ added in v0.8.0

func ScriptResultWithError(err error) *ScriptResult

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL