nodejs

Mar 20, 2025

Changes in this version

+ type Context struct

+ func (c *Context) Close() error

+ func (c *Context) Eval(ctx context.Context, code string, opts map[string]any) (any, error)

+ func (c *Context) EvalChannel(code string, opts map[string]any) (chan map[string]any, error)

+ func (c *Context) ID() string

+ func (c *Context) ServeHTTPToHandler(handlerFunc string, w http.ResponseWriter, r *http.Request)

+ type HTTPHandlerOptions struct

+ Context string

type Process

+ func (p *Process) NewContext() (*Context, error)

+ func (p *Process) ServeHTTPToHandler(handlerFunc string, w http.ResponseWriter, r *http.Request)

+ func (p *Process) ServeHTTPWithOptions(handlerFunc string, options HTTPHandlerOptions, w http.ResponseWriter, ...)

Jun 23, 2024

Changes in this version

type Pool

+ Timeout time.Duration

Jun 21, 2024

Changes in this version

type Factory

+ func (factory *Factory) NewWithTimeout(timeout time.Duration) (*Process, error)

Mar 18, 2024

Changes in this version

+ var ErrDeadProcess = errors.New("nodejs: process has died")

type Process

+ func (p *Process) EvalChannel(code string, opts map[string]any) (chan map[string]any, error)

Mar 17, 2024

Changes in this version

+ const CREATE_NO_WINDOW — windows/amd64

+ var ErrTimeout = errors.New("nodejs: timeout reached")

+ type Factory struct

+ func New() (*Factory, error)

+ func (f *Factory) NewPool(queueSize, maxProcs int) *Pool

+ func (factory *Factory) New() (*Process, error)

+ type IpcFunc func(map[string]any) (any, error)

+ type Message struct

+ Action string

+ Data pjson.RawMessage

+ Id int64

+ type Pool struct

+ func (pool *Pool) Take(ctx context.Context) (*Process, error)

+ func (pool *Pool) TakeIfAvailable() *Process

+ func (pool *Pool) TakeTimeout(t time.Duration) (*Process, error)

+ type Process struct

+ func (p *Process) Alive() <-chan struct{}

+ func (p *Process) Checkpoint(timeout time.Duration) error

+ func (p *Process) Close() error

+ func (p *Process) Console() []byte

+ func (p *Process) Eval(code string, opts map[string]interface{}) (interface{}, error)

+ func (p *Process) GetVersion(what string) string

+ func (p *Process) Kill()

+ func (p *Process) Log(msg string, args ...interface{})

+ func (p *Process) MakeResponse() (string, chan map[string]interface{})

+ func (p *Process) Run(code string, opts map[string]interface{})

+ func (p *Process) Set(v string, val interface{})

+ func (p *Process) SetContext(ctx context.Context)

+ func (p *Process) SetIPC(name string, f IpcFunc)