runner

package
v0.3.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 25, 2020 License: MIT Imports: 7 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HTTPServerLifecycle

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

HTTPServerLifecycle TODO

func ServGo added in v0.2.0

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

ServGo TODO

func ServWait added in v0.2.0

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

ServWait TODO

Types

type HTTPServ added in v0.2.0

type HTTPServ struct {
	*http.Server
}

HTTPServ TODO

func (*HTTPServ) OnStart added in v0.2.0

func (serv *HTTPServ) OnStart(ctx context.Context) error

OnStart TODO

func (*HTTPServ) OnStop added in v0.2.0

func (serv *HTTPServ) OnStop(ctx context.Context) error

OnStop TODO

type Runner added in v0.0.17

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

Runner TODO

func New added in v0.0.17

func New() *Runner

New TODO

func (*Runner) AddReady added in v0.2.0

func (runner *Runner) AddReady() *sync.WaitGroup

AddReady TODO

func (*Runner) Fail added in v0.0.17

func (runner *Runner) Fail(err error)

Fail TODO

func (*Runner) PopReady added in v0.2.0

func (runner *Runner) PopReady() *sync.WaitGroup

PopReady TODO

func (*Runner) Run added in v0.0.17

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

Run TODO

func (*Runner) WaitFail added in v0.0.17

func (runner *Runner) WaitFail() chan error

WaitFail TODO

func (*Runner) WaitReady added in v0.0.17

func (runner *Runner) WaitReady()

WaitReady TODO

Jump to

Keyboard shortcuts

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