Versions in this module Expand all Collapse all v1 v1.0.1 Jan 21, 2025 Changes in this version + type EventCallBack func(event IEvent) + type EventType int32 + type IBus interface + AsyncCall func(method string, timeout time.Duration, in interface{}, ...) (dto.CancelRpc, error) + Call func(method string, in, out interface{}) error + CallWithTimeout func(method string, timeout time.Duration, in, out interface{}) error + Cast func(method string, in interface{}) + Send func(method string, in interface{}) error + type IDataDef interface + IsRef func() bool + Ref func() + UnRef func() + type IDiscovery interface + Close func() + Init func(eventProcessor IEventProcessor) error + Start func() + type IEnvelope interface + Done func() + GetErrStr func() string + GetError func() error + GetHeader func(key string) string + GetHeaders func() dto.Header + GetMethod func() string + GetReceiverPid func() *actor.PID + GetReqId func() uint64 + GetRequest func() interface{} + GetResponse func() interface{} + GetSender func() IRpcSender + GetSenderPid func() *actor.PID + GetTimeout func() time.Duration + GetTimerId func() uint64 + IsReply func() bool + NeedCallback func() bool + NeedResponse func() bool + RunCompletions func() + SetCallback func(cbs []dto.CompletionFunc) + SetErrStr func(err string) + SetError func(err error) + SetHeader func(key string, value string) + SetHeaders func(header dto.Header) + SetMethod func(method string) + SetNeedResponse func(need bool) + SetReceiverPid func(receiver *actor.PID) + SetReply func() + SetReqId func(reqId uint64) + SetRequest func(req interface{}) + SetResponse func(res interface{}) + SetSender func(client IRpcSender) + SetSenderPid func(sender *actor.PID) + SetTimeout func(timeout time.Duration) + SetTimerId func(id uint64) + ToProtoMsg func() *actor.Message + Wait func() + type IEvent interface + GetType func() EventType + type IEventChannel interface + PushEvent func(ev IEvent) error + type IEventHandler interface + AddRegInfo func(eventType EventType, eventProcessor IEventProcessor) + Destroy func() + GetEventProcessor func() IEventProcessor + Init func(p IEventProcessor) + NotifyEvent func(IEvent) + RemoveRegInfo func(eventType EventType, eventProcessor IEventProcessor) + type IEventProcessor interface + AddBindEvent func(eventType EventType, receiver IEventHandler, callback EventCallBack) + AddListen func(eventType EventType, receiver IEventHandler) + CastEvent func(event IEvent) + EventHandler func(ev IEvent) + Init func(eventChannel IEventChannel) + RegEventReceiverFunc func(eventType EventType, receiver IEventHandler, callback EventCallBack) + RemoveBindEvent func(eventType EventType, receiver IEventHandler) + RemoveListen func(eventType EventType, receiver IEventHandler) + UnRegEventReceiverFun func(eventType EventType, receiver IEventHandler) + type IHttpChannel interface + PushHttpEvent func(e interface{}) error + type IIdentifiable interface + GetName func() string + GetPid func() *actor.PID + GetServerId func() int32 + GetServiceId func() string + IsClosed func() bool + OnSetup func(svc IService) + SetName func(string) + SetServiceId func(id string) + type ILifecycle interface + Init func(src interface{}, serviceInitConf *config.ServiceInitConf, cfg interface{}) + OnInit func() error + OnRelease func() + OnStart func() error + Start func() error + Stop func() + type IModule interface + type IModuleHierarchy interface + AddModule func(IModule) (uint32, error) + GetBaseModule func() IModule + GetModule func(uint32) IModule + GetParent func() IModule + GetRoot func() IModule + ReleaseAllChildModule func() + ReleaseModule func(moduleId uint32) + type IModuleIdentity interface + GetModuleID func() uint32 + GetModuleName func() string + NewModuleID func() uint32 + SetModuleID func(uint32) bool + type IModuleLifecycle interface + OnInit func() error + OnRelease func() + type IModuleServiceEvent interface + GetEventHandler func() IEventHandler + GetEventProcessor func() IEventProcessor + GetService func() IService + NotifyEvent func(IEvent) + type IModuleTimer interface + AfterFunc func(d time.Duration, cb func(iTimer timer.ITimer)) timer.ITimer + CronFunc func(cronExpr *timer.CronExpr, cb func(timer.ITimer)) timer.ITimer + NewTicker func(d time.Duration, cb func(timer.ITimer)) timer.ITimer + type IMonitor interface + Add func(call IEnvelope) + GenSeq func() uint64 + Get func(seq uint64) IEnvelope + Init func() IMonitor + Remove func(seq uint64) IEnvelope + Start func() + Stop func() + type IProfiler interface + GetProfiler func() *profiler.Profiler + OpenProfiler func() + type IRemoteServer interface + Close func() + Init func(IRpcSenderFactory) + Serve func(*config.RPCServer) error + type IRpcChannel interface + PushRequest func(req IEnvelope) error + type IRpcHandler interface + GetName func() string + GetPid func() *actor.PID + GetRpcHandler func() IRpcHandler + HandleRequest func(msg IEnvelope) + HandleResponse func(msg IEnvelope) + IsClosed func() bool + IsPrivate func() bool + type IRpcSelector interface + Select func(serverId int32, serviceId, serviceName string) IBus + SelectByPid func(receiver *actor.PID) IBus + SelectByRule func(rule func(pid *actor.PID) bool) IBus + SelectByServiceType func(serverId int32, serviceType, serviceName string, ...) IBus + SelectSameServer func(serviceId, serviceName string) IBus + SelectSameServerByServiceType func(serviceType, serviceName string, filters ...func(pid *actor.PID) bool) IBus + type IRpcSender interface + GetPid func() *actor.PID + type IRpcSenderFactory interface + GetSender func(pid *actor.PID) IRpcSender + type IRpcSenderHandler interface + Close func() + SendRequest func(envelope IEnvelope) error + SendRequestAndRelease func(envelope IEnvelope) error + SendResponse func(envelope IEnvelope) error + type ISelector interface + Select func(sender *actor.PID, serverId int32, serviceId, serviceName string) IBus + SelectByFilterAndChoice func(sender *actor.PID, filter func(pid *actor.PID) bool, ...) IBus + SelectByPid func(sender, receiver *actor.PID) IBus + SelectByRule func(sender *actor.PID, rule func(pid *actor.PID) bool) IBus + SelectByServiceType func(sender *actor.PID, serverId int32, serviceType, serviceName string) IBus + type IService interface + type IServiceHandler interface + GetRpcHandler func() IRpcHandler + GetServiceCfg func() interface{} + GetServiceEventChannelNum func() int + GetServiceTimerChannelNum func() int + SetGoRoutineNum func(num int32) + type ITimer interface + Do func() + GetName func() string + GetTimerId func() uint64
Go to main page