pinus-rpc

Index

Classes

Interfaces

Type aliases

Functions

Object literals

constants

Type aliases

MailBoxFactory

MailBoxFactory: function

Type declaration

- (serverInfo: object, opts: MailBoxOpts): MailBox
- Parameters
  - serverInfo: object
    - host: string
    - id: string
    - port: number
  - opts: MailBoxOpts
  Returns MailBox

MailBoxTimeoutCallback

MailBoxTimeoutCallback: function

Type declaration

- (tracer: Tracer, err: Error, resp?: any): void
- Parameters
  - tracer: Tracer
  - err: Error
  - Optional resp: any
  Returns void

MailStationErrorHandler

MailStationErrorHandler: function

Type declaration

- (err: Error, serverId: string, msg: any, opts: any): void
- Parameters
  - err: Error
  - serverId: string
  - msg: any
  - opts: any
  Returns void

Proxies

Proxies: object

Type declaration

[namespace: string]: object
- [serverType: string]: object
  - [attr: string]: Function

ProxyCallback

ProxyCallback: function

Type declaration

- (serviceName: string, methodName: string, args: any[], attach: any, isToSpecifiedServer?: boolean): Promise<any>
- Parameters
  - serviceName: string
  - methodName: string
  - args: any[]
  - attach: any
  - Optional isToSpecifiedServer: boolean
  Returns Promise<any>

RemoteMethod

RemoteMethod: function

Type declaration

- (...args: any[]): Promise<any>
- Parameters
  - Rest ...args: any[]
  Returns Promise<any>

Remoter

Remoter: object

Type declaration

[method: string]: RemoteMethod

Remoters

Remoters: object

Type declaration

[service: string]: Remoter

Router

Router: defRoute | object

RpcFilter

RpcFilter: RpcFilterFunction | IRpcFilter

RpcFilterFunction

RpcFilterFunction: function

Type declaration

- (serverId: string, msg: any, opts: any, next: function): void
- Parameters
  - serverId: string
  - msg: any
  - opts: any
  - next: function
    - - (target?: Error | string, message?: any, options?: any): void
      - Parameters
        
        Optional target: Error | string
        
        Optional message: any
        
        Optional options: any
        
        Returns void
  Returns void

Services

Services: object

Type declaration

[namespace: string]: Remoters

Variables

BUFFER_SIZE_DEFAULT

BUFFER_SIZE_DEFAULT: number = 32

CONNECT_TIMEOUT

CONNECT_TIMEOUT: number = 2000

Composer

Composer: any = require('stream-pkg')

DEFAULT_CALLBACK_TIMEOUT

DEFAULT_CALLBACK_TIMEOUT: number = 10 * 1000

DEFAULT_INTERVAL

DEFAULT_INTERVAL: number = 50

DEFAULT_ZIP_LENGTH

DEFAULT_ZIP_LENGTH: number = 1024 * 10

KEEP_ALIVE_INTERVAL

KEEP_ALIVE_INTERVAL: number = 30 * 1000

KEEP_ALIVE_TIMEOUT

KEEP_ALIVE_TIMEOUT: number = 10 * 1000

MqttCon

MqttCon: any = require('mqtt-connection')

STATE_CLOSED

STATE_CLOSED: number = 3

STATE_INITED

STATE_INITED: number = 1

Client states

STATE_STARTED

STATE_STARTED: number = 2

ch

ch: chRoute = chRoute

checkArray

checkArray: (Anonymous function) = Array.isArray || isType("Array")

Utils check array

param
returns: true|false
api: public

checkBoolean

checkBoolean: (Anonymous function) = isType("Boolean")

Utils check boolean

param: object
returns: true|false
api: public

checkFunction

checkFunction: (Anonymous function) = isType("Function")

Utils check function

param: function
returns: true|false
api: public

checkNumber

checkNumber: (Anonymous function) = isType("Number")

Utils check number

param
returns: true|false
api: public

checkObject

checkObject: (Anonymous function) = isType("Object")

Utils check object

param: object
returns: true|false
api: public

checkString

checkString: (Anonymous function) = isType("String")

Utils check string

param
returns: true|false
api: public

curId

curId: number = 1

df

df: defRoute = defRoute

la

la: laRoute = laRoute

logger

logger: Logger = getLogger('pinus-rpc', 'ws-acceptor')

rd

rd: rdRoute = rdRoute

rr

rr: rrRoute = rrRoute

