server

Oct 8, 2026

Changes in this version

+ const PluginName

+ const RPCPluginName

+ const RrRPC

+ const RrRelay

+ const RrVersion

+ type Config struct

+ Command []string

+ Env map[string]string

+ Group string

+ OnInit *InitConfig

+ Relay string

+ RelaySocket *tcplisten.UnixSocketOptions

+ User string

+ func (cfg *Config) InitDefaults() error

+ type Configurer interface

+ Has func(name string) bool

+ RRVersion func() string

+ UnmarshalKey func(name string, out any) error

+ type InitConfig struct

+ Command []string

+ Env map[string]string

+ ExecTimeout time.Duration

+ ExitOnError bool

+ User string

+ type NamedLogger interface

+ NamedLogger func(name string) *slog.Logger

+ type Plugin struct

+ func (p *Plugin) GID() int

+ func (p *Plugin) Init(cfg Configurer, log NamedLogger) error

+ func (p *Plugin) Name() string

+ func (p *Plugin) NewPool(ctx context.Context, cfg *pool.Config, env map[string]string, _ *slog.Logger) (*staticPool.Pool, error)

+ func (p *Plugin) NewPoolWithOptions(ctx context.Context, cfg *pool.Config, env map[string]string, _ *slog.Logger, ...) (*staticPool.Pool, error)

+ func (p *Plugin) NewWorker(ctx context.Context, env map[string]string) (*worker.Process, error)

+ func (p *Plugin) Serve() chan error

+ func (p *Plugin) Stop(_ context.Context) error

+ func (p *Plugin) UID() int

+ type Pool interface

+ AddWorker func() error

+ Destroy func(ctx context.Context)

+ Exec func(ctx context.Context, p *payload.Payload, stopCh chan struct{}) (chan *staticPool.PExec, error)

+ GetConfig func() *pool.Config

+ RemoveWorker func(ctx context.Context) error

+ Reset func(ctx context.Context) error

+ Workers func() (workers []*worker.Process)

+ type RPCConfig struct

+ Listen string