Options
All
  • Public
  • Public/Protected
  • All
Menu

Class GrpcClient

Hierarchy

  • GrpcClient

Index

Constructors

Properties

Methods

Constructors

constructor

Properties

Private connectionInfo

connectionInfo: any = {} as any

Private gatewayClient

gatewayClient: TelemetryGatewayClient

Private queueForRetry

queueForRetry: any[] = []

Private queueForSubscribing

queueForSubscribing: any[] = []

Private registeringInfo

registeringInfo: any = {} as any

Private robotStatusInfo

robotStatusInfo: any = {} as any

Object for storing robots status information.

Private streamClient

streamClient: StreamClient

Private token

token: string = ""

Methods

Private activeTheRetryQueue

  • activeTheRetryQueue(): void

Private activeWaitingSubscriptionsInTheQueue

  • activeWaitingSubscriptionsInTheQueue(): void

Private checkConnectionInfoProjectId

  • checkConnectionInfoProjectId(projectId: string): void

Private checkToken

  • checkToken(): void

getDebugInfo

  • getDebugInfo(): { connectionInfo: any; queueForRetry: any[]; queueForSubscribing: any[]; registeringInfo: any; token: string }

  • Returns { connectionInfo: any; queueForRetry: any[]; queueForSubscribing: any[]; registeringInfo: any; token: string }

    • connectionInfo: any
    • queueForRetry: any[]
    • queueForSubscribing: any[]
    • registeringInfo: any
    • token: string

Private getMetadata

  • getMetadata(projId?: string): any

Private listenNoopMessagesAndRenew

  • listenNoopMessagesAndRenew(projectId: string): void

Private onData

registerReceiver

  • registerReceiver(projId: string): Observable<any>

Private requestTelemetry

  • requestTelemetry(projectId: string, callsigns: string[], sources: string[]): void

robotStatus

  • robotStatus(projectId: string, callsign: string): Observable<RobotStatus>

searchStream

Private sendMessageToSubscribers

slowLaneQueryData

  • slowLaneQueryData(projectId: string, query: string): Observable<any>

  • Slow lane elasticsearch API call.

    Parameters

    • projectId: string

      Project

    • query: string

      Query string

    Returns Observable<any>

subscribe

  • subscribe(projectId: string, callsigns: string[], sources: string[]): Observable<any>

Private subscribeRegisterReceiver

  • subscribeRegisterReceiver(projectId: string, ob: Observable<any>): void

Private subscribeSources

  • subscribeSources(projectId: string, callsigns: string[], sources: string[]): Observable<any>

  • Subscribe sources

    Parameters

    • projectId: string

      Project Id

    • callsigns: string[]

      Callsigns (Robot ids)

    • sources: string[]

      Sources

    Returns Observable<any>

Private subscribeSourcesInBackground

  • subscribeSourcesInBackground(projectId: string, callsigns: string[], sources: string[]): void

  • Try to subscribe sources - save to waiting queue if haven't got the subscriberId for that project.

    Parameters

    • projectId: string

      Project Id

    • callsigns: string[]

      Robot callsigns

    • sources: string[]

      Sources

    Returns void

Private tryRegisterReceiver

  • tryRegisterReceiver(projectId: string): void

updateToken

  • updateToken(token: string): void

Generated using TypeDoc