typeArray

typeArray: string[] = ['', 'null', 'buffer', 'array', 'string', 'object', 'bean', 'boolean', 'float', 'number']

typeMap

typeMap: any

useZipCompress

useZipCompress: boolean = false

wrr

wrr: wrrRoute = wrrRoute

Functions

addToPending

addToPending(tracer: Tracer, station: object, serverId: string, args: IArguments): void

- Defined in rpc-client/mailstation.ts:504
Parameters
- tracer: Tracer
- station: object
  - [key: string]: any
- serverId: string
- args: IArguments
Returns void

applyCallback

applyCallback(cb: Function, args: any[]): void

- Defined in util/utils.ts:10
Parameters
- cb: Function
- args: any[]
Returns void

chRoute

chRoute(client: RpcClient, serverType: string, msg: RpcMsg, cb: function): void

- Defined in rpc-client/router.ts:223
Consistent-Hash algorithm for calculating server id.

Parameters
- client: RpcClient
  
  rpc client.
- serverType: string
  
  rpc target serverType.
- msg: RpcMsg
  
  rpc message.
- cb: function
  
  cb(err, serverId).
  - - (err: Error, serverId?: string): void
    - Parameters
      - err: Error
      - Optional serverId: string
      Returns void
Returns void

checkBean

checkBean(obj: any): boolean

- Defined in util/utils.ts:145
Utils check bean

Parameters
- obj: any
  
  object
Returns boolean

true|false

checkFloat

checkFloat(v: any): boolean

- Defined in util/utils.ts:64
Utils check float

api

public

Parameters
- v: any
Returns boolean

true|false

checkNull

checkNull(obj: any): boolean

- Defined in util/utils.ts:152
Parameters
- obj: any
Returns boolean

compare

compare(v1: string, v2: string): number

- Defined in util/consistentHash.ts:15
Parameters
- v1: string
- v2: string
Returns number

create

create(server: object, opts: MailBoxOpts): MailBox

- Defined in rpc-client/mailboxes/mqtt-mailbox.ts:372
Factory method to create mailbox

Parameters
- server: object
  
  remote server info {id:"", host:"", port:""}
  - host: string
  - id: string
  - port: number
- opts: MailBoxOpts
  
  construct parameters opts.origin {Object} delegated object opts.proxyCB {Function} proxy invoke callback opts.service {String} deletgated service name opts.attach {Object} attach parameter pass to proxyCB
Returns MailBox

proxy instance

createAcceptor

createAcceptor(opts: AcceptorOpts, cb: function): MQTTAcceptor

- Defined in rpc-server/acceptor.ts:5
Parameters
- opts: AcceptorOpts
- cb: function
  - - (tracer: Tracer, msg?: any, cb?: Function): void
    - Parameters
      - tracer: Tracer
      - Optional msg: any
      - Optional cb: Function
      Returns void
Returns MQTTAcceptor

createClient

createClient(opts: RpcClientOpts): RpcClient

- Defined in rpc-client/client.ts:552
RPC client factory method.

Parameters
- opts: RpcClientOpts
  
  client init parameter. opts.context: mail box init parameter, opts.router: (optional) rpc message route function, route(routeParam, msg, cb), opts.mailBoxFactory: (optional) mail box factory instance.
Returns RpcClient

client instance.

createGateway

createGateway(opts: RpcServerOpts): Gateway

- Defined in rpc-server/gateway.ts:117
create and init gateway

Parameters
- opts: RpcServerOpts
  
  , connector:conFactory(optional), router:routeFunction(optional)}
Returns Gateway

createMailBox

createMailBox(serverInfo: object, opts: MailBoxOpts): MailBox

- Defined in rpc-client/mailbox.ts:18
default mailbox factory

Parameters
- serverInfo: object
  
  single server instance info, {id, host, port, ...}
  - host: string
  - id: string
  - port: number
- opts: MailBoxOpts
  
  construct parameters
Returns MailBox

mailbox instancef

createMailStation

createMailStation(opts?: MailStationOpts, mailboxFactory?: MailBoxFactory): MailStation

- Defined in rpc-client/mailstation.ts:562
Mail station factory function.

Parameters
- Optional opts: MailStationOpts
  
  construct paramters opts.servers {Object} global server info map. {serverType: [{id, host, port, ...}, ...]} opts.mailboxFactory {Function} mailbox factory function
- Optional mailboxFactory: MailBoxFactory
Returns MailStation

