executor

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

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

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

type NoScriptFoundError struct{}

type Reply struct {
	Results []*ScriptResult `json:"script_result"`
	HTML    bool            `json:"is_html"`
	Error   string          `json:"error,omitempty"`
}

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"`
}

type WorkerInput struct {
	NatsURL     string                  `json:"nats_url"`
	ScriptStore *WorkerInputScriptStore `json:"script_store"`
	LuaExecutor *WorkerInputLuaExecutor `json:"lua_executor"`
	Message     *Message                `json:"messsage"`
}

type WorkerInputLuaExecutor struct {
	PluginDir string `json:"plugin_dir"`
}

type WorkerInputScriptStore struct {
	BackendName      string `json:"backend_name"`
	EtcdURL          string `json:"etcd_url"`
	ScriptDirectory  string `json:"script_directory"`
	LibraryDirectory string `json:"library_directory"`
}

type WorkerOutput struct {
	Error error  `json:"error"`
	Reply *Reply `json:"reply"`
}