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 java.lang.String	JMX_DOMAIN_RPC
static java.lang.String	LOG_PREFIX
static java.lang.String	RPC_DURATION
static java.lang.String	RPC_FAILED
static java.lang.String	RPC_REQUEST_SENT
static java.lang.String	RPC_REQUEST_SIZE
static java.lang.String	RPC_REQUESTS_RECEIVED
static java.lang.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, java.lang.String location, java.lang.String moduleId)
static void	markRpcCount(com.codahale.metrics.MetricRegistry metricRegistry, java.lang.String location, java.lang.String moduleId)
static void	updateDuration(com.codahale.metrics.MetricRegistry metricRegistry, java.lang.String location, java.lang.String moduleId, long duration)
static void	updateRequestSize(com.codahale.metrics.MetricRegistry metricRegistry, java.lang.String location, java.lang.String moduleId, int requestSize)
static void	updateResponseSize(com.codahale.metrics.MetricRegistry metricRegistry, java.lang.String location, java.lang.String moduleId, int responseSize)

Field Detail

LOG_PREFIX

static final java.lang.String LOG_PREFIX

See Also:

Constant Field Values

JMX_DOMAIN_RPC

static final java.lang.String JMX_DOMAIN_RPC

See Also:

Constant Field Values

RPC_REQUEST_SENT

static final java.lang.String RPC_REQUEST_SENT

See Also:

Constant Field Values

RPC_REQUESTS_RECEIVED

static final java.lang.String RPC_REQUESTS_RECEIVED

See Also:

Constant Field Values

RPC_FAILED

static final java.lang.String RPC_FAILED

See Also:

Constant Field Values

RPC_DURATION

static final java.lang.String RPC_DURATION

See Also:

Constant Field Values

RPC_REQUEST_SIZE

static final java.lang.String RPC_REQUEST_SIZE

See Also:

Constant Field Values

RPC_RESPONSE_SIZE

static final java.lang.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,
                           java.lang.String location,
                           java.lang.String moduleId,
                           long duration)

markRpcCount

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

updateRequestSize

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

updateResponseSize

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

markFailed

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