idlrpc

Oct 10, 2023

Changes in this version

+ func RpcStrError(errorCode uint32) error

type CallInfo

+ func (sc *CallInfo) Clean() error

type IRpc

+ AsyncCall func(IServiceContext, IProxy, uint32, uint32, int32, proto.Message, ...) error

+ SyncCall func(IServiceContext, IProxy, uint32, uint32, int32, proto.Message) ([]byte, error)

type IServiceContext

+ Continue func()

+ Debug func(string, ...interface{})

+ Finish func(interface{}, error) error

+ IsContinue func() bool

type IStub

+ GetTimeout func(uint32) uint32

+ Return func(IServiceContext, uint32, interface{}, error) ([]byte, error)

type Option

+ func WithLocation(location *time.Location) Option

+ func WithMaxTaskCount(count int) Option

+ type RpcCallManager struct

+ func NewRpcCallManager() *RpcCallManager

+ func (cm *RpcCallManager) CreateAsyncCall(ctx IServiceContext, callBack proxy.RpcCallBack, opts ...proxy.RpcCallOption) *RpcCallWrapper

+ func (cm *RpcCallManager) CreateSyncCall(opts ...proxy.RpcCallOption) *RpcCallWrapper

+ func (cm *RpcCallManager) Destroy(callId uint32)

+ func (cm *RpcCallManager) GenCallID() uint32

+ func (cm *RpcCallManager) Get(callId uint32) *RpcCallWrapper

+ type RpcCallWrapper struct

+ func (rc *RpcCallWrapper) SetErrorCode(errorCode uint32)

type RpcContext

+ func (c *RpcContext) Continue()

+ func (c *RpcContext) Finish(any interface{}, err error) error

+ func (c *RpcContext) IsContinue() bool

Aug 8, 2023

Changes in this version

type IMessageHandler

+ OnRawMessage func(transport transport.ITransport, msg []byte)

Jul 6, 2023

Changes in this version

type IServiceContext

+ Clone func() IServiceContext

type RpcContext

+ func (c *RpcContext) Clone() *RpcContext

Jun 30, 2023

Changes in this version

+ type CallInfo struct

+ func (sc *CallInfo) CallID() uint32

+ func (sc *CallInfo) GetBody() []byte

+ func (sc *CallInfo) GetServiceUUID() uint64

+ func (sc *CallInfo) GetUUID() CallUuid

+ func (sc *CallInfo) GlobalIndex() protocol.GlobalIndexType

+ func (sc *CallInfo) MethodID() uint32

+ type ContextIterator func(string, string)

+ type ContextKV map[string]string

+ type IServiceContext interface

+ Error func(string, ...interface{})

+ GetGlobalIndex func() protocol.GlobalIndexType

+ GetIdentityID func() string

+ GetIdentityTag func() string

+ GetProxy func(uuid uint64) IProxy

+ GetProxyFromPeer func(uuid uint64) IProxy

+ GetProxyWithNickname func(uuid uint64, name string) IProxy

+ GetRequestContext func() ContextKV

+ GetResponseContext func() ContextKV

+ GetResponseValue func(string) (string, bool)

+ GetTransport func() transport.ITransport

+ GetUserContext func() ContextKV

+ GetValue func(string) (string, bool)

+ Info func(string, ...interface{})

+ SetContext func(string, string)

+ SetResponseContext func(string, string)

+ SetUserContext func(string, string)

+ Warning func(string, ...interface{})

type Option

+ func WithServiceContext(ctx IServiceContext) Option

+ type RpcContext struct

+ func (c *RpcContext) GetGlobalIndex() protocol.GlobalIndexType

+ func (c *RpcContext) GetRequestContext() ContextKV

+ func (c *RpcContext) GetResponseContext() ContextKV

+ func (c *RpcContext) GetResponseValue(key string) (string, bool)

+ func (c *RpcContext) GetUserContext() ContextKV

+ func (c *RpcContext) GetValue(key string) (string, bool)

+ func (c *RpcContext) SetContext(key string, value string)

+ func (c *RpcContext) SetResponseContext(key string, value string)

+ func (c *RpcContext) SetUserContext(key string, value string)

Jun 28, 2023

Changes in this version

+ type IMessageHandler interface

+ OnIdentityNotify func(transport transport.ITransport, identityID string, identityTag string)

+ OnLoggedOut func(index protocol.GlobalIndexType)

type IProxy

+ GetIdentityID func() string

type IRpc

+ GetExtraProxy func(uuid uint64, globalIndex protocol.GlobalIndexType, trans transport.ITransport) (IProxy, error)

type Option

+ func WithMessageHandler(handler IMessageHandler) Option

type ProxyBase

+ func (base *ProxyBase) GetIdentityID() string

Jun 7, 2023

