apps

Dec 29, 2022

Changes in this version

type Api

+ func (app *Api) Ready() (ok bool)

+ type ApiApp interface

+ GetGinEngine func() (engine *gin.Engine)

+ GetHttpServer func() (svr *http.Server)

+ Ready func() (ok bool)

+ type Docker struct

+ func GetDocker(opts ...DockerOption) *Docker

+ func NewDocker(opts ...DockerOption) *Docker

+ func (app *Docker) GetParent() (parent ServerApp)

+ func (app *Docker) Init()

+ func (app *Docker) Ready() (ok bool)

+ func (app *Docker) SetParent(parent ServerApp)

+ func (app *Docker) Start()

+ func (app *Docker) Stop()

+ func (app *Docker) Wait()

+ type DockerApp interface

+ GetParent func() (parent ServerApp)

+ Ready func() (ok bool)

+ SetParent func(parent ServerApp)

+ type DockerOption func(dck DockerApp)

+ func WithDockerParent(parent ServerApp) DockerOption

+ type Server struct

+ func (app *Server) GetApi() (api *Api)

+ func (app *Server) GetNodeService() (svc interfaces.NodeService)

+ func (app *Server) Init()

+ func (app *Server) SetGrpcAddress(address interfaces.Address)

+ func (app *Server) Start()

+ func (app *Server) Stop()

+ func (app *Server) Wait()

+ type ServerApp interface

+ GetApi func() (api *Api)

+ GetNodeService func() (masterSvc interfaces.NodeService)

+ func GetServer(opts ...ServerOption) ServerApp

+ func NewServer(opts ...ServerOption) (app ServerApp)

+ type ServerOption func(app ServerApp)

+ func WithServerConfigPath(path string) ServerOption

+ func WithServerGrpcAddress(address interfaces.Address) ServerOption

May 15, 2022

Changes in this version

+ func DefaultWait()

+ func Start(app App)

+ type Api struct

+ func GetApi() *Api

+ func NewApi() *Api

+ func (app *Api) GetGinEngine() *gin.Engine

+ func (app *Api) GetHttpServer() *http.Server

+ func (app *Api) Init()

+ func (app *Api) Start()

+ func (app *Api) Stop()

+ func (app *Api) Wait()

+ type App interface

+ Init func()

+ Start func()

+ Stop func()

+ Wait func()

+ type Master struct

+ func (app *Master) GetApi() (api *Api)

+ func (app *Master) GetMasterService() (masterSvc interfaces.NodeMasterService)

+ func (app *Master) Init()

+ func (app *Master) SetGrpcAddress(address interfaces.Address)

+ func (app *Master) SetRunOnMaster(ok bool)

+ func (app *Master) Start()

+ func (app *Master) Stop()

+ func (app *Master) Wait()

+ type MasterApp interface

+ GetApi func() (api *Api)

+ GetMasterService func() (masterSvc interfaces.NodeMasterService)

+ SetRunOnMaster func(ok bool)

+ func GetMaster(opts ...MasterOption) MasterApp

+ func NewMaster(opts ...MasterOption) (app MasterApp)

+ type MasterOption func(app MasterApp)

+ func WithMasterConfigPath(path string) MasterOption

+ func WithMasterGrpcAddress(address interfaces.Address) MasterOption

+ func WithRunOnMaster(ok bool) MasterOption

+ type NodeApp interface

+ SetGrpcAddress func(address interfaces.Address)

+ type Worker struct

+ func NewWorker(opts ...WorkerOption) (app *Worker)

+ func (app *Worker) Init()

+ func (app *Worker) SetGrpcAddress(address interfaces.Address)

+ func (app *Worker) Start()

+ func (app *Worker) Stop()

+ func (app *Worker) Wait()

+ type WorkerApp interface

+ type WorkerOption func(app WorkerApp)

+ func WithWorkerConfigPath(path string) WorkerOption

+ func WithWorkerGrpcAddress(address interfaces.Address) WorkerOption