service

package
v1.17.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 19, 2022 License: Apache-2.0 Imports: 14 Imported by: 20

Documentation

Index

Constants

View Source 
const InitModuleId = 1e9

Variables

This section is empty.

Functions

func Init 

func Init(chanCloseSig chan bool)

func SetMaxServiceChannel 

func SetMaxServiceChannel(maxEventChannel int)

func Setup 

func Setup(s IService) bool

func Start 

func Start()

func WaitStop 

func WaitStop()

Types

type IModule 

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

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

type IModuleTimer 

type IModuleTimer interface {
	AfterFunc(d time.Duration, cb func(*timer.Timer)) *timer.Timer
	CronFunc(cronExpr *timer.CronExpr, cb func(*timer.Cron)) *timer.Cron
	NewTicker(d time.Duration, cb func(*timer.Ticker)) *timer.Ticker
}

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
	OnStart()
	OnRelease()
	Wait()
	Start()
	GetRpcHandler() rpc.IRpcHandler
	GetServiceCfg() interface{}
	OpenProfiler()
	GetProfiler() *profiler.Profiler
}

func GetService 

func GetService(serviceName string) IService

type Module 

type Module struct {
	rpcHandle.IRpcHandler
	// contains filtered or unexported fields
}

func (*Module) AddModule 

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

func (*Module) AfterFunc 

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

func (*Module) CancelTimerId 

func (m *Module) CancelTimerId(timerId *uint64) bool

func (*Module) CronFunc 

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

func (*Module) GenTimerId 

func (m *Module) GenTimerId() uint64

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 uint32) IModule

func (*Module) GetModuleId 

func (m *Module) GetModuleId() uint32

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() uint32

func (*Module) NewTicker 

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

func (*Module) NotifyEvent 

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

func (*Module) OnAddTimer 

func (m *Module) OnAddTimer(t timer.ITimer)

func (*Module) OnCloseTimer 

func (m *Module) OnCloseTimer(t timer.ITimer)

func (*Module) OnInit 

func (m *Module) OnInit() error

func (*Module) OnRelease 

func (m *Module) OnRelease()

func (*Module) ReleaseModule 

func (m *Module) ReleaseModule(moduleId uint32)

func (*Module) SafeAfterFunc 

func (m *Module) SafeAfterFunc(timerId *uint64, d time.Duration, AdditionData interface{}, cb func(uint64, interface{}))

func (*Module) SafeCronFunc 

func (m *Module) SafeCronFunc(cronId *uint64, cronExpr *timer.CronExpr, AdditionData interface{}, cb func(uint64, interface{}))

func (*Module) SafeNewTicker 

func (m *Module) SafeNewTicker(tickerId *uint64, d time.Duration, AdditionData interface{}, cb func(uint64, interface{}))

func (*Module) SetModuleId 

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

type RegRpcEventFunType 

type RegRpcEventFunType func(serviceName string)
var RegRpcEventFun RegRpcEventFunType

type RpcConnEvent 

type RpcConnEvent struct {
	IsConnect bool
	NodeId    int
}

RpcConnEvent Node结点连接事件

func (*RpcConnEvent) GetEventType 

func (rpcEventData *RpcConnEvent) GetEventType() event.EventType

type Service 

type Service struct {
	Module
	// 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) OnRpcEvent 

func (s *Service) OnRpcEvent(ev event.IEvent)

func (*Service) OnSetup 

func (s *Service) OnSetup(iService IService)

func (*Service) OnStart 

func (s *Service) OnStart()

func (*Service) OpenProfiler 

func (s *Service) OpenProfiler()

func (*Service) PushEvent 

func (s *Service) PushEvent(ev event.IEvent) error

func (*Service) PushRpcRequest 

func (s *Service) PushRpcRequest(rpcRequest *rpc.RpcRequest) error

func (*Service) PushRpcResponse 

func (s *Service) PushRpcResponse(call *rpc.Call) error

func (*Service) RegEventReceiverFunc 

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

func (*Service) RegRawRpc 

func (s *Service) RegRawRpc(rpcMethodId uint32, rawRpcCB rpc.RawRpcCallBack)

func (*Service) RegRpcListener 

func (s *Service) RegRpcListener(rpcEventLister rpc.IRpcListener)

func (*Service) Release 

func (s *Service) Release()

func (*Service) Run 

func (s *Service) Run()

func (*Service) SetGoRoutineNum 

func (s *Service) SetGoRoutineNum(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) UnRegRpcListener 

func (s *Service) UnRegRpcListener(rpcLister rpc.IRpcListener)

func (*Service) Wait 

func (s *Service) Wait()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.