Changes in this version

type IStub

+ GetMultipleNum func() uint32

Jan 13, 2023

Changes in this version

+ type EventCallBack func(string, []byte)

type IProxy

+ Cancel func(string) error

+ NotifyEvent func(string, []byte)

+ SetSubscriber func(ISubscriber)

+ Subscribe func(string, []byte, EventCallBack) error

+ type IPublisher interface

+ AddSub func(string, string, []byte, ProxyId, transport.ITransport) error

+ CancelSub func(string) error

+ Publish func(string, []byte) error

type IRpc

+ Publish func(uuid SvcUuid, serviceID int32, event string, data []byte) error

type IService

+ OnCancel func(string, string) error

+ OnSubscribe func(string, string, []byte) error

type IStub

+ OnCancel func(string, string) error

+ OnSub func(string, string, []byte) error

+ type ISubscriber interface

+ Cancel func(uint32, string) error

+ CancelAll func(uint32) error

+ OnNotify func(string, []byte) error

+ Subscribe func(uint32, string, []byte, EventCallBack) error

+ type IUuidFactory interface

+ NewUuid func() string

type Option

+ func WithUuidFactory(uid IUuidFactory) Option

type ProxyBase

+ func (base *ProxyBase) Cancel(event string) error

+ func (base *ProxyBase) NotifyEvent(subId string, data []byte)

+ func (base *ProxyBase) SetSubscriber(s ISubscriber)

+ func (base *ProxyBase) Subscribe(event string, data []byte, callback EventCallBack) error

type StubManager

+ func (m *StubManager) AddSubInfo(subId string, sUid SvcUuid) error

+ func (m *StubManager) GetSubService(subId string) *stubWrapper

+ func (m *StubManager) RemoveSubInfo(subId string)

+ type SubStubMap map[string]SvcUuid

May 9, 2023

Changes in this version

+ const ProxyConnected

+ const ProxyDisconnected

type IRpc

+ Options func() *Options

type Option

+ func WithCallTrace(open bool) Option

type Options

+ func (o *Options) CallTrace() bool

+ func (o *Options) StackTrace() bool

Jun 30, 2022

Changes in this version

+ const InvalidGlobalIndex

+ const RpcClosed

+ const RpcNotInit

+ const RpcRunning

type IProxy

+ GetGlobalIndex func() protocol.GlobalIndexType

+ SetGlobalIndex func(indexType protocol.GlobalIndexType)

+ type IProxyHandler interface

+ OnRelay func(trans transport.ITransport, header *protocol.RpcMsgHeader) error

type IRpc

+ GetServiceProxy func(uuid uint64, trans transport.ITransport) (IProxy, error)

+ Init func(...Option) error

+ OnProxyMessage func(tran transport.ITransport, ph IProxyHandler) error

+ type ISDK interface

+ GetNickName func() string

+ GetUuid func() uint64

+ IsProxy func() bool

+ Register func(IRpc) error

type IService

+ GetNickName func() string

+ type Option func(*Options)

+ func WithLogger(logger log.ILogger) Option

+ func WithStackTrace(open bool) Option

+ func WithUserData(key, val interface{}) Option

+ type Options struct

+ type PackageInfo struct

+ Creator SdkCreateHandle

+ ServiceUUID uint64

type ProxyBase

+ func (base *ProxyBase) GetGlobalIndex() protocol.GlobalIndexType

+ func (base *ProxyBase) SetGlobalIndex(index protocol.GlobalIndexType)

+ type SdkCreateHandle func(...string) (ISDK, error)

type StubCall

+ func (sc *StubCall) GetBody() []byte

+ func (sc *StubCall) GlobalIndex() protocol.GlobalIndexType

type StubManager

+ func (m *StubManager) UnInit()

Feb 14, 2022

Changes in this version

+ type IRpc interface

+ AddProxyCreator func(uuid uint64, pc ProxyCreator) error

+ AddStubCreator func(uuid uint64, bc StubCreator) error

+ Call func(proxyId IProxy, methodId, timeout uint32, retry int32, message proto.Message) ([]byte, error)

+ GetProxyFromPeer func(sCall *StubCall) (IProxy, error)

+ OnMessage func(trans transport.ITransport, ctx context.Context)

+ RegisterService func(service IService) error

+ ShutDown func() error

+ Start func() error

+ Tick func() error

+ func CreateRpcFramework() IRpc

Feb 11, 2022

Changes in this version

+ type CallUuid uint32

+ type IProxy interface

+ GetID func() ProxyId

+ GetRpc func() IRpc

+ GetSignature func(uint32) string

+ GetSrvName func() string

+ GetTargetID func() uint32

+ GetTransport func() transport.ITransport

+ GetUUID func() uint64

+ IsConnected func() bool

