Options
All
  • Public
  • Public/Protected
  • All
Menu

Class FastLaneStream

Hierarchy

  • FastLaneStream

Index

Constructors

Properties

Methods

Constructors

constructor

Properties

Private autoResubscribeEnabled

autoResubscribeEnabled: boolean

Private autoResubscribeMessageLimit

autoResubscribeMessageLimit: number

Private autoResubscribeMinimumTime

autoResubscribeMinimumTime: number

Private callsignsLookup

callsignsLookup: CallsignsLookup

Private checkerStartedAt

checkerStartedAt: Date

Private fastLaneClient

fastLaneClient: TelemetryGatewayClient

Private lastMessageReceived

lastMessageReceived: Date

Private lastRobotMessageReceived

lastRobotMessageReceived: Date

Private logger

logger: Logger

Optional messageSubject

messageSubject: Subject<IRocosTelemetryMessage>

Private messageTimeoutInSec

messageTimeoutInSec: number = config.grpc.messageTimeoutInSec

Private messagesTimer

messagesTimer: any

Private projectId

projectId: string

Private receivedDataStats

receivedDataStats: {}

Type declaration

  • [callsignAndTopicName: string]: number

Private receivedMessagesCount

receivedMessagesCount: number = 0

Private Optional receiverCall

receiverCall: ResponseStream<TelemetryMessage>

Private retryTimes

retryTimes: number = 0

Private scope

scope: string

Private sources

sources: string[]

statusSubject

statusSubject: BehaviorSubject<SubscriberStatus>

Private subscriberId

subscriberId: string

Private subscriberStatus

subscriberStatus: SubscriberStatus = SubscriberStatus.UNKNOWN

Private subscriptions

subscriptions: Map<string, ISubscriptionDataExtended> = new Map()

Private timerIntervalInSec

timerIntervalInSec: number = 1

Private token

token: string

Static Private instances

instances: Map<string, FastLaneStream> = new Map()

Methods

addSubscription

Private autoResubscribe

  • autoResubscribe(): void

Private getMetadata

  • getMetadata(projId?: string): any

Private getSubscriptions

  • getSubscriptions(): Record<string, string[]>

init

  • init(): void

Private isFoundCallsign

  • isFoundCallsign(callsign: string): boolean

Private isFoundSource

  • isFoundSource(source: string): boolean

Private isRegisteredMessage

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

Private listenMessagesAndRenew

  • listenMessagesAndRenew(): void

Private messageTimeoutTryAgain

  • messageTimeoutTryAgain(): void

Private onData

  • onData(msg: TelemetryMessage): void

Private onEnd

  • onEnd(status?: Status): void

Private readOptions

Private registerReceiver

  • registerReceiver(): (Anonymous function)

removeSubscription

Private takeTelemetryAction

  • takeTelemetryAction(actionType: "subscribe" | "unsubscribe", callsignsLookup?: CallsignsLookup, sources?: string[]): void

toJSON

  • toJSON(): any

Private updateReceviedDataStatsWithMessage

updateToken

  • updateToken(token: string): void

Static createInstance

Static getInstance

Generated using TypeDoc