app

Documentation

Index

• type App
  • func New(opts ...Option) *App
  • func (a *App) Run() error
  • func (a *App) Stop() error
• type Option
  • func WithEndpoints(endpoints []*url.URL) Option
  • func WithName(name string) Option
  • func WithRPCServer(server *rpcserver.Server) Option
  • func WithRegistrar(registrar registry.Registrar) Option
  • func WithRegistrarTimeout(registrarTimeout time.Duration) Option
  • func WithRestServer(server *restserver.Server) Option
  • func WithSigs(sigs []os.Signal) Option
  • func WithStopTimeout(stopTimeout time.Duration) Option

Types

type App

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

func New

func New(opts ...Option) *App

New create a new app instance

func (*App) Run

func (a *App) Run() error

Run start the app instance

func (*App) Stop

func (a *App) Stop() error

Stop the app instance

type Option

type Option func(o *options)

func WithEndpoints

func WithEndpoints(endpoints []*url.URL) Option

func WithName

func WithName(name string) Option

func WithRPCServer

func WithRPCServer(server *rpcserver.Server) Option

WithRPCServer allows user to provide own implementation of rpc server

func WithRegistrar

func WithRegistrar(registrar registry.Registrar) Option

WithRegistrar allows user to provide own implementation of registry center

func WithRegistrarTimeout

func WithRegistrarTimeout(registrarTimeout time.Duration) Option

func WithRestServer

func WithRestServer(server *restserver.Server) Option

WithRestServer allows user to provide own implementation of rest server

func WithSigs

func WithSigs(sigs []os.Signal) Option

func WithStopTimeout

func WithStopTimeout(stopTimeout time.Duration) Option