+ IsOneWay func(uint32) bool

+ SetID func(ProxyId)

+ SetRpc func(IRpc)

+ SetTargetID func(uint32)

+ SetTransport func(transport transport.ITransport)

+ type IStub interface

+ Call func(*StubCall, []byte) ([]byte, error)

+ GetMutipleNum func() uint32

+ GetServiceName func() string

+ GetSignature func(methodId uint32) string

+ GetStatus func() ServiceStatus

+ GetUUID func() SvcUuid

+ IsOneWay func(methodId uint32) bool

+ OnAfterFork func() bool

+ OnBeforeDestroy func() bool

+ OnTick func() bool

+ SetStatus func(status ServiceStatus)

+ type ProxyBase struct

+ func (base *ProxyBase) GetID() ProxyId

+ func (base *ProxyBase) GetRpc() IRpc

+ func (base *ProxyBase) GetTargetID() uint32

+ func (base *ProxyBase) GetTransport() transport.ITransport

+ func (base *ProxyBase) IsConnected() bool

+ func (base *ProxyBase) SetID(id ProxyId)

+ func (base *ProxyBase) SetRpc(r IRpc)

+ func (base *ProxyBase) SetTargetID(id uint32)

+ func (base *ProxyBase) SetTransport(trans transport.ITransport)

+ type ProxyCreator func(transport.ITransport) IProxy

+ type ProxyId proxy2.ProxyUuid

+ type ProxyManager struct

+ func (p *ProxyManager) Add(proxy IProxy) error

+ func (p *ProxyManager) Destroy(proxyId uint32) error

+ func (p *ProxyManager) GeneProxyId() ProxyId

+ func (p *ProxyManager) Get(proxyId ProxyId) (IProxy, error)

+ type ProxyMap map[ProxyId]IProxy

+ type ServiceCache map[SvcUuid]*stubWrapper

+ type ServiceStatus uint32

+ const SERVICE_RESOLVED

+ const SERVICE_UPDATING

+ type StubCall struct

+ func (sc *StubCall) CallID() uint32

+ func (sc *StubCall) GetServiceUUID() uint64

+ func (sc *StubCall) GetUUID() CallUuid

+ func (sc *StubCall) MethodID() uint32

+ type StubCreator func(v interface{}) IStub

+ type StubManager struct

+ func (m *StubManager) Add(impl IStub) (err error)

+ func (m *StubManager) GeneUuid() CallUuid

+ func (m *StubManager) Get(uuid SvcUuid) *stubWrapper

+ func (m *StubManager) Init(logger log.ILogger)

+ func (m *StubManager) Tick()

+ type SvcUuid uint64

+ type Trans2Proxy map[uint64]IProxy

Feb 8, 2022

Changes in this version

+ func AddProxyCreator(uuid uint64, pc proxy.ProxyCreator) error

+ func AddStubCreator(uuid uint64, bc stub.StubCreator) error

+ func Init() error

+ func SetRpcLogger(logger rlog.RpcLogger)

+ type IService interface

+ GetUUID func() uint64

+ OnAfterFork func() bool

+ OnBeforeDestroy func() bool

+ OnTick func() bool

+ type ServiceCreator func(interface{}) IService

Jan 21, 2022

Changes in this version

+ func AddCreator(uuid uint64, pc proxy.ProxyCreator) error

+ func AddProxy(proxy proxy.Proxy) error

+ func GetProxyFromPeer(sCall *stub.StubCall) proxy.Proxy

+ func GetProxyManager() *proxy.ProxyManager

+ func GetStubManager() *stub.StubManager

Jul 15, 2021

Changes in this version

+ func Call(stubid, methodid, retry, timeout uint32, message proto.Message) (resp *protocol.ResponsePackage, err error)

+ func GetClientStubMgr() *stub.ClientStubMgr

+ func GetConnMaps() *map[uint64]*RpcConnHandle

+ func GetServerStubMgr() *stub.StubManager

+ func GetStubCallMgr() *stubcall.SrvStubCallMgr

+ func OnMessage(trans transport.Transport, ctx context.Context)

+ func RegisterProxy(proxy stub.ProxyStub) error

+ func RegisterService(uuid uint64, srvstub stub.SrvStub, impl interface{}) error

+ func Start()

+ func Tick()

+ type RpcConnHandle struct

+ func (rc *RpcConnHandle) GetTrans() transport.Transport

+ func (rc *RpcConnHandle) OnClose()

+ func (rc *RpcConnHandle) OnConnect(conn net.IdlConn) bool

+ func (rc *RpcConnHandle) OnRecv(pkg []byte) bool

+ func (rc *RpcConnHandle) Tick() int

+ type RpcListenHandle struct

+ func (rpc *RpcListenHandle) OnAccept(conn net.IdlConn) bool