runner

Documentation

Index

• func HTTPServerLifecycle(lc fx.Lifecycle, server *http.Server, runner *Runner)
• func ServeFlowLifecycle(lc fx.Lifecycle, serv serv.IServ, runner *Runner)
• type Runner
  • func New() *Runner
  • func (runner *Runner) Fail(err error)
  • func (runner *Runner) Ready()
  • func (runner *Runner) Run(app *fx.App)
  • func (runner *Runner) WaitFail() chan error
  • func (runner *Runner) WaitReady() chan struct{}

Functions

func HTTPServerLifecycle

func HTTPServerLifecycle(lc fx.Lifecycle, server *http.Server, runner *Runner)

HTTPServerLifecycle TODO

func ServeFlowLifecycle

func ServeFlowLifecycle(lc fx.Lifecycle, serv serv.IServ, runner *Runner)

ServeFlowLifecycle TODO

Types

type Runner

type Runner struct {
	messagebus.MessageBus
	// contains filtered or unexported fields
}

Runner TODO

func New

func New() *Runner

New TODO

func (*Runner) Fail

func (runner *Runner) Fail(err error)

Fail TODO

func (*Runner) Ready

func (runner *Runner) Ready()

Ready TODO

func (*Runner) Run

func (runner *Runner) Run(app *fx.App)

Run TODO

func (*Runner) WaitFail

func (runner *Runner) WaitFail() chan error

WaitFail TODO

func (*Runner) WaitReady

func (runner *Runner) WaitReady() chan struct{}

WaitReady TODO