Options
All
  • Public
  • Public/Protected
  • All
Menu

Class MonitorAgent

MonitorAgent Constructor

class

MasterAgent

constructor
param

construct parameter opts.consoleService {Object} consoleService opts.id {String} server id opts.type {String} server type, 'master', 'connector', etc. opts.info {Object} more server info for current server, {id, serverType, host, port}

api

public

Hierarchy

  • EventEmitter
    • MonitorAgent

Index

Constructors

constructor

Properties

callbacks

callbacks: object

Type declaration

consoleService

consoleService: ConsoleService

id

id: string

info

opts

reqId

reqId: number = 1

socket

socket: MqttClient

state

state: number = ST_INITED

type

type: string

Static defaultMaxListeners

defaultMaxListeners: number

Methods

addListener

  • addListener(event: string | symbol, listener: function): this
  • Parameters

    • event: string | symbol
    • listener: function
        • (...args: any[]): void
        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns this

close

  • close(): void

connect

  • connect(port: number, host: string, cb: function): void
  • register and connect to master server

    api

    public

    Parameters

    • port: number
    • host: string
    • cb: function

      callback function

        • (err?: Error): void
        • Parameters

          • Optional err: Error

          Returns void

    Returns void

doSend

  • doSend(topic: string, msg: any): void

emit

  • emit(event: string | symbol, ...args: any[]): boolean
  • Parameters

    • event: string | symbol
    • Rest ...args: any[]

    Returns boolean

eventNames

  • eventNames(): Array<string | symbol>
  • Returns Array<string | symbol>

get

  • get(moduleId: string): any

getMaxListeners

  • getMaxListeners(): number
  • Returns number

listenerCount

  • listenerCount(type: string | symbol): number
  • Parameters

    • type: string | symbol

    Returns number

listeners

  • listeners(event: string | symbol): Function[]
  • Parameters

    • event: string | symbol

    Returns Function[]

notify

  • notify(moduleId: string, msg: any): void
  • notify master server without callback

    api

    public

    Parameters

    • moduleId: string

      module id/name

    • msg: any

      message

    Returns void

on

  • on(event: string | symbol, listener: function): this
  • Parameters

    • event: string | symbol
    • listener: function
        • (...args: any[]): void
        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns this

once

  • once(event: string | symbol, listener: function): this
  • Parameters

    • event: string | symbol
    • listener: function
        • (...args: any[]): void
        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns this

prependListener

  • prependListener(event: string | symbol, listener: function): this
  • Parameters

    • event: string | symbol
    • listener: function
        • (...args: any[]): void
        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns this

prependOnceListener

  • prependOnceListener(event: string | symbol, listener: function): this
  • Parameters

    • event: string | symbol
    • listener: function
        • (...args: any[]): void
        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns this

removeAllListeners

  • removeAllListeners(event?: string | symbol): this
  • Parameters

    • Optional event: string | symbol

    Returns this

removeListener

  • removeListener(event: string | symbol, listener: function): this
  • Parameters

    • event: string | symbol
    • listener: function
        • (...args: any[]): void
        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns this

request

  • request(moduleId: string, msg: any, cb: Callback): void

set

  • set(moduleId: string, value: any): void
  • set module

    api

    public

    Parameters

    • moduleId: string

      module id/name

    • value: any

      module object

    Returns void

setMaxListeners

  • setMaxListeners(n: number): this
  • Parameters

    • n: number

    Returns this

Static listenerCount

  • listenerCount(emitter: EventEmitter, event: string | symbol): number
  • Parameters

    • emitter: EventEmitter
    • event: string | symbol

    Returns number