script

package

v0.2.5 Latest Latest Go to latest Published: Jan 6, 2025 License: Apache-2.0 Imports: 20 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 ¶

type Message
type NoScriptFoundError
- func (e *NoScriptFoundError) Error() string
type Reply
- func NewErrReply(err error) *Reply
- func NewReply() *Reply
- func (r *Reply) JSON() ([]byte, error)
type Script
type ScriptExecutor
- func NewScriptExecutor(store msgstore.ScriptStore, plugins []msgplugins.PreloadFunc, nc *nats.Conn) *ScriptExecutor
- func (se *ScriptExecutor) HandleMessage(ctx context.Context, msg *Message, replyFunc func(r *Reply))
- func (se *ScriptExecutor) Stop()
type ScriptResult

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Message ¶ added in v0.2.0

type Message struct {
	Subject string `json:"subject"`
	Payload []byte `json:"payload"`
	Method  string `json:"method"`
	URL     string `json:"url"`
}

type NoScriptFoundError ¶ added in v0.2.3

type NoScriptFoundError struct{}

func (*NoScriptFoundError) Error ¶ added in v0.2.3

func (e *NoScriptFoundError) Error() string

type Reply ¶ added in v0.2.1

type Reply struct {
	Results    sync.Map
	HTML       bool                     `json:"is_html"`
	Error      string                   `json:"error,omitempty"`
	AllResults map[string]*ScriptResult `json:"results,omitempty"`
}

func NewErrReply ¶ added in v0.2.1

func NewErrReply(err error) *Reply

func NewReply ¶ added in v0.2.1

func NewReply() *Reply

func (*Reply) JSON ¶ added in v0.2.1

func (r *Reply) JSON() ([]byte, error)

type Script ¶

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

func (*Script) Read ¶ added in v0.2.3

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

func (*Script) ReadFile ¶ added in v0.2.3

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

func (*Script) ReadString ¶ added in v0.2.3

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

type ScriptExecutor ¶

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

ScriptExecutor defines the structure responsible for managing Lua script execution

func NewScriptExecutor ¶

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

NewScriptExecutor creates a new ScriptExecutor using the provided ScriptStore

func (*ScriptExecutor) HandleMessage ¶

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

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

func (*ScriptExecutor) Stop ¶

func (se *ScriptExecutor) Stop()

Stop gracefully shuts down the ScriptExecutor and stops watching for messages

type ScriptResult ¶ added in v0.2.5

type ScriptResult struct {
	Error   string `json:"error"`
	Payload []byte `json:"payload"`
	IsHTML  bool   `json:"is_html"`
}

Source Files ¶

View all Source files

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