factory

Documentation

Index

• type App
  • func (app *App) Close() error
  • func (app *App) Configure() error
  • func (app *App) Init(provider config.Provider) error
  • func (app *App) NewCmd(env Env) (func() *exec.Cmd, error)
  • func (app *App) NewFactory() (roadrunner.Factory, error)
  • func (app *App) Serve() chan error
  • func (app *App) Stop() error
• type AppConfig
• type Env
• type Spawner
• type WFactory
  • func (wf *WFactory) AddListener(l events.EventListener)
  • func (wf *WFactory) Init(app Spawner) error
  • func (wf *WFactory) NewWorker(ctx context.Context, env Env) (roadrunner.WorkerBase, error)
  • func (wf *WFactory) NewWorkerPool(ctx context.Context, opt *roadrunner.Config, env Env) (roadrunner.Pool, error)
• type WorkerFactory

Types

type App

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

func (*App) Close

func (app *App) Close() error

func (*App) Configure

func (app *App) Configure() error

func (*App) Init

func (app *App) Init(provider config.Provider) error

func (*App) NewCmd

func (app *App) NewCmd(env Env) (func() *exec.Cmd, error)

func (*App) NewFactory

func (app *App) NewFactory() (roadrunner.Factory, error)

todo ENV unused

func (*App) Serve

func (app *App) Serve() chan error

func (*App) Stop

func (app *App) Stop() error

type AppConfig

type AppConfig struct {
	Command string
	User    string
	Group   string
	Env     Env

	Relay string
	// Listen 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.
	Listen string

	// RelayTimeout defines for how long socket factory will be waiting for worker connection. This config section
	// must not change on re-configuration.
	RelayTimeout time.Duration
}

AppConfig config combines factory, pool and cmd configurations.

type Env

type Env map[string]string

type Spawner

type Spawner interface {
	// CmdFactory create new command factory with given env variables.
	NewCmd(env Env) (func() *exec.Cmd, error)

	// NewFactory inits new factory for workers.
	NewFactory(env Env) (roadrunner.Factory, error)
}

type WFactory

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

func (*WFactory) AddListener

func (wf *WFactory) AddListener(l events.EventListener)

func (*WFactory) Init

func (wf *WFactory) Init(app Spawner) error

func (*WFactory) NewWorker

func (wf *WFactory) NewWorker(ctx context.Context, env Env) (roadrunner.WorkerBase, error)

func (*WFactory) NewWorkerPool

func (wf *WFactory) NewWorkerPool(ctx context.Context, opt *roadrunner.Config, env Env) (roadrunner.Pool, error)

type WorkerFactory

type WorkerFactory interface {
	NewWorker(ctx context.Context, env Env) (roadrunner.WorkerBase, error)
	NewWorkerPool(ctx context.Context, opt *roadrunner.Config, env Env) (roadrunner.Pool, error)
}