script

package

v0.2.0 Latest Latest Go to latest Published: Oct 15, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Message struct {
	Subject string
	Payload []byte
	Method  string
	URL     string
}

type Script struct {
	Name    string
	Subject string
	Content []byte
	LibKeys []string
}

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

ScriptExecutor defines the structure responsible for managing Lua script execution

func NewScriptExecutor(store msgstore.ScriptStore, plugins []msgplugins.PreloadFunc, nc *nats.Conn) *ScriptExecutor

NewScriptExecutor creates a new ScriptExecutor using the provided ScriptStore

func (se *ScriptExecutor) HandleMessage(ctx context.Context, msg *Message, replyFunc func(string))

HandleMessage receives a message, matches it to a Lua script, and executes the script in a new goroutine

func (se *ScriptExecutor) Stop()

Stop gracefully shuts down the ScriptExecutor and stops watching for messages

type ScriptReader struct {
	Script *Script
}

func (s *ScriptReader) Read(f io.Reader) error

func (s *ScriptReader) ReadFile(filename string) error

func (s *ScriptReader) ReadString(str string) error