cbase

Documentation

Index

• func NewServiceSession(node *registry.ServiceNode) (ss core.IServiceSession, err error)
• func Recover()
• type ModuleBase
  • func (this *ModuleBase) Destroy() (err error)
  • func (this *ModuleBase) Init(service core.IService, module core.IModule, setting map[string]interface{}) (err error)
  • func (this *ModuleBase) OnInstallComp()
  • func (this *ModuleBase) RegisterComp(comp core.IModuleComp) interface{}
  • func (this *ModuleBase) Run(closeSig chan bool) (err error)
  • func (this *ModuleBase) Start() (err error)
• type ModuleCompBase
  • func (this *ModuleCompBase) Destroy() (err error)
  • func (this *ModuleCompBase) Init(service core.IService, module core.IModule, comp core.IModuleComp, ...) (err error)
  • func (this *ModuleCompBase) Start() (err error)
• type ServiceBase
  • func (this *ServiceBase) Close(closemsg string)
  • func (this *ServiceBase) Destroy() (err error)
  • func (this *ServiceBase) GetComp(CompName core.S_Comps) (comp core.IServiceComp, err error)
  • func (this *ServiceBase) GetModule(ModuleName core.M_Modules) (module core.IModule, err error)
  • func (this *ServiceBase) Init(service core.IService) (err error)
  • func (this *ServiceBase) InitSys()
  • func (this *ServiceBase) OnInstallComp(cops ...core.IServiceComp)
  • func (this *ServiceBase) Run(mod ...core.IModule)
  • func (this *ServiceBase) Start() (err error)
• type ServiceCompBase
  • func (this *ServiceCompBase) Destroy() (err error)
  • func (this *ServiceCompBase) Init(service core.IService, comp core.IServiceComp) (err error)
  • func (this *ServiceCompBase) Start() (err error)
• type ServiceSession
  • func (this *ServiceSession) Call(f core.Rpc_Key, params ...interface{}) (interface{}, error)
  • func (this *ServiceSession) CallNR(f core.Rpc_Key, params ...interface{}) (err error)
  • func (this *ServiceSession) Done()
  • func (this *ServiceSession) GetId() string
  • func (this *ServiceSession) GetPreWeight() int32
  • func (this *ServiceSession) GetRpcId() string
  • func (this *ServiceSession) GetType() string
  • func (this *ServiceSession) GetVersion() int32
  • func (this *ServiceSession) SetPreWeight(p int32)
  • func (this *ServiceSession) SetVersion(v int32)

Functions

func NewServiceSession

func NewServiceSession(node *registry.ServiceNode) (ss core.IServiceSession, err error)

func Recover

func Recover()

Types

type ModuleBase

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

func (*ModuleBase) Destroy

func (this *ModuleBase) Destroy() (err error)

func (*ModuleBase) Init

func (this *ModuleBase) Init(service core.IService, module core.IModule, setting map[string]interface{}) (err error)

func (*ModuleBase) OnInstallComp

func (this *ModuleBase) OnInstallComp()

func (*ModuleBase) RegisterComp

func (this *ModuleBase) RegisterComp(comp core.IModuleComp) interface{}

func (*ModuleBase) Run

func (this *ModuleBase) Run(closeSig chan bool) (err error)

func (*ModuleBase) Start

func (this *ModuleBase) Start() (err error)

type ModuleCompBase

type ModuleCompBase struct{}

func (*ModuleCompBase) Destroy

func (this *ModuleCompBase) Destroy() (err error)

func (*ModuleCompBase) Init

func (this *ModuleCompBase) Init(service core.IService, module core.IModule, comp core.IModuleComp, setting map[string]interface{}) (err error)

func (*ModuleCompBase) Start

func (this *ModuleCompBase) Start() (err error)

type ServiceBase

type ServiceBase struct {
	Service core.IService
	// contains filtered or unexported fields
}

func (*ServiceBase) Close

func (this *ServiceBase) Close(closemsg string)

func (*ServiceBase) Destroy

func (this *ServiceBase) Destroy() (err error)

func (*ServiceBase) GetComp

func (this *ServiceBase) GetComp(CompName core.S_Comps) (comp core.IServiceComp, err error)

func (*ServiceBase) GetModule

func (this *ServiceBase) GetModule(ModuleName core.M_Modules) (module core.IModule, err error)

func (*ServiceBase) Init

func (this *ServiceBase) Init(service core.IService) (err error)

func (*ServiceBase) InitSys

func (this *ServiceBase) InitSys()

初始化服务系统模块

func (*ServiceBase) OnInstallComp

func (this *ServiceBase) OnInstallComp(cops ...core.IServiceComp)

配置服务组件

func (*ServiceBase) Run

func (this *ServiceBase) Run(mod ...core.IModule)

func (*ServiceBase) Start

func (this *ServiceBase) Start() (err error)

type ServiceCompBase

type ServiceCompBase struct {
}

func (*ServiceCompBase) Destroy

func (this *ServiceCompBase) Destroy() (err error)

func (*ServiceCompBase) Init

func (this *ServiceCompBase) Init(service core.IService, comp core.IServiceComp) (err error)

func (*ServiceCompBase) Start

func (this *ServiceCompBase) Start() (err error)

type ServiceSession

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

func (*ServiceSession) Call

func (this *ServiceSession) Call(f core.Rpc_Key, params ...interface{}) (interface{}, error)

func (*ServiceSession) CallNR

func (this *ServiceSession) CallNR(f core.Rpc_Key, params ...interface{}) (err error)

func (*ServiceSession) Done

func (this *ServiceSession) Done()

func (*ServiceSession) GetId

func (this *ServiceSession) GetId() string

func (*ServiceSession) GetPreWeight

func (this *ServiceSession) GetPreWeight() int32

func (*ServiceSession) GetRpcId

func (this *ServiceSession) GetRpcId() string

func (*ServiceSession) GetType

func (this *ServiceSession) GetType() string

func (*ServiceSession) GetVersion

func (this *ServiceSession) GetVersion() int32

func (*ServiceSession) SetPreWeight

func (this *ServiceSession) SetPreWeight(p int32)

func (*ServiceSession) SetVersion

func (this *ServiceSession) SetVersion(v int32)