mail station instance

createNamespace

createNamespace(namespace: string, proxies: object): void
createNamespace(namespace: string, proxies: Services): void

- Defined in rpc-server/gateway.ts:128
Parameters
- namespace: string
- proxies: object
  - [key: string]: object
Returns void
- Defined in rpc-server/server.ts:28
Parameters
- namespace: string
- proxies: Services
Returns void

createServer

createServer(opts: RpcServerOpts): Gateway

- Defined in rpc-server/server.ts:44
Create rpc server.

Parameters
- opts: RpcServerOpts
  
  construct parameters opts.port {Number|String} rpc server listen port opts.paths {Array} remote service code paths, [{namespace, path}, ...] opts.context {Object} context for remote service opts.acceptorFactory {Object} (optionals)acceptorFactory(opts, cb)
Returns Gateway

rpc server instance

createStation

createStation(opts: RpcClientOpts): MailStation

- Defined in rpc-client/client.ts:312
Create mail station.

Parameters
- opts: RpcClientOpts
  
  construct parameters.
Returns MailStation

decodeClient

decodeClient(buf: Buffer): object

- Defined in util/coder.ts:74
Parameters
- buf: Buffer
Returns object
- id: number
- resp: string | object | (string | object)[]

decodeServer

decodeServer(buf: Buffer, servicesMap: object): object

- Defined in util/coder.ts:48
Parameters
- buf: Buffer
- servicesMap: object
  - [key: number]: any
Returns object
- id: number
- msg: object
  - args: string | object | (string | object)[]
  - method: any
  - namespace: any
  - service: any

defRoute

defRoute(session: object, msg: RpcMsg, context: object, cb: function): void

- Defined in rpc-client/router.ts:13
Calculate route info and return an appropriate server id.

Parameters
- session: object
  
  session object for current rpc request
  - [key: string]: any
- msg: RpcMsg
  
  rpc message. {serverType, service, method, args, opts}
- context: object
  
  context of client
  - [key: string]: any
- cb: function
  - - (err: Error, serverId?: string): void
    - Parameters
      - err: Error
      - Optional serverId: string
      Returns void
Returns void

doFilter

doFilter(tracer: Tracer, err: Error, serverId: string, msg: MailBoxMessage, opts: object, filters: Array<RpcFilter>, index: number, operate: "before" | "after", cb: Function): void

- Defined in rpc-client/mailstation.ts:435
Do before or after filter

Parameters
- tracer: Tracer
- err: Error
- serverId: string
- msg: MailBoxMessage
- opts: object
- filters: Array<RpcFilter>
- index: number
- operate: "before" | "after"
- cb: Function
Returns void

encodeClient

encodeClient(id: number, msg: Msg, servicesMap: object): Buffer

- Defined in util/coder.ts:17
Parameters
- id: number
- msg: Msg
- servicesMap: object
  - [key: number]: any
Returns Buffer

encodeServer

encodeServer(id: number, args: object): Buffer

- Defined in util/coder.ts:39
Parameters
- id: number
- args: object
Returns Buffer

errorHandler

errorHandler(tracer: Tracer, station: MailStation, err: Error, serverId: string, msg: object, opts: object, flag: boolean, cb: Function): void

- Defined in rpc-client/mailstation.ts:542
Parameters
- tracer: Tracer
- station: MailStation
- err: Error
- serverId: string
- msg: object
- opts: object
- flag: boolean
- cb: Function
Returns void

failback

failback(code: number, tracer: object, serverId: string, msg: object, opts: object, cb: Function): void

- Defined in rpc-client/failureProcess.ts:160
Failback rpc failure process. This will try the same server with sendInterval option and retries option.

Parameters
- code: number
  
  error code number.
- tracer: object
  
  current rpc tracer.
  - [key: string]: any
- serverId: string
  
  rpc remote target server id.
- msg: object
  
  rpc message.
  - serverType: string
- opts: object
  
  rpc client options.
  - [key: string]: any
- cb: Function
  
  user rpc callback.
Returns void

failfast

failfast(code: number, tracer: object, serverId: string, msg: object, opts: object, cb: Function): void

- Defined in rpc-client/failureProcess.ts:177
Failfast rpc failure process. This will ignore error in rpc client.

Parameters
- code: number
  
  error code number.
- tracer: object
  
  current rpc tracer.
  - [key: string]: any
- serverId: string
  
  rpc remote target server id.
