Class FlowDAO

DAO for accessing flow (Netflow/IPFIX/sFlow) data.

Hierarchy

BaseDAO
- FlowDAO

Constructors

constructor

new FlowDAO(impl: IOnmsHTTP | IHasHTTP): FlowDAO
Construct a DAO instance.
Parameters
- impl: IOnmsHTTP | IHasHTTP
  The HTTP implementation to use. It is also legal to pass any object conforming to the [[IHasHTTP]] interface (like a [[Client]]).
Returns FlowDAO
Inherited from BaseDAO.constructor
- Defined in src/dao/BaseDAO.ts:45

Accessors

http

get http(): IOnmsHTTP
The HTTP implementation to use internally when making DAO requests.

Returns IOnmsHTTP
Inherited from BaseDAO.http
- Defined in src/dao/BaseDAO.ts:56
set http(impl: IOnmsHTTP): void
Parameters
- impl: IOnmsHTTP
Returns void
Inherited from BaseDAO.http
- Defined in src/dao/BaseDAO.ts:61

server

get server(): OnmsServer
The [[OnmsServer]] being connected to by this DAO.

Returns OnmsServer
Inherited from BaseDAO.server
- Defined in src/dao/BaseDAO.ts:68
set server(s: OnmsServer): void
Parameters
- s: OnmsServer
Returns void
Inherited from BaseDAO.server
- Defined in src/dao/BaseDAO.ts:76

Methods

getApplications

