rpc

Documentation

Index

• func OnInit(s core.IService, opt ...Option) (err error)
• func OnRegisterRpcData(d interface{}, sf func(d interface{}) ([]byte, error), ...)
• func Register(id string, f interface{}) (err error)
• func RegisterGO(id string, f interface{}) (err error)
• func RpcId() (rpcId string, err error)
• func UnRegister(id string, f interface{}) (err error)
• type IRpcClient
  • func NewRpcClient(sId, rId string) (clent IRpcClient, err error)
• type IRpcServer
• type Option
  • func Id(v string) Option
  • func Log(v bool) Option
  • func MaxCoroutine(v int) Option
  • func NatsAddr(v string) Option
  • func RpcExpired(v int) Option
• type Options

Functions

func OnInit

func OnInit(s core.IService, opt ...Option) (err error)

func OnRegisterRpcData

func OnRegisterRpcData(d interface{}, sf func(d interface{}) ([]byte, error), unsf func(dataType reflect.Type, d []byte) (interface{}, error))

func Register

func Register(id string, f interface{}) (err error)

func RegisterGO

func RegisterGO(id string, f interface{}) (err error)

func RpcId

func RpcId() (rpcId string, err error)

func UnRegister

func UnRegister(id string, f interface{}) (err error)

Types

type IRpcClient

type IRpcClient interface {
	Done() (err error)
	Call(_func string, params ...interface{}) (interface{}, error)
	CallNR(_func string, params ...interface{}) (err error)
}

func NewRpcClient

func NewRpcClient(sId, rId string) (clent IRpcClient, err error)

type IRpcServer

type IRpcServer interface {
	RpcId() string
	Register(id string, f interface{})
	RegisterGO(id string, f interface{})
	UnRegister(id string, f interface{})
	Done() (err error)
}

type Option

type Option func(*Options)

func Id

func Id(v string) Option

func Log

func Log(v bool) Option

func MaxCoroutine

func MaxCoroutine(v int) Option

func NatsAddr

func NatsAddr(v string) Option

func RpcExpired

func RpcExpired(v int) Option

type Options

type Options struct {
	NatsAddr     string
	MaxCoroutine int
	RpcExpired   int
	Log          bool
	// contains filtered or unexported fields
}