- msg: object
  
  rpc message.
  - serverType: string
- opts: object
  
  rpc client options.
  - [key: string]: any
- cb: Function
  
  user rpc callback.
Returns void

failover

failover(this: any, code: number, tracer: object, serverId: string, msg: object, opts: object, cb: Function): void

- Defined in rpc-client/failureProcess.ts:53
Failover rpc failure process. This will try other servers with option retries.

Parameters
- this: any
- code: number
  
  error code number.
- tracer: object
  
  current rpc tracer.
  - servers: object
- serverId: string
  
  rpc remote target server id.
- msg: object
  
  rpc message.
  - serverType: string
- opts: object
  
  rpc client options.
- cb: Function
  
  user rpc callback.
Returns void

failsafe

failsafe(this: any, code: number, tracer: object, serverId: string, msg: object, opts: object, cb: Function): void

- Defined in rpc-client/failureProcess.ts:96
Failsafe rpc failure process.

Parameters
- this: any
- code: number
  
  error code number.
- tracer: object
  
  current rpc tracer.
  - [key: string]: any
- serverId: string
  
  rpc remote target server id.
- msg: object
  
  rpc message.
  - serverType: string
- opts: object
  
  rpc client options.
  - [key: string]: any
- cb: Function
  
  user rpc callback.
Returns void

failureProcess

failureProcess(this: any, code: string, tracer: any, serverId: string, msg: object, opts: object): void

- Defined in rpc-client/failureProcess.ts:6
Parameters
- this: any
- code: string
- tracer: any
- serverId: string
- msg: object
- opts: object
  - failMode: string
Returns void

flushPending

flushPending(tracer: Tracer, station: object, serverId: string, cb?: Function): void

- Defined in rpc-client/mailstation.ts:521
Parameters
- tracer: Tracer
- station: object
  - [key: string]: any
- serverId: string
- Optional cb: Function
Returns void

genFunctionProxy

genFunctionProxy(serviceName: string, methodName: string, origin: any, attach: boolean, proxyCB: ProxyCallback): Proxy

- Defined in util/proxy.ts:63
Generate prxoy for function type field

Parameters
- serviceName: string
  
  delegated service name
- methodName: string
  
  delegated method name
- origin: any
  
  origin object
- attach: boolean
- proxyCB: ProxyCallback
  
  proxy callback function
Returns Proxy

function proxy

genObjectProxy

genObjectProxy(serviceName: string, origin: any, attach: any, proxyCB: ProxyCallback): object

- Defined in util/proxy.ts:32
Parameters
- serviceName: string
- origin: any
- attach: any
- proxyCB: ProxyCallback
Returns object
- [key: string]: Proxy

generateProxy

generateProxy(client: RpcClient, record: RemoteServerCode, context: object): object

- Defined in rpc-client/client.ts:326
Generate proxies for remote servers.

Parameters
- client: RpcClient
  
  current client instance.
- record: RemoteServerCode
  
  proxy reocrd info. {namespace, serverType, path}
- context: object
  
  mailbox init context parameter
Returns object
- [key: string]: any

getBearcat

getBearcat(): any

- Defined in util/utils.ts:251
Returns any

getKeysLength

getKeysLength<T>(map: object): number

- Defined in util/consistentHash.ts:5
Type parameters
- T
Parameters
- map: object
  - [key: string]: T
Returns number

getModule

getModule(module: string): string

- Defined in util/tracer.ts:4
Parameters
- module: string
Returns string

getObjectClass

getObjectClass(obj: Object): string

- Defined in util/utils.ts:18
Parameters
- obj: Object
Returns string

getRouteTarget

getRouteTarget(client: RpcClient, serverType: string, msg: RpcMsg, routeParam: object, cb: function): void

- Defined in rpc-client/client.ts:428
Calculate remote target server id for rpc client.

Parameters
- client: RpcClient
  
  current client instance.
- serverType: string
  
  remote server type.
- msg: RpcMsg
- routeParam: object
  
  mailbox init context parameter.
- cb: function
  
  return rpc remote target server id.
  - - (err: Error, serverId: string): void
    - Parameters
      - err: Error
      - serverId: string
      Returns void
Returns void

getType

getType(object: any): any

- Defined in util/utils.ts:191
Parameters
- object: any
Returns any

hash

hash(algorithm: string, str: string): string

- Defined in util/consistentHash.ts:10
Parameters
- algorithm: string
- str: string
Returns string

