script

Documentation

Index

• Variables
• type LuamdaEndpoints
• type LuamdaReader
  • func (l *LuamdaReader) Read(f io.Reader) error
  • func (l *LuamdaReader) ReadFile(filename string) error
  • func (l *LuamdaReader) ReadString(str string) error
• type Script
• type ScriptExecutor
  • func NewScriptExecutor(store msgstore.ScriptStore, plugins []msgplugins.PreloadFunc, nc *nats.Conn) *ScriptExecutor
  • func (se *ScriptExecutor) HandleMessage(ctx context.Context, subject string, payload []byte, replyFunc func(string))
  • func (se *ScriptExecutor) Stop()
• type ScriptReader
  • func (s *ScriptReader) Read(f io.Reader) error
  • func (s *ScriptReader) ReadFile(filename string) error
  • func (s *ScriptReader) ReadString(str string) error

Variables

var LUAMDA_HTTP_VERBS = [7]string{
	http.MethodDelete,
	http.MethodGet,
	http.MethodHead,
	http.MethodOptions,
	http.MethodPatch,
	http.MethodPost,
	http.MethodPut,
}

Types

type LuamdaEndpoints

type LuamdaEndpoints struct {
	GET     []string
	POST    []string
	PUT     []string
	PATCH   []string
	DELETE  []string
	HEAD    []string
	OPTIONS []string
}

type LuamdaReader

type LuamdaReader struct {
	Endpoints *LuamdaEndpoints
}

func (*LuamdaReader) Read

func (l *LuamdaReader) Read(f io.Reader) error

func (*LuamdaReader) ReadFile

func (l *LuamdaReader) ReadFile(filename string) error

func (*LuamdaReader) ReadString

func (l *LuamdaReader) ReadString(str string) error

type Script

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

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, subject string, payload []byte, replyFunc func(string))

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 ScriptReader

type ScriptReader struct {
	Script *Script
}

func (*ScriptReader) Read

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

func (*ScriptReader) ReadFile

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

func (*ScriptReader) ReadString

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