Documentation ¶
Overview ¶
Package framework Golaxy分布式服务开发框架。
Index ¶
- type App
- func (app *App) GetStartupConf() *viper.Viper
- func (app *App) InitCB(cb generic.DelegateAction1[*App]) *App
- func (app *App) Run()
- func (app *App) Setup(name string, generic any) *App
- func (app *App) StartingCB(cb generic.DelegateAction1[*App]) *App
- func (app *App) TerminateCB(cb generic.DelegateAction1[*App]) *App
- type IRuntimeInstantiation
- type IServiceInstantiation
- type InstallRuntimeDistEntities
- type InstallRuntimeLogger
- type InstallServiceBroker
- type InstallServiceConfig
- type InstallServiceDistEntityQuerier
- type InstallServiceDistService
- type InstallServiceDistSync
- type InstallServiceLogger
- type InstallServiceRPC
- type InstallServiceRegistry
- type LifecycleRuntimeBirth
- type LifecycleRuntimeBuilt
- type LifecycleRuntimeFrameLoopBegin
- type LifecycleRuntimeFrameLoopEnd
- type LifecycleRuntimeFrameUpdateBegin
- type LifecycleRuntimeFrameUpdateEnd
- type LifecycleRuntimeRunCallBegin
- type LifecycleRuntimeRunCallEnd
- type LifecycleRuntimeRunGCBegin
- type LifecycleRuntimeRunGCEnd
- type LifecycleRuntimeStarted
- type LifecycleRuntimeStarting
- type LifecycleRuntimeTerminated
- type LifecycleRuntimeTerminating
- type LifecycleServiceBirth
- type LifecycleServiceBuilt
- type LifecycleServiceStarted
- type LifecycleServiceStarting
- type LifecycleServiceTerminated
- type LifecycleServiceTerminating
- type RuntimeCreator
- func (c RuntimeCreator) AutoRun(auto bool) RuntimeCreator
- func (c RuntimeCreator) FPS(fps float32) RuntimeCreator
- func (c RuntimeCreator) Name(name string) RuntimeCreator
- func (c RuntimeCreator) PanicHandling(autoRecover bool, reportError chan error) RuntimeCreator
- func (c RuntimeCreator) ProcessQueueCapacity(cap int) RuntimeCreator
- func (c RuntimeCreator) Setup(generic any) RuntimeCreator
- func (c RuntimeCreator) Spawn() core.Runtime
- type RuntimeGeneric
- type RuntimeInstance
- type ServiceGeneric
- type ServiceInstance
- func (instance *ServiceInstance) CreateEntityPT() core.EntityPTCreator
- func (instance *ServiceInstance) CreateRuntime() RuntimeCreator
- func (instance *ServiceInstance) GetBroker() broker.IBroker
- func (instance *ServiceInstance) GetConf() conf.IVisitConf
- func (instance *ServiceInstance) GetDistEntityQuerier() dentq.IDistEntityQuerier
- func (instance *ServiceInstance) GetDistService() dserv.IDistService
- func (instance *ServiceInstance) GetDistSync() dsync.IDistSync
- func (instance *ServiceInstance) GetMemKVs() *sync.Map
- func (instance *ServiceInstance) GetRPC() rpc.IRPC
- func (instance *ServiceInstance) GetRegistry() discovery.IRegistry
- func (instance *ServiceInstance) GetStartupConf() *viper.Viper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type App ¶
type App struct {
// contains filtered or unexported fields
}
App 应用
func (*App) StartingCB ¶
func (app *App) StartingCB(cb generic.DelegateAction1[*App]) *App
StartingCB 启动回调
func (*App) TerminateCB ¶ added in v0.1.33
func (app *App) TerminateCB(cb generic.DelegateAction1[*App]) *App
TerminateCB 终止回调
type IRuntimeInstantiation ¶ added in v0.1.45
IRuntimeInstantiation 运行时实例化接口
type IServiceInstantiation ¶ added in v0.1.45
IServiceInstantiation 服务实例化接口
type InstallRuntimeLogger ¶
type InstallServiceBroker ¶
type InstallServiceConfig ¶
type InstallServiceDistSync ¶
type InstallServiceLogger ¶
type InstallServiceRPC ¶
type InstallServiceRegistry ¶
type LifecycleRuntimeBirth ¶
type LifecycleRuntimeBuilt ¶ added in v0.1.45
type LifecycleRuntimeStarted ¶
type LifecycleServiceBirth ¶
type LifecycleServiceBuilt ¶ added in v0.1.45
type LifecycleServiceStarted ¶
type RuntimeCreator ¶
type RuntimeCreator struct {
// contains filtered or unexported fields
}
RuntimeCreator 运行时构建器
func (RuntimeCreator) AutoRun ¶
func (c RuntimeCreator) AutoRun(auto bool) RuntimeCreator
AutoRun 自动开始运行
func (RuntimeCreator) FPS ¶ added in v0.1.27
func (c RuntimeCreator) FPS(fps float32) RuntimeCreator
FPS 帧率
func (RuntimeCreator) PanicHandling ¶ added in v0.1.27
func (c RuntimeCreator) PanicHandling(autoRecover bool, reportError chan error) RuntimeCreator
PanicHandling panic时的处理方式
func (RuntimeCreator) ProcessQueueCapacity ¶
func (c RuntimeCreator) ProcessQueueCapacity(cap int) RuntimeCreator
ProcessQueueCapacity 任务处理流水线大小
func (RuntimeCreator) Setup ¶
func (c RuntimeCreator) Setup(generic any) RuntimeCreator
Setup 安装运行时泛化类型
type RuntimeGeneric ¶ added in v0.1.37
type RuntimeGeneric struct {
// contains filtered or unexported fields
}
RuntimeGeneric 运行时泛化类型
func (*RuntimeGeneric) GetMemKVs ¶ added in v0.1.37
func (r *RuntimeGeneric) GetMemKVs() *sync.Map
GetMemKVs 获取服务内存KV数据库
func (*RuntimeGeneric) GetServiceCtx ¶ added in v0.1.37
func (r *RuntimeGeneric) GetServiceCtx() service.Context
GetServiceCtx 获取服务上下文
func (*RuntimeGeneric) GetStartupConf ¶ added in v0.1.37
func (r *RuntimeGeneric) GetStartupConf() *viper.Viper
GetStartupConf 获取启动参数配置
type RuntimeInstance ¶ added in v0.1.45
type RuntimeInstance struct {
runtime.ContextBehavior
}
RuntimeInstance 运行时实例
func (*RuntimeInstance) CreateEntity ¶ added in v0.1.45
func (instance *RuntimeInstance) CreateEntity() core.EntityCreator
CreateEntity 创建实体
func (*RuntimeInstance) GetMemKVs ¶ added in v0.1.45
func (instance *RuntimeInstance) GetMemKVs() *sync.Map
GetMemKVs 获取服务内存KV数据库
func (*RuntimeInstance) GetStartupConf ¶ added in v0.1.45
func (instance *RuntimeInstance) GetStartupConf() *viper.Viper
GetStartupConf 获取启动参数配置
type ServiceGeneric ¶ added in v0.1.37
type ServiceGeneric struct {
// contains filtered or unexported fields
}
ServiceGeneric 服务泛化类型
func (*ServiceGeneric) GetName ¶ added in v0.1.37
func (s *ServiceGeneric) GetName() string
GetName 获取服务名称
func (*ServiceGeneric) GetStartupConf ¶ added in v0.1.37
func (s *ServiceGeneric) GetStartupConf() *viper.Viper
GetStartupConf 获取启动参数配置
type ServiceInstance ¶ added in v0.1.45
type ServiceInstance struct {
service.ContextBehavior
}
ServiceInstance 服务实例
func (*ServiceInstance) CreateEntityPT ¶ added in v0.1.45
func (instance *ServiceInstance) CreateEntityPT() core.EntityPTCreator
CreateEntityPT 创建实体原型
func (*ServiceInstance) CreateRuntime ¶ added in v0.1.45
func (instance *ServiceInstance) CreateRuntime() RuntimeCreator
CreateRuntime 创建运行时
func (*ServiceInstance) GetBroker ¶ added in v0.1.45
func (instance *ServiceInstance) GetBroker() broker.IBroker
GetBroker 获取broker插件
func (*ServiceInstance) GetConf ¶ added in v0.1.45
func (instance *ServiceInstance) GetConf() conf.IVisitConf
GetConf 获取配置插件
func (*ServiceInstance) GetDistEntityQuerier ¶ added in v0.1.45
func (instance *ServiceInstance) GetDistEntityQuerier() dentq.IDistEntityQuerier
GetDistEntityQuerier 获取分布式实体查询插件
func (*ServiceInstance) GetDistService ¶ added in v0.1.45
func (instance *ServiceInstance) GetDistService() dserv.IDistService
GetDistService 获取分布式服务插件
func (*ServiceInstance) GetDistSync ¶ added in v0.1.45
func (instance *ServiceInstance) GetDistSync() dsync.IDistSync
GetDistSync 获取分布式同步插件
func (*ServiceInstance) GetMemKVs ¶ added in v0.1.45
func (instance *ServiceInstance) GetMemKVs() *sync.Map
GetMemKVs 获取服务内存KV数据库
func (*ServiceInstance) GetRPC ¶ added in v0.1.45
func (instance *ServiceInstance) GetRPC() rpc.IRPC
GetRPC 获取RPC支持插件
func (*ServiceInstance) GetRegistry ¶ added in v0.1.45
func (instance *ServiceInstance) GetRegistry() discovery.IRegistry
GetRegistry 获取服务发现插件
func (*ServiceInstance) GetStartupConf ¶ added in v0.1.45
func (instance *ServiceInstance) GetStartupConf() *viper.Viper
GetStartupConf 获取启动参数配置
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
net
|
|
gap
Package gap Golaxy应用层协议(golaxy application protocol),适用于开发应用层通信消息,需要工作在GTP协议或MQ之上,支持消息判重,解决了幂等性问题。
|
Package gap Golaxy应用层协议(golaxy application protocol),适用于开发应用层通信消息,需要工作在GTP协议或MQ之上,支持消息判重,解决了幂等性问题。 |
gtp
Package gtp Golaxy传输层协议(golaxy transfer protocol),适用于长连接、实时通信的工作场景,需要工作在可靠网络协议(TCP/WebSocket)之上,支持链路加密、链路鉴权、断线续连等特性。
|
Package gtp Golaxy传输层协议(golaxy transfer protocol),适用于长连接、实时通信的工作场景,需要工作在可靠网络协议(TCP/WebSocket)之上,支持链路加密、链路鉴权、断线续连等特性。 |
plugins
|
|
dentq
+k8s:deepcopy-gen=package
|
+k8s:deepcopy-gen=package |
discovery
+k8s:deepcopy-gen=package
|
+k8s:deepcopy-gen=package |
util
|
|