service

package

v0.0.0-...-ff803ae Latest Latest Go to latest Published: Nov 20, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/3dseals/origin

Documentation ¶

Index ¶

Constants
func Init(chanCloseSig chan bool)
func Setup(s IService) bool
func Start()
func WaitStop()
type IModule
type IService
- func GetService(serviceName string) IService
type Module
type Service

Constants ¶

View Source

const InitModuleId = 1e17

Variables ¶

This section is empty.

Functions ¶

func Init ¶

func Init(chanCloseSig chan bool)

func Setup ¶

func Setup(s IService) bool

func Start ¶

func Start()

func WaitStop ¶

func WaitStop()

Types ¶

type IModule ¶

type IModule interface {
	SetModuleId(moduleId int64) bool
	GetModuleId() int64
	AddModule(module IModule) (int64, error)
	GetModule(moduleId int64) IModule
	GetAncestor() IModule
	ReleaseModule(moduleId int64)
	NewModuleId() int64
	GetParent() IModule
	OnInit() error
	OnRelease()

	GetService() IService
	GetModuleName() string
	GetEventProcessor() event.IEventProcessor
	NotifyEvent(ev *event.Event)
	// contains filtered or unexported methods
}

type IService ¶

type IService interface {
	Init(iService IService, getClientFun rpc.FuncRpcClient, getServerFun rpc.FuncRpcServer, serviceCfg interface{})
	SetName(serviceName string)
	GetName() string
	OnSetup(iService IService)
	OnInit() error
	OnRelease()
	Wait()
	Start()
	GetRpcHandler() rpc.IRpcHandler
	GetServiceCfg() interface{}
	OpenProfiler()
	GetProfiler() *profiler.Profiler
}

func GetService ¶

func GetService(serviceName string) IService

type Module ¶

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

1.管理各模块树层关系 2.提供定时器常用工具

func (*Module) AddModule ¶

func (m *Module) AddModule(module IModule) (int64, error)

func (*Module) AfterFunc ¶

func (m *Module) AfterFunc(d time.Duration, cb func()) *timer.Timer

func (*Module) CronFunc ¶

func (m *Module) CronFunc(cronExpr *timer.CronExpr, cb func()) *timer.Cron

func (*Module) GetAncestor ¶

func (m *Module) GetAncestor() IModule

func (*Module) GetEventHandler ¶

func (m *Module) GetEventHandler() event.IEventHandler

func (*Module) GetEventProcessor ¶

func (m *Module) GetEventProcessor() event.IEventProcessor

func (*Module) GetModule ¶

func (m *Module) GetModule(moduleId int64) IModule

func (*Module) GetModuleId ¶

func (m *Module) GetModuleId() int64

func (*Module) GetModuleName ¶

func (m *Module) GetModuleName() string

func (*Module) GetParent ¶

func (m *Module) GetParent() IModule

func (*Module) GetService ¶

func (m *Module) GetService() IService

func (*Module) NewModuleId ¶

func (m *Module) NewModuleId() int64

func (*Module) NewTicker ¶

func (m *Module) NewTicker(d time.Duration, cb func()) *timer.Ticker

func (*Module) NotifyEvent ¶

func (m *Module) NotifyEvent(ev *event.Event)

func (*Module) OnAddTimer ¶

func (m *Module) OnAddTimer(t *timewheel.Timer)

func (*Module) OnCloseTimer ¶

func (m *Module) OnCloseTimer(timer *timewheel.Timer)

func (*Module) OnInit ¶

func (m *Module) OnInit() error

func (*Module) OnRelease ¶

func (m *Module) OnRelease()

func (*Module) ReleaseModule ¶

func (m *Module) ReleaseModule(moduleId int64)

func (*Module) SetModuleId ¶

func (m *Module) SetModuleId(moduleId int64) bool

type Service ¶

type Service struct {
	Module
	rpc.RpcHandler //rpc
	// contains filtered or unexported fields
}

func (*Service) GetName ¶

func (s *Service) GetName() string

func (*Service) GetProfiler ¶

func (s *Service) GetProfiler() *profiler.Profiler

func (*Service) GetServiceCfg ¶

func (s *Service) GetServiceCfg() interface{}

func (*Service) Init ¶

func (s *Service) Init(iService IService, getClientFun rpc.FuncRpcClient, getServerFun rpc.FuncRpcServer, serviceCfg interface{})

func (*Service) IsSingleCoroutine ¶

func (s *Service) IsSingleCoroutine() bool

func (*Service) OnInit ¶

func (s *Service) OnInit() error

func (*Service) OnRelease ¶

func (s *Service) OnRelease()

func (*Service) OnSetup ¶

func (s *Service) OnSetup(iService IService)

func (*Service) OpenProfiler ¶

func (s *Service) OpenProfiler()

func (*Service) RegEventReceiverFunc ¶

func (s *Service) RegEventReceiverFunc(eventType event.EventType, receiver event.IEventHandler, callback event.EventCallBack)

func (*Service) Release ¶

func (s *Service) Release()

func (*Service) Run ¶

func (s *Service) Run()

func (*Service) SetGoRouterNum ¶

func (s *Service) SetGoRouterNum(goroutineNum int32) bool

func (*Service) SetName ¶

func (s *Service) SetName(serviceName string)

func (*Service) Start ¶

func (s *Service) Start()

func (*Service) UnRegEventReceiverFunc ¶

func (s *Service) UnRegEventReceiverFunc(eventType event.EventType, receiver event.IEventHandler)

func (*Service) Wait ¶

func (s *Service) Wait()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL