-
Notifications
You must be signed in to change notification settings - Fork 1
/
runtime_instance.go
58 lines (49 loc) · 1.69 KB
/
runtime_instance.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
package framework
import (
"git.golaxy.org/core"
"git.golaxy.org/core/runtime"
"git.golaxy.org/core/service"
"git.golaxy.org/core/utils/reinterpret"
"git.golaxy.org/framework/plugins/dentr"
"git.golaxy.org/framework/plugins/rpcstack"
)
// IRuntimeInstantiation 运行时实例化接口
type IRuntimeInstantiation interface {
Instantiation() IRuntimeInstance
}
// GetRuntimeInstance 获取运行时实例
func GetRuntimeInstance(provider runtime.CurrentContextProvider) IRuntimeInstance {
return reinterpret.Cast[IRuntimeInstance](runtime.Current(provider))
}
// IRuntimeInstance 运行时实例接口
type IRuntimeInstance interface {
runtime.Context
// GetDistEntityRegistry 获取分布式实体注册支持
GetDistEntityRegistry() dentr.IDistEntityRegistry
// GetRPCStack 获取RPC调用堆栈支持
GetRPCStack() rpcstack.IRPCStack
// GetService 获取服务实例
GetService() IServiceInstance
// CreateEntity 创建实体
CreateEntity(prototype string) core.EntityCreator
}
// RuntimeInstance 运行时实例
type RuntimeInstance struct {
runtime.ContextBehavior
}
// GetDistEntityRegistry 获取分布式实体注册支持
func (inst *RuntimeInstance) GetDistEntityRegistry() dentr.IDistEntityRegistry {
return dentr.Using(inst)
}
// GetRPCStack 获取RPC调用堆栈支持
func (inst *RuntimeInstance) GetRPCStack() rpcstack.IRPCStack {
return rpcstack.Using(inst)
}
// GetService 获取服务
func (inst *RuntimeInstance) GetService() IServiceInstance {
return reinterpret.Cast[IServiceInstance](service.Current(inst))
}
// CreateEntity 创建实体
func (inst *RuntimeInstance) CreateEntity(prototype string) core.EntityCreator {
return core.CreateEntity(runtime.Current(inst), prototype)
}