server

type Config struct {
	// OnInit configuration
	OnInit *OnInitConfig `mapstructure:"on_init"`

	// Command to run as application.
	Command string `mapstructure:"command"`

	// User to run application under.
	User string `mapstructure:"user"`

	// Group to run application under.
	Group string `mapstructure:"group"`

	// Env represents application environment.
	Env map[string]string `mapstructure:"env"`

	// Relay defines connection method and factory to be used to connect to workers:
	// "pipes", "tcp://:6001", "unix://rr.sock"
	// This config section must not change on re-configuration.
	Relay string `mapstructure:"relay"`

	// RelayTimeout defines for how long socket factory will be waiting for worker connection. This config section
	// must not change on re-configuration. Defaults to 60s.
	RelayTimeout time.Duration `mapstructure:"relay_timeout"`
}

type Configurer interface {
	// UnmarshalKey takes a single key and unmarshal it into a Struct.
	UnmarshalKey(name string, out any) error

	// Has checks if config section exists.
	Has(name string) bool
}

type OnInitConfig struct {
	// Command which is started before worker starts
	Command string `mapstructure:"command"`

	// ExecTimeout is execute timeout for the command
	ExecTimeout time.Duration `mapstructure:"exec_timeout"`

	// Env represents application environment.
	Env map[string]string `mapstructure:"env"`
}

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

type Pool interface {
	// GetConfig returns pool configuration.
	GetConfig() *pool.Config

	// Workers returns worker list associated with the pool.
	Workers() (workers []*worker.Process)

	// RemoveWorker removes worker from the pool.
	RemoveWorker(worker *worker.Process) error

	// Exec payload
	Exec(ctx context.Context, p *payload.Payload) (*payload.Payload, error)

	// Reset kill all workers inside the watcher and replaces with new
	Reset(ctx context.Context) error

	// Destroy all underlying stack (but let them to complete the task).
	Destroy(ctx context.Context)
}

type RPCConfig struct {
	Listen string `mapstructure:"listen"`
}