node

package

Go to main page

Versions in this module

v0

v0.18.1

Feb 24, 2026

v0.18.0

Feb 21, 2026

Changes in this version

type Client

+ func (c *Client) ServerPayloadEnter(e *am.Event) bool

+ func (c *Client) ServerPayloadState(e *am.Event)

v0.17.2

Feb 20, 2026

v0.17.1

Jan 18, 2026

v0.17.0

Dec 22, 2025

Changes in this version

type Client

+ RpcSuper *rpc.Client

+ RpcWorker *rpc.Client

type ClientOpts

+ ClientSchema am.Schema

+ ClientStates am.S

v0.16.2

Dec 5, 2025

v0.16.1

Nov 23, 2025

v0.16.0

Nov 11, 2025

v0.15.2

Oct 19, 2025

v0.15.1

Oct 1, 2025

v0.15.0

Sep 22, 2025

v0.14.0-pre1

Aug 17, 2025

v0.13.0

Jul 9, 2025

v0.12.0

Jun 26, 2025

v0.11.0

May 1, 2025

v0.10.3

Apr 13, 2025

v0.10.2

Feb 25, 2025

v0.10.1

Feb 15, 2025

Changes in this version

+ const APrefix

v0.10.0

Jan 16, 2025

Changes in this version

type A

+ WorkerAddr string

+ WorkerInfo *workerInfo

+ WorkerRpc *rpc.Client

+ WorkerState WorkerState

+ WorkersCh chan<- []*workerInfo

type Supervisor

+ OpTimeout time.Duration

+ WorkerCheckInterval time.Duration

+ func (s *Supervisor) ListWorkersEnter(e *am.Event) bool

+ func (s *Supervisor) ListWorkersState(e *am.Event)

+ func (s *Supervisor) SetWorkerEnter(e *am.Event) bool

+ func (s *Supervisor) SetWorkerState(e *am.Event)

+ func (s *Supervisor) Workers(ctx context.Context, state WorkerState) ([]*workerInfo, error)

+ type WorkerState string

+ const StateBusy

+ const StateIdle

+ const StateIniting

+ const StateReady

+ const StateRpc

v0.9.1

Jan 14, 2025

v0.9.0

Dec 15, 2024

Changes in this version

+ var ErrHeartbeat = errors.New("heartbeat failed")

+ func GetSuperClientId(name string) string

+ func GetWorkerClientId(name string) string

type A

+ BootAddr string

+ SuperRpcId string

+ WorkerRpcId string

type ARpc

+ BootAddr string

+ SuperRpcId string

+ WorkerRpcId string

type Client

+ func (c *Client) WorkerReadyState(e *am.Event)

type ClientOpts

+ Tags []string

type Supervisor

+ HealthcheckState am.HandlerFinal

+ KillWorkerState am.HandlerFinal

+ TestFork func(string) error

+ TestKill func(string) error

+ func (s *Supervisor) WorkerConnectedEnter(e *am.Event) bool

+ func (s *Supervisor) WorkerConnectedState(e *am.Event)

type SupervisorOpts

+ Tags []string

type WorkerOpts

+ Tags []string

v0.8.1

Dec 14, 2024

v0.8.0

Nov 13, 2024

Changes in this version

+ const EnvAmNodeLogClient

+ const EnvAmNodeLogSupervisor

+ var ErrPool = errors.New("pool error")

+ var ErrRpc = errors.New("rpc error")

+ var ErrWorker = errors.New("worker error")

+ var ErrWorkerConn = errors.New("error starting connection")

+ var ErrWorkerHealth = errors.New("worker failed healthcheck")

+ var ErrWorkerKill = errors.New("error killing worker")

+ var ErrWorkerMissing = errors.New("worker missing")

+ func AddErrPool(mach *am.Machine, err error, args am.A)

+ func AddErrPoolStr(mach *am.Machine, msg string, args am.A)

+ func AddErrRpc(mach *am.Machine, err error, args am.A)

+ func AddErrWorker(mach *am.Machine, err error, args am.A)

+ func AddErrWorkerStr(mach *am.Machine, msg string, args am.A)

+ func GetClientId(name string) string

+ func GetRpcClientId(name string) string

+ func LogArgs(args am.A) map[string]string

+ func Pass(args *A) am.A

+ func PassRpc(args *A) am.A

+ type A struct

+ Bootstrap *bootstrap

+ ClientAddr string

+ Dispose bool

+ Id string

+ LocalAddr string

+ NodesList []string

+ PublicAddr string

+ Worker *rpc.Client

+ func ParseArgs(args am.A) *A

+ type ARpc struct

+ ClientAddr string

+ Id string

+ LocalAddr string

+ NodesList []string

+ PublicAddr string

+ type Client struct

+ ConnTimeout time.Duration

+ LeaveSuper bool

+ LogEnabled bool

+ Mach *am.Machine

+ Name string

+ SuperAddr string

+ SuperRpc *rpc.Client

+ WorkerRpc *rpc.Client

+ func NewClient(ctx context.Context, id string, workerKind string, stateDeps *ClientStateDeps, ...) (*Client, error)

+ func (c *Client) Dispose(ctx context.Context)

+ func (c *Client) ReqWorker(ctx context.Context) error

+ func (c *Client) Start(nodesList []string)

+ func (c *Client) StartEnd(e *am.Event)

+ func (c *Client) StartEnter(e *am.Event) bool

+ func (c *Client) StartState(e *am.Event)

+ func (c *Client) Stop(ctx context.Context)

+ func (c *Client) WorkerPayloadEnter(e *am.Event) bool

+ func (c *Client) WorkerPayloadState(e *am.Event)

