@openiap/nodeapi / Exports / client
Class: client
Implements
Table of contents
Constructors
Properties
- agent
- call
- connected
- connecting
- created
- doping
- exchanges
- grpc
- grpcStream
- id
- jwt
- lastheartbeat
- lastheartbeatsec
- lastheartbeatstr
- protocol
- queues
- remoteip
- replies
- seq
- signedin
- stream
- streams
- url
- user
- version
- watches
- ws
Methods
Constructors
constructor
• new client()
Properties
agent
• agent: clientAgent
Implementation of
Defined in
call
• call: any
Implementation of
Defined in
connected
• connected: boolean
= false
Implementation of
Defined in
connecting
• connecting: boolean
= false
Implementation of
Defined in
created
• created: Date
Implementation of
Defined in
doping
• doping: boolean
Implementation of
Defined in
exchanges
• exchanges: any
[] = []
Implementation of
Defined in
grpc
• grpc: FlowService
Implementation of
Defined in
grpcStream
• grpcStream: any
Implementation of
Defined in
id
• id: string
= ""
Implementation of
Defined in
jwt
• jwt: string
Implementation of
Defined in
lastheartbeat
• lastheartbeat: Date
Implementation of
Defined in
lastheartbeatsec
• lastheartbeatsec: string
= "0"
Implementation of
Defined in
lastheartbeatstr
• lastheartbeatstr: string
Implementation of
Defined in
protocol
• protocol: clientType
Implementation of
Defined in
queues
• queues: any
[] = []
Implementation of
Defined in
remoteip
• remoteip: string
= "unknown"
Implementation of
Defined in
replies
• replies: any
Implementation of
Defined in
seq
• seq: number
= 0
Implementation of
Defined in
signedin
• signedin: boolean
= false
Implementation of
Defined in
stream
• stream: any
Implementation of
Defined in
streams
• streams: any
Implementation of
Defined in
url
• url: string
Implementation of
Defined in
user
• user: any
Implementation of
Defined in
version
• version: string
Implementation of
Defined in
watches
• watches: changestream
[] = []
Implementation of
Defined in
ws
• ws: any
Implementation of
Defined in
Methods
Close
▸ Close(): void
Returns
void
Implementation of
Defined in
Initialize
▸ Initialize(ws
, stream
, call
, req
): Promise
<boolean
>
Parameters
Name | Type |
---|---|
ws | any |
stream | any |
call | any |
req | any |
Returns
Promise
<boolean
>
Implementation of
Defined in
SendWatch
▸ SendWatch(watch
, next
, span
): void
Parameters
Name | Type |
---|---|
watch | any |
next | any |
span | any |
Returns
void
Implementation of
Defined in
UnWatch
▸ UnWatch(id
, jwt
): Promise
<void
>
Parameters
Name | Type |
---|---|
id | string |
jwt | string |
Returns
Promise
<void
>
Implementation of
Defined in
Watch
▸ Watch(aggregates
, collectionname
, jwt
): Promise
<string
>
Parameters
Name | Type |
---|---|
aggregates | object [] |
collectionname | string |
jwt | string |
Returns
Promise
<string
>
Implementation of
Defined in
onConnected
▸ onConnected(client
): void
Parameters
Name | Type |
---|---|
client | client |
Returns
void
Implementation of
Defined in
onDisconnected
▸ onDisconnected(client
, error
): void
Parameters
Name | Type |
---|---|
client | client |
error | Error |
Returns
void
Implementation of
Defined in
onMessage
▸ onMessage(client
, message
): Promise
<Envelope
>
Parameters
Name | Type |
---|---|
client | client |
message | any |
Returns
Promise
<Envelope
>
Implementation of
Defined in
ping
▸ ping(span
): void
Parameters
Name | Type |
---|---|
span | any |
Returns
void
Implementation of
Defined in
queuecount
▸ queuecount(): number
Returns
number