insertProxy

insertProxy(proxies: Proxies, namespace: string, serverType: string, proxy: object): void

- Defined in rpc-client/client.ts:528
Add proxy into array.

Parameters
- proxies: Proxies
  
  rpc proxies
- namespace: string
  
  rpc namespace sys/user
- serverType: string
  
  rpc remote server type
- proxy: object
  
  rpc proxy
  - [key: string]: any
Returns void

invokeCallback

invokeCallback(cb: Function, err: Error): void

- Defined in util/utils.ts:2
Parameters
- cb: Function
- err: Error
Returns void

isNotNull

isNotNull(value: any): boolean

- Defined in util/utils.ts:184
Utils check is not null

Parameters
- value: any
Returns boolean

true|false

isType

isType(type: any): (Anonymous function)

- Defined in util/utils.ts:77
Utils check type

api

public

Parameters
- type: any
Returns (Anonymous function)

high order function

laRoute

laRoute(client: RpcClient & object, serverType: string, msg: RpcMsg, cb: function): void

- Defined in rpc-client/router.ts:163
Least-Active algorithm for calculating server id.

Parameters
- client: RpcClient & object
  
  rpc client.
- serverType: string
  
  rpc target serverType.
- msg: RpcMsg
  
  rpc message.
- cb: function
  
  cb(err, serverId).
  - - (err: Error, serverId?: string): void
    - Parameters
      - err: Error
      - Optional serverId: string
      Returns void
Returns void

lazyConnect

lazyConnect(tracer: Tracer, station: object, serverId: string, factory: MailBoxFactory, cb: Function): boolean

- Defined in rpc-client/mailstation.ts:482
Parameters
- tracer: Tracer
- station: object
  - [key: string]: any
- serverId: string
- factory: MailBoxFactory
- cb: Function
Returns boolean

listEs6ClassMethods

listEs6ClassMethods(objInstance: object): string[]

- Defined in util/utils.ts:260
列出ES6的一个Class实例上的所有方法，但不包括父类的

Parameters
- objInstance: object
  - [key: string]: any
Returns string[]

loadRemoteServices

loadRemoteServices(paths: Array<RemoteServerCode>, context: object, res: Services): Services

- Defined in rpc-server/server.ts:6
Parameters
- paths: Array<RemoteServerCode>
- context: object
- res: Services
Returns Services

proxyCB

proxyCB(client: RpcClient, serviceName: string, methodName: string, args: Array<any>, attach: object, isToSpecifiedServer: boolean): Promise<Object>

- Defined in rpc-client/client.ts:362
Generate prxoy for function type field

Parameters
- client: RpcClient
  
  current client instance.
- serviceName: string
  
  delegated service name.
- methodName: string
  
  delegated method name.
- args: Array<any>
  
  rpc invoke arguments.
- attach: object
  
  attach parameter pass to proxyCB.
  - [key: string]: any
- isToSpecifiedServer: boolean
  
  true means rpc route to specified remote server.
Returns Promise<Object>

rdRoute

rdRoute(client: RpcClient, serverType: string, msg: RpcMsg, cb: function): void

- Defined in rpc-client/router.ts:34
Random algorithm for calculating server id.

Parameters
- client: RpcClient
  
  rpc client.
- serverType: string
  
  rpc target serverType.
- msg: RpcMsg
  
  rpc message.
- cb: function
  
  cb(err, serverId).
  - - (err: Error, serverId?: string): void
    - Parameters
      - err: Error
      - Optional serverId: string
      Returns void
Returns void

rpcToSpecifiedServer

rpcToSpecifiedServer(client: RpcClient, msg: RpcMsg, serverType: string, serverId: string, cb: ErrorCallback<__type>): void

- Defined in rpc-client/client.ts:488
Rpc to specified server id or servers.

Parameters
- client: RpcClient
  
  current client instance.
- msg: RpcMsg
  
  rpc message.
- serverType: string
  
  remote server type.
- serverId: string
  
  mailbox init context parameter.
- cb: ErrorCallback<__type>
Returns void

rrRoute

rrRoute(client: RpcClient & object, serverType: string, msg: RpcMsg, cb: function): void

- Defined in rpc-client/router.ts:54
Round-Robin algorithm for calculating server id.

Parameters
- client: RpcClient & object
  
  rpc client.
- serverType: string
  
  rpc target serverType.
- msg: RpcMsg
  
  rpc message.
