import MetricsBusCollector from 'devapt-core-server/js/metrics/bus/metrics_bus_collector.js'

public class | source

MetricsBusCollector

Extends:

devapt-core-common/dist/js/base/settingsable~Settingsable → MetricsCollector → MetricsBusCollector

Metrics Bus collector class.

Constructor Summary

Public Constructor
public	constructor(arg_settings: Immutable.Map, arg_log_context: string): nothing Metrics collector constructor.

Member Summary

Public Members
public	is_metrics_bus_collector: boolean Class test flag.
public	metrics_logs_bus: MetricsBusRecord Logs bus metrics record.
public	metrics_metrics_bus: MetricsBusRecord Metrics bus metrics record.
public	metrics_msg_bus: MetricsBusRecord Message bus metrics record.
public	metrics_reducer: MetricsReducer Metrics reducer instance.
public	metrics_state: MetricsState Metrics state instance.
public	scheduler: Timer Timer instance.

Method Summary

Public Methods
public	close(): nothing Flush and close the metrics collector.
public	flush(): nothing Flush pending metrics records.
public	init(): nothing Initialize metrics collector.

Inherited Summary

From class MetricsCollector
public	is_metrics_collector: boolean Class test flag.
public	metrics_reducer: MetricsReducer Metrics reducer instance.
public	metrics_server_name: string Metrics server name.
public	metrics_state: MetricsState Metrics state instance.
private	$state: string Metrics collector status.
public	close(): nothing Flush and close the metrics collector.
public	flush(): nothing Flush pending metrics records.
public	get_state_values(): string Get the metrics collector status: CREATED, INITIALIZED, CLOSED.
public	get_status(): string Get the metrics collector status: CREATED, INITIALIZED, CLOSED.
public	init(): nothing Initialize metrics collector.
public	process_record(arg_metrics_record: MetricsRecord): nothing Process a metrics record.
public	process_values(arg_metrics_values: object): nothing Process metrics record values.
public	send_metrics(arg_type: string, arg_values: array): boolean Send metrics message.

Public Constructors

public constructor(arg_settings: Immutable.Map, arg_log_context: string): nothing source

Metrics collector constructor.

Override:

MetricsCollector#constructor

Params:

Name	Type	Attribute	Description
arg_settings	Immutable.Map		instance settings map.
arg_log_context	string		trace context string.

Return:

nothing

Public Members

public is_metrics_bus_collector: boolean source

Class test flag.

public metrics_logs_bus: MetricsBusRecord source

Logs bus metrics record.

public metrics_metrics_bus: MetricsBusRecord source

Metrics bus metrics record.

public metrics_msg_bus: MetricsBusRecord source

Message bus metrics record.

public metrics_reducer: MetricsReducer source

Metrics reducer instance.

Override:

MetricsCollector#metrics_reducer

public metrics_state: MetricsState source

Metrics state instance.

Override:

MetricsCollector#metrics_state

public scheduler: Timer source

Timer instance.

Public Methods

public close(): nothing source

Flush and close the metrics collector.

Override:

MetricsCollector#close

Return:

nothing

public flush(): nothing source

Flush pending metrics records.

Override:

MetricsCollector#flush

Return:

nothing

public init(): nothing source

Initialize metrics collector.

Override:

MetricsCollector#init

Return:

nothing