Documentation ¶
Index ¶
- Constants
- type Application
- func (app *Application) GracefulStop(ctx context.Context) (err error)
- func (app *Application) Job(runner job.Runner) error
- func (app *Application) RegisterHooks(k uint32, fns ...func() error) error
- func (app *Application) Run(servers ...server.Server) error
- func (app *Application) Schedule(w worker.Worker) error
- func (app *Application) Serve(s ...server.Server) error
- func (app *Application) SetRegistry(reg registry.Registry)
- func (app *Application) Startup(fns ...func() error) error
- func (app *Application) Stop() (err error)
- func (a *Application) WithOptions(options ...Option)
- type Disable
- type Option
Constants ¶
View Source
const ( //StageAfterStop after app stop StageAfterStop uint32 = iota + 1 //StageBeforeStop before app stop StageBeforeStop )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Application ¶
type Application struct { HideBanner bool // contains filtered or unexported fields }
Application is the framework's instance, it contains the servers, workers, client and configuration settings. Create an instance of Application, by using &Application{}
func DefaultApp ¶ added in v0.2.4
func DefaultApp() *Application
func New ¶ added in v0.2.0
func New(fns ...func() error) (*Application, error)
New new a Application
func (*Application) GracefulStop ¶
func (app *Application) GracefulStop(ctx context.Context) (err error)
GracefulStop application after necessary cleanup
func (*Application) Job ¶ added in v0.2.0
func (app *Application) Job(runner job.Runner) error
Job ..
func (*Application) RegisterHooks ¶ added in v0.2.0
func (app *Application) RegisterHooks(k uint32, fns ...func() error) error
RegisterHooks register a stage Hook
func (*Application) Run ¶
func (app *Application) Run(servers ...server.Server) error
Run run application
func (*Application) Serve ¶
func (app *Application) Serve(s ...server.Server) error
Serve start server
func (*Application) SetRegistry ¶
func (app *Application) SetRegistry(reg registry.Registry)
SetRegistry set customize registry
func (*Application) Stop ¶
func (app *Application) Stop() (err error)
Stop application immediately after necessary cleanup
func (*Application) WithOptions ¶ added in v0.2.4
func (a *Application) WithOptions(options ...Option)
type Option ¶ added in v0.2.4
type Option func(a *Application)
func WithConfigParser ¶ added in v0.2.4
func WithConfigParser(unmarshaller conf.Unmarshaller) Option
func WithDisable ¶ added in v0.2.4
Directories ¶
Path | Synopsis |
---|---|
cmd
|
|
jupiter
Module
|
|
protoc-gen-go-echo
Module
|
|
protoc-gen-go-gin
Module
|
|
example
module
|
|
util/xbuffer
Package buffer provides an implementation of an unbounded buffer.
|
Package buffer provides an implementation of an unbounded buffer. |
util/xtime
https://github.com/siddontang/go/tree/master/time2
|
https://github.com/siddontang/go/tree/master/time2 |
server/xfasthttp
Module
|
|
util/xgeneric
Module
|
|
test
|
|
e2e
Module
|
|
tools
|
|
jupiter
Module
|
Click to show internal directories.
Click to hide internal directories.