mirror of
https://github.com/duanhf2012/origin.git
synced 2026-02-03 22:45:13 +08:00
新增设置自定义服务名称接口
This commit is contained in:
@@ -19,8 +19,8 @@ var timerDispatcherLen = 10
|
|||||||
|
|
||||||
type IService interface {
|
type IService interface {
|
||||||
Init(iservice IService,getClientFun rpc.FuncRpcClient,getServerFun rpc.FuncRpcServer,serviceCfg interface{})
|
Init(iservice IService,getClientFun rpc.FuncRpcClient,getServerFun rpc.FuncRpcServer,serviceCfg interface{})
|
||||||
|
SetName(serviceName string)
|
||||||
GetName() string
|
GetName() string
|
||||||
|
|
||||||
OnSetup(iservice IService)
|
OnSetup(iservice IService)
|
||||||
OnInit() error
|
OnInit() error
|
||||||
OnRelease()
|
OnRelease()
|
||||||
@@ -163,6 +163,11 @@ func (slf *Service) GetName() string{
|
|||||||
return slf.name
|
return slf.name
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (slf *Service) SetName(serviceName string) {
|
||||||
|
slf.name = serviceName
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
func (slf *Service) Release(){
|
func (slf *Service) Release(){
|
||||||
defer func() {
|
defer func() {
|
||||||
if r := recover(); r != nil {
|
if r := recover(); r != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user