cloud.metaapi.sdk.meta_api

Class LatencyMonitor

java.lang.Object

cloud.metaapi.sdk.clients.meta_api.LatencyListener

cloud.metaapi.sdk.meta_api.LatencyMonitor

public class LatencyMonitor
extends LatencyListener

Responsible for monitoring MetaApi application latencies

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LatencyMonitor.Latencies Contains measured latencies
static class	LatencyMonitor.MonitorLatencies Contains latencies from client, server and broker side

Nested classes/interfaces inherited from class cloud.metaapi.sdk.clients.meta_api.LatencyListener

LatencyListener.ResponseTimestamps, LatencyListener.SymbolPriceTimestamps, LatencyListener.TradeTimestamps, LatencyListener.UpdateTimestamps

Constructor Summary

Constructors

Constructor and Description
LatencyMonitor() Constructs latency monitor instance

Method Summary

Modifier and Type	Method and Description
LatencyMonitor.MonitorLatencies	getPriceLatencies() Returns price streaming latencies
Map<String,LatencyMonitor.MonitorLatencies>	getRequestLatencies() Returns request processing latencies
LatencyMonitor.MonitorLatencies	getTradeLatencies() Returns trade latencies
LatencyMonitor.MonitorLatencies	getUpdateLatencies() Returns update streaming latencies
CompletableFuture<Void>	onResponse(String accountId, String type, LatencyListener.ResponseTimestamps timestamps) Invoked with latency information when application receives a response to RPC request
CompletableFuture<Void>	onSymbolPrice(String accountId, String symbol, LatencyListener.SymbolPriceTimestamps timestamps) Invoked with latency information when application receives symbol price update event
CompletableFuture<Void>	onTrade(String accountId, LatencyListener.TradeTimestamps timestamps) Invoked with latency information when application receives trade response
CompletableFuture<Void>	onUpdate(String accountId, LatencyListener.UpdateTimestamps timestamps) Invoked with latency information when application receives update event

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LatencyMonitor

public LatencyMonitor()

Constructs latency monitor instance

Method Detail

onResponse

public CompletableFuture<Void> onResponse(String accountId,
                                          String type,
                                          LatencyListener.ResponseTimestamps timestamps)

Description copied from class: LatencyListener

Invoked with latency information when application receives a response to RPC request

Overrides:

onResponse in class LatencyListener

Parameters:

accountId - account id

type - request type

timestamps - request timestamps object containing latency information

Returns:

completable future which resolves when latency information is processed

getRequestLatencies

public Map<String,LatencyMonitor.MonitorLatencies> getRequestLatencies()

Returns request processing latencies

Returns:

request processing latencies

onSymbolPrice

public CompletableFuture<Void> onSymbolPrice(String accountId,
                                             String symbol,
                                             LatencyListener.SymbolPriceTimestamps timestamps)

Description copied from class: LatencyListener

Invoked with latency information when application receives symbol price update event

Overrides:

onSymbolPrice in class LatencyListener

Parameters:

accountId - account id

symbol - price symbol

timestamps - timestamps object containing latency information about price streaming

Returns:

completable future which resolves when latency information is processed

getPriceLatencies

public LatencyMonitor.MonitorLatencies getPriceLatencies()

Returns price streaming latencies

Returns:

price streaming latencies

onUpdate

public CompletableFuture<Void> onUpdate(String accountId,
                                        LatencyListener.UpdateTimestamps timestamps)

Description copied from class: LatencyListener

Invoked with latency information when application receives update event

Overrides:

onUpdate in class LatencyListener

Parameters:

accountId - account id

timestamps - timestamps object containing latency information about update streaming

Returns:

completable future which resolves when latency information is processed

getUpdateLatencies

public LatencyMonitor.MonitorLatencies getUpdateLatencies()

Returns update streaming latencies

Returns:

update streaming latencies

onTrade

public CompletableFuture<Void> onTrade(String accountId,
                                       LatencyListener.TradeTimestamps timestamps)

Description copied from class: LatencyListener

Invoked with latency information when application receives trade response

Overrides:

onTrade in class LatencyListener

Parameters:

accountId - account id

timestamps - timestamps object containing latency information about a trade

Returns:

completable future which resolves when latency information is processed

getTradeLatencies

public LatencyMonitor.MonitorLatencies getTradeLatencies()

Returns trade latencies

Returns:

trade latencies