idlrpc

Documentation

Index

• func AddCreator(uuid uint64, pc proxy.ProxyCreator) error
• func AddProxy(proxy proxy.Proxy) error
• func Call(proxyId proxy.ProxyId, methodId, timeout uint32, retry int32, ...) (resp *protocol.ResponsePackage, err error)
• func GetProxyFromPeer(sCall *stub.StubCall) proxy.Proxy
• func GetProxyManager() *proxy.ProxyManager
• func GetStubManager() *stub.StubManager
• func OnMessage(trans transport.Transport, ctx context.Context)
• func RegisterService(service stub.Stub) error
• func Start()
• func Tick()

Functions

func AddCreator

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

func AddProxy

func AddProxy(proxy proxy.Proxy) error

AddProxy add remote service proxy to framework

func Call

func Call(proxyId proxy.ProxyId, methodId, timeout uint32, retry int32, message proto.Message) (resp *protocol.ResponsePackage, err error)

Call service proxy call remote sync

func GetProxyFromPeer

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

func GetProxyManager

func GetProxyManager() *proxy.ProxyManager

func GetStubManager

func GetStubManager() *stub.StubManager

func OnMessage

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

OnMessage try to create one rpc message

func RegisterService

func RegisterService(service stub.Stub) error

RegisterService register user impl service struct to framework

func Start

func Start()

Start start rpc framework

func Tick

func Tick()

Tick tick rpc frame work