script

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
  • func (s *Script) Read(f io.Reader) error
  • func (s *Script) ReadFile(filename string) error
  • func (s *Script) ReadString(str string) error
• 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()

Types

type Message

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

type NoScriptFoundError

type NoScriptFoundError struct{}

func (*NoScriptFoundError) Error

func (e *NoScriptFoundError) Error() string

type Reply

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

func NewErrReply

func NewErrReply(err error) *Reply

func NewReply

func NewReply() *Reply

func (*Reply) JSON

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

type Script

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

func (*Script) Read

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

func (*Script) ReadFile

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

func (*Script) ReadString

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