Package org.opennms.core.rpc.api

Interface RpcClientFactory

All Known Implementing Classes:

CamelRpcClientFactory, KafkaRpcClientFactory, MockRpcClientFactory, OpennmsGrpcServer, OsgiIpcManager

public interface RpcClientFactory

Creates a RpcClient that can be used to invoke RPCs against the given RpcModule.

Author:

jwhite

Field Summary

Fields

Modifier and Type	Field	Description
static String	JMX_DOMAIN_RPC
static String	LOG_PREFIX
static String	RPC_DURATION
static String	RPC_FAILED
static String	RPC_REQUEST_SENT
static String	RPC_REQUEST_SIZE
static String	RPC_REQUESTS_RECEIVED
static String	RPC_RESPONSE_SIZE

Method Summary

Modifier and Type	Method	Description
<R extends RpcRequest,S extends RpcResponse> RpcClient<R,S>	getClient(RpcModule<R,S> module)
static void	markFailed(com.codahale.metrics.MetricRegistry metricRegistry, String location, String moduleId)
static void	markRpcCount(com.codahale.metrics.MetricRegistry metricRegistry, String location, String moduleId)
static void	updateDuration(com.codahale.metrics.MetricRegistry metricRegistry, String location, String moduleId, long duration)
static void	updateRequestSize(com.codahale.metrics.MetricRegistry metricRegistry, String location, String moduleId, int requestSize)
static void	updateResponseSize(com.codahale.metrics.MetricRegistry metricRegistry, String location, String moduleId, int responseSize)

Field Detail

LOG_PREFIX

static final String LOG_PREFIX

See Also:

Constant Field Values

JMX_DOMAIN_RPC

static final String JMX_DOMAIN_RPC

See Also:

Constant Field Values

RPC_REQUEST_SENT

static final String RPC_REQUEST_SENT

See Also:

Constant Field Values

RPC_REQUESTS_RECEIVED

static final String RPC_REQUESTS_RECEIVED

See Also:

Constant Field Values

RPC_FAILED

static final String RPC_FAILED

See Also:

Constant Field Values

RPC_DURATION

static final String RPC_DURATION

See Also:

Constant Field Values

RPC_REQUEST_SIZE

static final String RPC_REQUEST_SIZE

See Also:

Constant Field Values

RPC_RESPONSE_SIZE

static final String RPC_RESPONSE_SIZE

See Also:

Constant Field Values

Method Detail

getClient

<R extends RpcRequest,S extends RpcResponse> RpcClient<R,S> getClient(RpcModule<R,S> module)

updateDuration

static void updateDuration(com.codahale.metrics.MetricRegistry metricRegistry,
                           String location,
                           String moduleId,
                           long duration)

markRpcCount

static void markRpcCount(com.codahale.metrics.MetricRegistry metricRegistry,
                         String location,
                         String moduleId)

updateRequestSize

static void updateRequestSize(com.codahale.metrics.MetricRegistry metricRegistry,
                              String location,
                              String moduleId,
                              int requestSize)

updateResponseSize

static void updateResponseSize(com.codahale.metrics.MetricRegistry metricRegistry,
                               String location,
                               String moduleId,
                               int responseSize)

markFailed

static void markFailed(com.codahale.metrics.MetricRegistry metricRegistry,
                       String location,
                       String moduleId)