cbase

Documentation

Index

• func NewServiceSession(node *registry.ServiceNode) (ss core.IServiceSession, err error)
• type ModuleBase
  • func (this *ModuleBase) Destroy() (err error)
  • func (this *ModuleBase) Init(service core.IService, module core.IModule, options core.IModuleOptions) (err error)
  • func (this *ModuleBase) NewOptions() (options core.IModuleOptions)
  • 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 ModuleOptions
  • func (this *ModuleOptions) LoadConfig(settings map[string]interface{}) (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) 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, options core.ICompOptions) (err error)
  • func (this *ServiceCompBase) NewOptions() (options core.ICompOptions)
  • func (this *ServiceCompBase) Start() (err error)
• type ServiceCompOptions
  • func (this *ServiceCompOptions) LoadConfig(settings map[string]interface{}) (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) GetIp() string
  • func (this *ServiceSession) GetPreWeight() float64
  • func (this *ServiceSession) GetRpcId() string
  • func (this *ServiceSession) GetType() string
  • func (this *ServiceSession) GetVersion() string
  • func (this *ServiceSession) SetPreWeight(p float64)
  • func (this *ServiceSession) SetVersion(v string)

Functions

func NewServiceSession

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

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, options core.IModuleOptions) (err error)

func (*ModuleBase) NewOptions

func (this *ModuleBase) NewOptions() (options core.IModuleOptions)

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, options core.IModuleOptions) (err error)

func (*ModuleCompBase) Start

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

type ModuleOptions

type ModuleOptions struct {
}

func (*ModuleOptions) LoadConfig

func (this *ModuleOptions) LoadConfig(settings map[string]interface{}) (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) 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, options core.ICompOptions) (err error)

func (*ServiceCompBase) NewOptions

func (this *ServiceCompBase) NewOptions() (options core.ICompOptions)

func (*ServiceCompBase) Start

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

type ServiceCompOptions

type ServiceCompOptions struct {
	core.ICompOptions
}

func (*ServiceCompOptions) LoadConfig

func (this *ServiceCompOptions) LoadConfig(settings map[string]interface{}) (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) GetIp

func (this *ServiceSession) GetIp() string

func (*ServiceSession) GetPreWeight

func (this *ServiceSession) GetPreWeight() float64

func (*ServiceSession) GetRpcId

func (this *ServiceSession) GetRpcId() string

func (*ServiceSession) GetType

func (this *ServiceSession) GetType() string

func (*ServiceSession) GetVersion

func (this *ServiceSession) GetVersion() string

func (*ServiceSession) SetPreWeight

func (this *ServiceSession) SetPreWeight(p float64)

func (*ServiceSession) SetVersion

func (this *ServiceSession) SetVersion(v string)