- cb: function
  
  cb(err, serverId).
  - - (err: Error, serverId?: string): void
    - Parameters
      - err: Error
      - Optional serverId: string
      Returns void
Returns void

to_array

to_array(args: any[]): any[]

- Defined in util/utils.ts:164
Utils args to array

Parameters
- args: any[]
  
  arguments
Returns any[]

array

wrrRoute

wrrRoute(client: RpcClient, serverType: string, msg: RpcMsg, cb: function): void

- Defined in rpc-client/router.ts:90
Weight-Round-Robin algorithm for calculating server id.

Parameters
- client: RpcClient
  
  rpc client.
- serverType: string
  
  rpc target serverType.
- msg: RpcMsg
  
  rpc message.
- cb: function
  
  cb(err, serverId).
  - - (err: Error, serverId?: string): void
    - Parameters
      - err: Error
      - Optional serverId: string
      Returns void
Returns void

Object literals

constants

constants: object

TOPIC_HANDSHAKE

TOPIC_HANDSHAKE: string = "h"

TOPIC_RPC

TOPIC_RPC: string = "r"

DEFAULT_PARAM

DEFAULT_PARAM: object

CALLBACK_TIMEOUT

CALLBACK_TIMEOUT: number = 30 * 1000

DEFAULT_PENDING_SIZE

DEFAULT_PENDING_SIZE: number = 10000

FAILSAFE_CONNECT_TIME

FAILSAFE_CONNECT_TIME: number = 5 * 1000

FAILSAFE_RETRIES

FAILSAFE_RETRIES: number = 3

GRACE_TIMEOUT

GRACE_TIMEOUT: number = 3 * 1000

INTERVAL

INTERVAL: number = 50

KEEPALIVE

KEEPALIVE: number = 10 * 1000

FAIL_MODE

FAIL_MODE: object

FAILBACK

FAILBACK: string = "failback"

FAILFAST

FAILFAST: string = "failfast"

FAILOVER

FAILOVER: string = "failover"

FAILSAFE

FAILSAFE: string = "failsafe"

RPC_ERROR

RPC_ERROR: object

FAIL_CONNECT_SERVER

FAIL_CONNECT_SERVER: number = 3

FAIL_FIND_MAILBOX

FAIL_FIND_MAILBOX: number = 4

FAIL_SEND_MESSAGE

FAIL_SEND_MESSAGE: number = 5

FILTER_ERROR

FILTER_ERROR: number = 6

NO_TRAGET_SERVER

NO_TRAGET_SERVER: number = 2

SERVER_NOT_STARTED

SERVER_NOT_STARTED: number = 1

SCHEDULE

SCHEDULE: object

CONSISTENT_HASH

CONSISTENT_HASH: string = "ch"

LEAST_ACTIVE

LEAST_ACTIVE: string = "la"

ROUNDROBIN

ROUNDROBIN: string = "rr"

WEIGHT_ROUNDROBIN

WEIGHT_ROUNDROBIN: string = "wrr"

Index

Classes

Interfaces

Type aliases

Variables

Functions

Object literals

Type aliases

MailBoxFactory

Type declaration

Parameters

serverInfo: object

host: string

id: string

port: number

opts: MailBoxOpts

Returns MailBox

MailBoxTimeoutCallback

Type declaration

Parameters

tracer: Tracer

err: Error

Optional resp: any

Returns void

MailStationErrorHandler

Type declaration

Parameters

err: Error

serverId: string

msg: any

opts: any

Returns void

Proxies

Type declaration

[namespace: string]: object

[serverType: string]: object

[attr: string]: Function

ProxyCallback

Type declaration

Parameters

serviceName: string

methodName: string

args: any[]

attach: any

Optional isToSpecifiedServer: boolean

Returns Promise<any>

RemoteMethod

Type declaration

Parameters

Rest ...args: any[]

Returns Promise<any>

Remoter

Type declaration

[method: string]: RemoteMethod

Remoters

Type declaration

[service: string]: Remoter

Router

RpcFilter

RpcFilterFunction

Type declaration

Parameters

serverId: string

msg: any

opts: any

next: function

Parameters

Optional target: Error | string

Optional message: any

Optional options: any

Returns void

Returns void

Services

Type declaration

[namespace: string]: Remoters

Variables

BUFFER_SIZE_DEFAULT

CONNECT_TIMEOUT

Composer

DEFAULT_CALLBACK_TIMEOUT