+ func (c *Client) WorkerRequestedEnter(e *am.Event) bool

+ func (c *Client) WorkerRequestedState(e *am.Event)

+ type ClientOpts struct

+ Parent am.Api

+ type ClientStateDeps struct

+ ClientSNames am.S

+ ClientSStruct am.Struct

+ WorkerSNames am.S

+ WorkerSStruct am.Struct

+ type Supervisor struct

+ ClientSendPayloadState am.HandlerFinal

+ ConnTimeout time.Duration

+ DeliveryTimeout time.Duration

+ HealthcheckPause time.Duration

+ Heartbeat time.Duration

+ LocalAddr string

+ LocalRpc *rpc.Server

+ LogEnabled bool

+ Mach *am.Machine

+ Max int

+ MaxClientWorkers int

+ Min int

+ Name string

+ PoolPause time.Duration

+ PublicAddr string

+ PublicMux *rpc.Mux

+ PublicRpcs map[string]*rpc.Server

+ SuperSendPayloadState am.HandlerFinal

+ Warm int

+ WorkerBin []string

+ WorkerErrKill int

+ WorkerErrRecent time.Duration

+ WorkerErrTtl time.Duration

+ WorkerGoneState am.HandlerFinal

+ WorkerKind string

+ WorkerReadyState am.HandlerFinal

+ func NewSupervisor(ctx context.Context, workerKind string, workerBin []string, ...) (*Supervisor, error)

+ func (s *Supervisor) AllWorkers() []*workerInfo

+ func (s *Supervisor) AwaitingWorkerEnter(e *am.Event) bool

+ func (s *Supervisor) AwaitingWorkerState(e *am.Event)

+ func (s *Supervisor) BusyWorkers() []*workerInfo

+ func (s *Supervisor) CheckPool() bool

+ func (s *Supervisor) ClientConnectedState(e *am.Event)

+ func (s *Supervisor) ClientDisconnectedEnter(e *am.Event) bool

+ func (s *Supervisor) ClientDisconnectedState(e *am.Event)

+ func (s *Supervisor) Dispose()

+ func (s *Supervisor) ErrWorkerState(e *am.Event)

+ func (s *Supervisor) ForkWorkerEnter(e *am.Event) bool

+ func (s *Supervisor) ForkWorkerState(e *am.Event)

+ func (s *Supervisor) ForkingWorkerEnter(e *am.Event) bool

+ func (s *Supervisor) ForkingWorkerState(e *am.Event)

+ func (s *Supervisor) HeartbeatState(e *am.Event)

+ func (s *Supervisor) IdleWorkers() []*workerInfo

+ func (s *Supervisor) InitingWorkers() []*workerInfo

+ func (s *Supervisor) KillingWorkerEnter(e *am.Event) bool

+ func (s *Supervisor) KillingWorkerState(e *am.Event)

+ func (s *Supervisor) NormalizingPoolState(e *am.Event)

+ func (s *Supervisor) PoolReadyEnter(e *am.Event) bool

+ func (s *Supervisor) PoolReadyExit(e *am.Event) bool

+ func (s *Supervisor) ProvideWorkerEnter(e *am.Event) bool

+ func (s *Supervisor) ProvideWorkerState(e *am.Event)

+ func (s *Supervisor) ReadyWorkers() []*workerInfo

+ func (s *Supervisor) RpcWorkers() []*workerInfo

+ func (s *Supervisor) SetPool(min, max, warm, maxPerClient int)

+ func (s *Supervisor) Start(publicAddr string)

+ func (s *Supervisor) StartEnd(e *am.Event)

+ func (s *Supervisor) StartEnter(e *am.Event) bool

+ func (s *Supervisor) StartState(e *am.Event)

+ func (s *Supervisor) Stop()

+ func (s *Supervisor) WorkerForkedEnter(e *am.Event) bool

+ func (s *Supervisor) WorkerForkedState(e *am.Event)

+ func (s *Supervisor) WorkerKilledEnter(e *am.Event) bool

+ func (s *Supervisor) WorkerKilledState(e *am.Event)

+ type SupervisorOpts struct

+ InstanceNum int

+ Parent am.Api

+ type Worker struct

+ AcceptClient string

+ BootAddr string

+ BootRpc *rpc.Client

+ ConnTimeout time.Duration

+ DeliveryTimeout time.Duration

+ Kind string

+ LocalAddr string

+ LocalRpc *rpc.Server

+ Mach *am.Machine

+ Name string

+ PublicAddr string

+ PublicRpc *rpc.Server

+ func NewWorker(ctx context.Context, kind string, workerStruct am.Struct, stateNames am.S, ...) (*Worker, error)

+ func (w *Worker) ErrNetworkState(e *am.Event)

+ func (w *Worker) HealthcheckState(e *am.Event)

+ func (w *Worker) LocalRpcReadyState(e *am.Event)

+ func (w *Worker) PublicRpcReadyState(e *am.Event)

+ func (w *Worker) RpcReadyState(e *am.Event)

+ func (w *Worker) SendPayloadEnter(e *am.Event) bool

+ func (w *Worker) ServeClientEnter(e *am.Event) bool

+ func (w *Worker) ServeClientState(e *am.Event)

+ func (w *Worker) Start(localAddr string) am.Result

+ func (w *Worker) StartEnd(e *am.Event)

+ func (w *Worker) StartEnter(e *am.Event) bool

+ func (w *Worker) StartState(e *am.Event)

+ func (w *Worker) Stop(dispose bool)

+ type WorkerOpts struct

+ Parent am.Api

v0.8.0-pre

Nov 13, 2024

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