example

Oct 10, 2023

Changes in this version

type DemoServiceContext

+ func (c *DemoServiceContext) Debug(format string, i ...interface{})

+ type GetInfoCallBack func(ret1 string, err error)

+ type SetInfoCallBack func(err error)

type TestCallerProxy

+ func (sp *TestCallerProxy) GetInfoAsync(ctx idlrpc.IServiceContext, cb GetInfoCallBack) (err error)

+ func (sp *TestCallerProxy) SetInfoAsync(ctx idlrpc.IServiceContext, _1 string, cb SetInfoCallBack) (err error)

type TestCallerStub

+ func (sb *TestCallerStub) GetTimeout(methodIndex uint32) uint32

+ func (sb *TestCallerStub) Return(ctx idlrpc.IServiceContext, methodId uint32, ret interface{}, err error) ([]byte, error)

Aug 8, 2023

Changes in this version

+ type TestMsgHandler struct

+ RawMsgChan chan *testNoRpcMessage

+ func NewTestMsgHandler() *TestMsgHandler

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

+ func (h *TestMsgHandler) OnLoggedOut(index protocol.GlobalIndexType)

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

Jul 6, 2023

Changes in this version

type DemoServiceContext

+ func (c *DemoServiceContext) Clone() idlrpc.IServiceContext

Jun 30, 2023

Changes in this version

+ type DemoServiceContext struct

+ func NewDemoServiceContext() *DemoServiceContext

+ func (c *DemoServiceContext) Error(format string, i ...interface{})

+ func (c *DemoServiceContext) GetIdentityID() string

+ func (c *DemoServiceContext) GetIdentityTag() string

+ func (c *DemoServiceContext) GetProxy(uuid uint64) idlrpc.IProxy

+ func (c *DemoServiceContext) GetProxyFromPeer(uuid uint64) idlrpc.IProxy

+ func (c *DemoServiceContext) GetProxyWithNickname(uint64, string) idlrpc.IProxy

+ func (c *DemoServiceContext) GetTransport() transport.ITransport

+ func (c *DemoServiceContext) Info(format string, i ...interface{})

+ func (c *DemoServiceContext) PushLogHeader(s string)

+ func (c *DemoServiceContext) Warning(format string, i ...interface{})

Jun 28, 2023

Changes in this version

type TransportRing

+ func (trans *TransportRing) IdentityID() string

+ func (trans *TransportRing) IdentityTag() string

+ func (trans *TransportRing) SetIdentityID(s string)

+ func (trans *TransportRing) SetIdentityTag(s string)

Jun 7, 2023

Changes in this version

type TestCallerStub

+ func (sb *TestCallerStub) GetMultipleNum() uint32

Jan 13, 2023

Changes in this version

type TestCallerImpl

+ func (sp *TestCallerImpl) OnCancel(subID string, event string) error

+ func (sp *TestCallerImpl) OnSubscribe(subID string, event string, bytes []byte) error

type TestCallerStub

+ func (sb *TestCallerStub) OnCancel(subID string, event string) error

+ func (sb *TestCallerStub) OnSub(subID string, event string, data []byte) error

May 9, 2023

Changes in this version

type TransportRing

+ func (trans *TransportRing) Heartbeat() error

Jun 30, 2022

Changes in this version

+ const SrvName

+ const SrvUUID

+ func TestCallerProxyCreator(trans transport.ITransport) idlrpc.IProxy

+ func TestCallerStubCreator(v interface{}) idlrpc.IStub

+ type ITestCaller interface

+ GetInfo func(context.Context) (string, error)

+ SetInfo func(context.Context, string) error

+ type TestCallerImpl struct

+ func NewTestCaller() *TestCallerImpl

+ func (sp *TestCallerImpl) GetInfo(ctx context.Context) (ret1 string, err error)

+ func (sp *TestCallerImpl) GetNickName() string

+ func (sp *TestCallerImpl) GetUUID() uint64

+ func (sp *TestCallerImpl) OnAfterFork(ctx context.Context) bool

+ func (sp *TestCallerImpl) OnBeforeDestroy() bool

+ func (sp *TestCallerImpl) OnTick() bool

+ func (sp *TestCallerImpl) SetInfo(ctx context.Context, _1 string) (err error)

+ type TestCallerProxy struct

+ func (sp *TestCallerProxy) GetInfo() (ret1 string, err error)

+ func (sp *TestCallerProxy) GetSignature(methid uint32) string

+ func (sp *TestCallerProxy) GetSrvName() string

+ func (sp *TestCallerProxy) GetUUID() uint64

+ func (sp *TestCallerProxy) IsOneWay(methodid uint32) (isoneway bool)

+ func (sp *TestCallerProxy) SetInfo(_1 string) (err error)

+ type TestCallerStub struct

+ func NewTestCallerStub(srvImpl ITestCaller) *TestCallerStub

+ func (sb *TestCallerStub) Call(ctx context.Context, methodId uint32, req []byte) (resp []byte, err error)

+ func (sb *TestCallerStub) GetInfo(ctx context.Context, req []byte) (resp []byte, err error)

+ func (sb *TestCallerStub) GetMutipleNum() uint32

+ func (sb *TestCallerStub) GetServiceName() string

+ func (sb *TestCallerStub) GetSignature(methodid uint32) string

+ func (sb *TestCallerStub) GetStatus() idlrpc.ServiceStatus

+ func (sb *TestCallerStub) GetUUID() idlrpc.SvcUuid

+ func (sb *TestCallerStub) IsOneWay(methodid uint32) (isoneway bool)

+ func (sb *TestCallerStub) OnAfterFork(ctx context.Context) bool

+ func (sb *TestCallerStub) OnBeforeDestroy() bool

+ func (sb *TestCallerStub) OnTick() bool

+ func (sb *TestCallerStub) SetInfo(ctx context.Context, req []byte) (resp []byte, err error)

+ func (sb *TestCallerStub) SetStatus(status idlrpc.ServiceStatus)

+ type TransportRing struct

+ func NewTransportRing() *TransportRing

+ func (trans *TransportRing) Close()

+ func (trans *TransportRing) GetID() uint32

+ func (trans *TransportRing) GlobalIndex() protocol.GlobalIndexType

+ func (trans *TransportRing) IsClose() bool

+ func (trans *TransportRing) LocalAddr() string

+ func (trans *TransportRing) Peek(length int) ([]byte, int, error)

+ func (trans *TransportRing) PopSend() []byte

+ func (trans *TransportRing) Read(pkg []byte, length int) (int, error)

+ func (trans *TransportRing) RemoteAddr() string

+ func (trans *TransportRing) Send(pkg []byte) error

+ func (trans *TransportRing) SetID(id uint32)

+ func (trans *TransportRing) Size() uint32

+ func (trans *TransportRing) Write(pkg []byte, length int) (int, error)