idlrpc

Documentation

Index

• func AddProxy(proxy proxy.Proxy) error
• func AddProxyCreator(uuid uint64, pc proxy.ProxyCreator) error
• func AddStubCreator(uuid uint64, bc stub.StubCreator) 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 Init() error
• func OnMessage(trans transport.Transport, ctx context.Context)
• func RegisterService(service IService) error
• func SetRpcLogger(logger rlog.RpcLogger)
• func Start()
• func Tick()
• type IService
• type ServiceCreator

Functions

func AddProxy

func AddProxy(proxy proxy.Proxy) error

AddProxy add remote service proxy to framework

func AddProxyCreator

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

func AddStubCreator

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

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 Init

func Init() error

Init you can do some init operator in this function TODO add rpc init config

func OnMessage

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

OnMessage try to create one rpc message

func RegisterService

func RegisterService(service IService) error

RegisterService register user impl service struct to framework

func SetRpcLogger

func SetRpcLogger(logger rlog.RpcLogger)

SetRpcLogger replace rpc framework logger

func Start

func Start()

Start start rpc framework

func Tick

func Tick()

Tick tick rpc frame work

Types

type IService

type IService interface {

	// GetUUID service uuid, generated by rpc-repo
	GetUUID() uint64

	// OnAfterFork init service by framework, user can init some custom data in this function
	OnAfterFork() bool

	// OnTick tick your service the same goroutine
	OnTick() bool

	// OnBeforeDestroy before service unload, you can clean your own data in this func
	OnBeforeDestroy() bool
}

IService user custom service framework interface

type ServiceCreator

type ServiceCreator func(interface{}) IService

ServiceCreator service creator