application

Documentation

Index

• func EnvServerHost() string
• func Hostname() string
• type Application
  • func DefaultApp() *Application
  • func New(fns ...func() error) (*Application, error)
  • func (app *Application) Executor(e executor.Executor)
  • func (app *Application) GracefulStop(ctx context.Context) (err error)
  • func (app *Application) Job(runner job.Runner) error
  • func (app *Application) RegisterHooks(stage hooks.Stage, fns ...func())
  • 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
  • func WithConfigParser(unmarshaller conf.Unmarshaller) Option
  • func WithDisable(d Disable) Option
• type RuntimeStats
  • func NewRuntimeStats() RuntimeStats

Functions

func EnvServerHost

func EnvServerHost() string

EnvServerHost gets SANCHIN_APP_HOST.

func Hostname

func Hostname() string

Hostname gets hostname.

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

func DefaultApp() *Application

func New

func New(fns ...func() error) (*Application, error)

New create a new Application instance

func (*Application) Executor

func (app *Application) Executor(e executor.Executor)

Executor ...

func (*Application) GracefulStop

func (app *Application) GracefulStop(ctx context.Context) (err error)

GracefulStop application after necessary cleanup

func (*Application) Job

func (app *Application) Job(runner job.Runner) error

Job ..

func (*Application) RegisterHooks

func (app *Application) RegisterHooks(stage hooks.Stage, fns ...func())

RegisterHooks register a stage Hook

func (*Application) Run

func (app *Application) Run(servers ...server.Server) error

Run run application

func (*Application) Schedule

func (app *Application) Schedule(w worker.Worker) error

Schedule ..

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) Startup

func (app *Application) Startup(fns ...func() error) error

Startup ..

func (*Application) Stop

func (app *Application) Stop() (err error)

Stop application immediately after necessary cleanup

func (*Application) WithOptions

func (a *Application) WithOptions(options ...Option)

type Disable

type Disable int

const (
	DisableParserFlag      Disable = 1
	DisableLoadConfig      Disable = 2
	DisableDefaultGovernor Disable = 3
)

type Option

type Option func(a *Application)

func WithConfigParser

func WithConfigParser(unmarshaller conf.Unmarshaller) Option

func WithDisable

func WithDisable(d Disable) Option

type RuntimeStats

type RuntimeStats struct {
	IP       string `json:"ip"`
	Hostname string `json:"hostname"`
	Time     string `json:"time"` // 每次展示数据的时间
	Err      string `json:"err"`
}

通用状态信息

func NewRuntimeStats

func NewRuntimeStats() RuntimeStats