FastLaneSubscriber | @dronedeploy/rocos-js

Hierarchy

FastLaneSubscriber

Implements

IFastLaneSubscriber

Index

Constructors

constructor

Accessors

uniqueId

Constructors

constructor

new FastLaneSubscriber(projectId: string, callsignsLookup: CallsignsLookup, sources: string[], options: FastLaneSubscriberOptions, fastLaneClient: TelemetryGatewayClient, token: string): FastLaneSubscriber

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:81
Parameters
- projectId: string
- callsignsLookup: CallsignsLookup
- sources: string[]
- options: FastLaneSubscriberOptions
- fastLaneClient: TelemetryGatewayClient
- token: string
Returns FastLaneSubscriber

Properties

Private autoResubscribeEnabled

autoResubscribeEnabled: boolean

Private autoResubscribeMessageLimit

autoResubscribeMessageLimit: number

Private autoResubscribeMinimumTime

autoResubscribeMinimumTime: number

callsignsLookup

callsignsLookup: CallsignsLookup

checkerStartedAt

checkerStartedAt: Date

fastLaneClient

fastLaneClient: TelemetryGatewayClient

Optional instanceId

instanceId: string

Optional instances

instances: string[] = []

Private lastMessageReceived

lastMessageReceived: Date

lastRobotMessageReceived

lastRobotMessageReceived: Date

Private logger

logger: Logger

messageTimeoutInSec

messageTimeoutInSec: number = config.grpc.messageTimeoutInSec

Private messagesTimer

messagesTimer: any

projectId

projectId: string

Private receivedDataStats

receivedDataStats: {}

Type declaration

[callsignAndTopicName: string]: number

Private receivedMessagesCount

receivedMessagesCount: number = 0

Private Optional receiverCall

receiverCall: ResponseStream<TelemetryMessage>

Private refCount

refCount: number = 0

Private retryTimes

retryTimes: number = 0

sources

sources: string[]

subject

subject: Subject<IRocosTelemetryMessage>

subscriberId

subscriberId: string

subscriberStatus

subscriberStatus: SubscriberStatus = SubscriberStatus.UNKNOWN

subscriberStatusSubject

subscriberStatusSubject: BehaviorSubject<SubscriberStatus>

timerIntervalInSec

timerIntervalInSec: number = 1

token

token: string

Accessors

uniqueId

get uniqueId(): string

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:74
Generate a unique id for identification.

Returns string

Methods

Private autoResubscribe

autoResubscribe(): void

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:537
Auto resubscribe to reduce CPU usage.

Returns void

createSubject

createSubject(): void

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:122
Returns void

Private getMetadata

getMetadata(projId?: string): any

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:308
Parameters
- Optional projId: string
Returns any

increaseRefCount

increaseRefCount(): void

Implementation of IFastLaneSubscriber.increaseRefCount
- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:193
Returns void

Private isInstanceLive

isInstanceLive(instanceId: string): boolean

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:565
Parameters
- instanceId: string
Returns boolean

Private isRegisteredMessage

isRegisteredMessage(callsign: string, source: string): boolean

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:553
Parameters
- callsign: string
- source: string
Returns boolean

isSafeToRemove

isSafeToRemove(): boolean

Implementation of IFastLaneSubscriber.isSafeToRemove
- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:202
Returns boolean

Private listenMessagesAndRenew

listenMessagesAndRenew(): void

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:419
Returns void

Private messageTimeoutTryAgain

messageTimeoutTryAgain(): void

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:518
Returns void

Private onData

onData(msg: TelemetryMessage): void

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:206
Parameters
- msg: TelemetryMessage
Returns void

Private onSubscriberIdChanged

onSubscriberIdChanged(): void

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:318
Returns void

Private readOptions

readOptions(options: FastLaneSubscriberOptions): void

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:578
Parameters
- options: FastLaneSubscriberOptions
Returns void

registerReceiver

registerReceiver(): (Anonymous function)

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:129
Returns (Anonymous function)

Private removeInstanceId

removeInstanceId(instanceId: string): void

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:569
Parameters
- instanceId: string
Returns void

Private sendMessageToSubscribers

sendMessageToSubscribers(message: IRocosTelemetryMessage): void

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:301
Parameters
- message: IRocosTelemetryMessage
Returns void

Private subscribeSources

subscribeSources(): void

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:322
Returns void

Private takeTelemetryAction

takeTelemetryAction(actionType: "subscribe" | "unsubscribe"): void

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:329
Parameters
- actionType: "subscribe" | "unsubscribe"
Returns void

toJSON

toJSON(): any

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:107
Returns any

unsubscribe

unsubscribe(instanceId?: string): void

Implementation of IFastLaneSubscriber.unsubscribe
- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:159
Parameters
- Optional instanceId: string
Returns void

Private unsubscribeSources

unsubscribeSources(): void

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:325
Returns void

Private updateReceviedDataStatsWithMessage

updateReceviedDataStatsWithMessage(msg: IRocosTelemetryMessage): void

- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:585
Parameters
- msg: IRocosTelemetryMessage
Returns void

updateToken

updateToken(token: string): void

Implementation of IFastLaneSubscriber.updateToken
- Defined in src/grpc/teletubby/fast-lane-subscriber.ts:189
Parameters
- token: string
Returns void

Hierarchy

Implements

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Parameters

projectId: string

callsignsLookup: CallsignsLookup

sources: string[]

options: FastLaneSubscriberOptions

fastLaneClient: TelemetryGatewayClient

token: string

Returns FastLaneSubscriber

Properties

Private autoResubscribeEnabled

Private autoResubscribeMessageLimit

Private autoResubscribeMinimumTime

callsignsLookup

checkerStartedAt

fastLaneClient

Optional instanceId

Optional instances

Private lastMessageReceived

lastRobotMessageReceived

Private logger

messageTimeoutInSec

Private messagesTimer

projectId

Private receivedDataStats

Type declaration

[callsignAndTopicName: string]: number

Private receivedMessagesCount

Private Optional receiverCall

Private refCount

Private retryTimes

sources

subject

subscriberId

subscriberStatus

subscriberStatusSubject

timerIntervalInSec

token

Accessors

uniqueId

Returns string

Methods

Private autoResubscribe

Returns void

createSubject

Returns void

Private getMetadata

Parameters

Optional projId: string

Returns any

increaseRefCount

Returns void

Private isInstanceLive

Parameters

instanceId: string

Returns boolean

Private isRegisteredMessage

Parameters

callsign: string

source: string

Returns boolean

isSafeToRemove

Returns boolean

Private listenMessagesAndRenew

Returns void

Private messageTimeoutTryAgain

Returns void

Private onData

Parameters

msg: TelemetryMessage

Returns void

Private onSubscriberIdChanged