getApplications(
    prefix?: string,
    start?: number,
    end?: number,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<string[]>
Enumerate the applications matching the given prefix and filters.
Parameters
- Optionalprefix: string
  the prefix to match
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<string[]>
- Defined in src/dao/FlowDAO.ts:140

`Protected`getCount

getCount(data: any, status?: number): number
A convenience method to make it easy for implementers to extract the count (or totalCount) values from response data.
Parameters
- data: any
- Optionalstatus: number
Returns number
Inherited from BaseDAO.getCount
- Defined in src/dao/BaseDAO.ts:139

getDscpValues

getDscpValues(
    exporterNodeCriteria?: string,
    ifIndex?: number,
    start?: number,
    end?: number,
): Promise<number[]>
Get used Dscp values for a specific interface
Parameters
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  the SNMP interface
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
Returns Promise<number[]>
- Defined in src/dao/FlowDAO.ts:73

getExporter

getExporter(
    criteria: string,
    limit: number,
    start?: number,
    end?: number,
): Promise<OnmsFlowExporter>
Get detailed information about a specific node.
Parameters
- criteria: string
  the node ID or foreignSource:foreignId tuple
- limit: number
  maximum number of interfaces to return (those with the most flows will be returned if the results are truncated)
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
Returns Promise<OnmsFlowExporter>
- Defined in src/dao/FlowDAO.ts:57

getExporters

getExporters(
    limit: number,
    start?: number,
    end?: number,
): Promise<OnmsFlowExporterSummary[]>
Get a summary of the nodes that have exported flows.
Parameters
- limit: number
  maximum number of exporters to return (those with the most flows will be returned if the results are truncated)
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
Returns Promise<OnmsFlowExporterSummary[]>
- Defined in src/dao/FlowDAO.ts:28

getHosts

getHosts(
    pattern?: string,
    start?: number,
    end?: number,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<string[]>
Enumerate all the hosts matching the given pattern and filters.
Parameters
- Optionalpattern: string
  the regex pattern to match
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<string[]>
- Defined in src/dao/FlowDAO.ts:410

`Protected`getOptions

getOptions(): OnmsHTTPOptionsBuilder
Create an [[OnmsHTTPOptions]] object for DAO calls.

Returns OnmsHTTPOptionsBuilder
- Defined in src/dao/FlowDAO.ts:640

getSeriesForApplications

getSeriesForApplications(
    applications?: string[],
    start?: number,
    end?: number,
    step?: number,
    includeOther?: boolean,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<OnmsFlowSeries>
Get time series data for the top N applications/protocols based on parameters.
Parameters
- Optionalapplications: string[]
  the applications to include
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- Optionalstep: number
  the requested time interval between rows
- OptionalincludeOther: boolean
  include an additional "other" result that represents everything that does not match the given applications
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<OnmsFlowSeries>
- Defined in src/dao/FlowDAO.ts:253

getSeriesForConversations

getSeriesForConversations(
    conversations?: string[],
    start?: number,
    end?: number,
    step?: number,
    includeOther?: boolean,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
    ecn?: string[],
): Promise<OnmsFlowSeries>
Get time series data for the given conversations based on parameters.
Parameters
- Optionalconversations: string[]
  how many conversations' series to return
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- Optionalstep: number
  the requested time interval between rows
- OptionalincludeOther: boolean
  include an additional "other" result that represents everything that does not match the given conversations
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
- Optionalecn: string[]
Returns Promise<OnmsFlowSeries>
- Defined in src/dao/FlowDAO.ts:380

getSeriesForDscps

getSeriesForDscps(
    start?: number,
    end?: number,
    step?: number,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<OnmsFlowSeries>
Get time series data for DSCP based on parameters.
Parameters
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- Optionalstep: number
  the requested time interval between rows
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<OnmsFlowSeries>
- Defined in src/dao/FlowDAO.ts:115

getSeriesForHosts

getSeriesForHosts(
    hosts?: string[],
    start?: number,
    end?: number,
    step?: number,
    includeOther?: boolean,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<OnmsFlowSeries>
Get time series data for the given hosts based on parameters.
Parameters
- Optionalhosts: string[]
  the hosts to include
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- Optionalstep: number
  the requested time interval between rows
- OptionalincludeOther: boolean
  include an additional "other" result that represents everything that does not match the given hosts
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<OnmsFlowSeries>
- Defined in src/dao/FlowDAO.ts:525

getSeriesForTopNApplications

getSeriesForTopNApplications(
    N?: number,
    start?: number,
    end?: number,
    step?: number,
    includeOther?: boolean,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<OnmsFlowSeries>
Get time series data for the top N applications/protocols based on parameters.
Parameters
- OptionalN: number
  how many applications' series to return
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- Optionalstep: number
  the requested time interval between rows
- OptionalincludeOther: boolean
  include an additional "other" result that represents everything that does not match the top N
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<OnmsFlowSeries>
- Defined in src/dao/FlowDAO.ts:224

getSeriesForTopNConversations

getSeriesForTopNConversations(
    NOptions?: number | ITopNOptions,
    start?: number,
    end?: number,
    step?: number,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<OnmsFlowSeries>
Get time series data for the top N conversations based on parameters.
Parameters
- OptionalNOptions: number | ITopNOptions
  how many conversations to return or an object that includes all of the parameters to be set on the API call
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- Optionalstep: number
  the requested time interval between rows
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<OnmsFlowSeries>
- Defined in src/dao/FlowDAO.ts:347

getSeriesForTopNHosts

getSeriesForTopNHosts(
    N?: number,
    start?: number,
    end?: number,
    step?: number,
    includeOther?: boolean,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<OnmsFlowSeries>
Get time series data for the top N hosts based on parameters.
Parameters
- OptionalN: number
  how many applications' series to return
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- Optionalstep: number
  the requested time interval between rows
- OptionalincludeOther: boolean
  include an additional "other" result that represents everything that does not match the top N
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<OnmsFlowSeries>
- Defined in src/dao/FlowDAO.ts:495

getSummaryForApplications

getSummaryForApplications(
    applications?: string[],
    start?: number,
    end?: number,
    includeOther?: boolean,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<OnmsFlowTable>
Summarize the given applications/protocols based on parameters.
Parameters
- Optionalapplications: string[]
  the applications to include
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- OptionalincludeOther: boolean
  include an additional "other" result that represents everything that does not match the given applications
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<OnmsFlowTable>
- Defined in src/dao/FlowDAO.ts:191

getSummaryForConversations

getSummaryForConversations(
    conversations?: string[],
    start?: number,
    end?: number,
    includeOther?: boolean,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<OnmsFlowTable>
Summarize the given conversations based on parameters.
Parameters
- Optionalconversations: string[]
  how many conversations to return
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- OptionalincludeOther: boolean
  include an additional "other" result that represents everything that does not match the given conversations
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<OnmsFlowTable>
- Defined in src/dao/FlowDAO.ts:316

getSummaryForDscps

getSummaryForDscps(
    start?: number,
    end?: number,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<OnmsFlowTable>
Summarize the the dscp values based on parameters.
Parameters
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<OnmsFlowTable>
- Defined in src/dao/FlowDAO.ts:92

getSummaryForHosts

getSummaryForHosts(
    hosts?: string[],
    start?: number,
    end?: number,
    includeOther?: boolean,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<OnmsFlowTable>
Summarize the given hosts based on parameters.
Parameters
- Optionalhosts: string[]
  the hosts to include
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- OptionalincludeOther: boolean
  include an additional "other" result that represents everything that does not match the given hosts
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<OnmsFlowTable>
- Defined in src/dao/FlowDAO.ts:435

getSummaryForTopNApplications

getSummaryForTopNApplications(
    N?: number,
    start?: number,
    end?: number,
    includeOther?: boolean,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<OnmsFlowTable>
Summarize the top N applications/protocols based on parameters.
Parameters
- OptionalN: number
  how many applications to return
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- OptionalincludeOther: boolean
  include an additional "other" result that represents everything that does not match the top N
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<OnmsFlowTable>
- Defined in src/dao/FlowDAO.ts:165

getSummaryForTopNConversations

getSummaryForTopNConversations(
    NOptions?: number | ITopNOptions,
    start?: number,
    end?: number,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<OnmsFlowTable>
Summarize the top N conversations based on parameters.
Parameters
- OptionalNOptions: number | ITopNOptions
  how many conversations to return or an object that includes all of the parameters to be set on the API call
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<OnmsFlowTable>
- Defined in src/dao/FlowDAO.ts:285

getSummaryForTopNHosts

getSummaryForTopNHosts(
    N?: number,
    start?: number,
    end?: number,
    includeOther?: boolean,
    exporterNodeCriteria?: string,
    ifIndex?: number,
    dscp?: string[],
): Promise<OnmsFlowTable>
Summarize the top N hosts based on parameters.
Parameters
- OptionalN: number
  how many conversations to return
- Optionalstart: number
  the start of the timespan to query (defaults to 4 hours ago)
- Optionalend: number
  the end of the timespan to query (defaults to now)
- OptionalincludeOther: boolean
  include an additional "other" result that represents everything that does not match the top N
- OptionalexporterNodeCriteria: string
  the node ID or foreignSource:foreignId tuple
- OptionalifIndex: number
  filter for flows that came through this SNMP interface
- Optionaldscp: string[]
  filter for flows with this Dscp value
Returns Promise<OnmsFlowTable>
- Defined in src/dao/FlowDAO.ts:467

`Protected`onSetServer

onSetServer(server?: OnmsServer): void
Called whenever the OpenNMS server has changed.
Parameters
- Optionalserver: OnmsServer
  the new server
Returns void
Inherited from BaseDAO.onSetServer
- Defined in src/dao/BaseDAO.ts:121

`Protected`toDate

toDate(from: any): Moment
Convert the given value to a date, or undefined if it cannot be converted.
Parameters
- from: any
Returns Moment
Deprecated
use [[Util.toDate]] instead.
Inherited from BaseDAO.toDate
- Defined in src/dao/BaseDAO.ts:161

`Protected`toNumber

toNumber(from: any): number
Convert the given value to a number, or undefined if it cannot be converted.
Parameters
- from: any
Returns number
Deprecated
use [[Util.toNumber]] instead.
Inherited from BaseDAO.toNumber
- Defined in src/dao/BaseDAO.ts:169

`Protected`useJson

useJson(): boolean
Whether or not to use JSON when making ReST requests.

Returns boolean
Inherited from BaseDAO.useJson
- Defined in src/dao/BaseDAO.ts:128

Class FlowDAO

Hierarchy

Index

Constructors

Accessors

Methods

Constructors

constructor

Parameters

Returns FlowDAO

Accessors

http

Returns IOnmsHTTP

Parameters

Returns void

server

Returns OnmsServer

Parameters

Returns void

Methods

getApplications

Parameters

Returns Promise<string[]>

ProtectedgetCount

Parameters

Returns number

getDscpValues

Parameters

Returns Promise<number[]>

getExporter

Parameters

Returns Promise<OnmsFlowExporter>

getExporters

Parameters

Returns Promise<OnmsFlowExporterSummary[]>

getHosts

Parameters

Returns Promise<string[]>

ProtectedgetOptions

Returns OnmsHTTPOptionsBuilder

getSeriesForApplications

Parameters

Returns Promise<OnmsFlowSeries>

getSeriesForConversations

Parameters

Returns Promise<OnmsFlowSeries>

getSeriesForDscps

Parameters

Returns Promise<OnmsFlowSeries>

getSeriesForHosts

Parameters

Returns Promise<OnmsFlowSeries>

getSeriesForTopNApplications

Parameters

Returns Promise<OnmsFlowSeries>

getSeriesForTopNConversations

Parameters

Returns Promise<OnmsFlowSeries>

getSeriesForTopNHosts

Parameters

Returns Promise<OnmsFlowSeries>

getSummaryForApplications

Parameters

Returns Promise<OnmsFlowTable>

getSummaryForConversations

Parameters

Returns Promise<OnmsFlowTable>

getSummaryForDscps

Parameters

Returns Promise<OnmsFlowTable>

getSummaryForHosts

Parameters

Returns Promise<OnmsFlowTable>

getSummaryForTopNApplications

Parameters

Returns Promise<OnmsFlowTable>

getSummaryForTopNConversations

Parameters

Returns Promise<OnmsFlowTable>

getSummaryForTopNHosts

`Protected`getCount

`Protected`getOptions

`Protected`onSetServer

`Protected`toDate

`Protected`toNumber

`Protected`useJson