Skip navigation links
A B C D E F G H I J K L M N O P Q R S T U V W 

A

abort() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
accept() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
 
ack() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
add(SubscriptionHolder) - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
Adds a SubscriptionHolder which will be used for event matching
addEventListener(ReactorClient.MessageListener) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
addGracePeriod(int) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
addResponse(JsonRpcResponse) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
 
addResponse(JsonRpcResponse) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
 
addResponse(JsonRpcResponse) - Method in interface org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcCall
 
ALL - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
await(long, TimeUnit) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.OneTimeCallback
 

B

BatchCall - Class in org.ovirt.vdsm.jsonrpc.client.internal
Groups responses for batch call and let user to get them when all of them are ready.
BatchCall(List<JsonRpcRequest>) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
 
batchCall(List<JsonRpcRequest>) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
Sends requests in batch and returns Future representation of JsonRpcResponse.
begin() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
beginHandshake() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
 
BUFFER_SIZE - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
build() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
build() - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
Builds JsonRpcRequest based on provided method name, parameter and generates id using UUID.
build() - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
Builds JsonRpcResponse based on provided id, result and error.
buildErrorResponse(JsonNode, T, String) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
buildFailedResponse(JsonRpcRequest) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
buildNetworkResponse(String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
Builds network issue message for specific protocol.
buildNetworkResponse(String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 

C

Call - Class in org.ovirt.vdsm.jsonrpc.client.internal
Call holds single response and uses BatchCall as internal implementation to promote code reuse.
Call(JsonRpcRequest) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.Call
 
call(JsonRpcRequest) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
Sends single request and returns Future representation of JsonRpcResponse.
call() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ChainedOperation
 
call(boolean) - Method in interface org.ovirt.vdsm.jsonrpc.client.utils.ChainedOperation.Operation
 
call() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.Retryable
 
cancel(boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
 
cancel(boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
 
cancel(boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ChainedOperation
 
cancel() - Method in interface org.reactivestreams.Subscription
Request the Publisher to stop sending data and clean up resources.
canProcess() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
 
canProcessMore() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
 
ChainedOperation<T> - Class in org.ovirt.vdsm.jsonrpc.client.utils
Allows to chain sent operation returning object of provided type.
ChainedOperation(ChainedOperation.Operation<T>) - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.ChainedOperation
 
ChainedOperation.Operation<T> - Interface in org.ovirt.vdsm.jsonrpc.client.utils
 
channel - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
checkAndExecute() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.OneTimeCallback
 
clean() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
Clean event queue.
clearBuff() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
 
CLIENT_CLOSED - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
ClientConnectionException - Exception in org.ovirt.vdsm.jsonrpc.client
Generic json-rpc client exception which wraps IO or encryption relates exceptions.
ClientConnectionException() - Constructor for exception org.ovirt.vdsm.jsonrpc.client.ClientConnectionException
 
ClientConnectionException(String) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.ClientConnectionException
 
ClientConnectionException(Throwable) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.ClientConnectionException
 
ClientConnectionException(String, Throwable) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.ClientConnectionException
 
ClientConnectionException(String, Throwable, boolean, boolean) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.ClientConnectionException
 
ClientPolicy - Class in org.ovirt.vdsm.jsonrpc.client.internal
Java bean which provide information how retry logic should work.
ClientPolicy(int, int, int, int, List<Class<? extends Exception>>) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
Create policy using provided values.
ClientPolicy(int, int, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
ClientPolicy(int, int, int, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
ClientPolicy(int, int, int, Class<? extends Exception>) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
ClientPolicy(int, int, int, int, Class<? extends Exception>) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
clone() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
clone() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
 
cloneBuffer(ByteBuffer) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
close() - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
 
close() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
 
close() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
 
close() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
 
close() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
 
close() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
close() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
 
close() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
close() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.LockWrapper
 
closeChannel() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
CommandExecutor - Interface in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
 
CommandFactory - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
 
CommandFactory(Sender, List<ReactorClient.MessageListener>) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.CommandFactory
 
commands - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.CommandFactory
 
commit() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
connect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
connect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
connected() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
connected - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
createClient(String, int) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
 
createClient(Reactor, Selector, String, int) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
 
createClient(Reactor, Selector, String, int) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompReactor
 
createClient(Reactor, Selector, String, int) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompReactor
 
createConnectedClient(Reactor, Selector, String, int, SocketChannel) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
 
createConnectedClient(Reactor, Selector, String, int, SocketChannel) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompReactor
 
createConnectedClient(Reactor, Selector, String, int, SocketChannel) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompReactor
 
createListener(String, int, ReactorListener.EventListener) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
 
createSSLEngine(boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
 

D

decompose(JsonRpcEvent) - Method in class org.ovirt.vdsm.jsonrpc.client.EventDecomposer
Decomposes an event to a map.
decomposeError() - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseDecomposer
Decomposes response error as Map.
decomposeResponse(Class<T>) - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseDecomposer
Decomposes response to provided type.
decomposeTypedArray(Object[], Class<T>, String) - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseDecomposer
Decomposes response to provided typed array.
decreaseAttempts() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
 
DEFAULT_REQUEST_QUEUE - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
DEFAULT_RESPONSE_QUEUE - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
DefaultClientRetryPolicy - Class in org.ovirt.vdsm.jsonrpc.client.utils.retry
Default implementation of operation level retry functionality.
DefaultClientRetryPolicy() - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.retry.DefaultClientRetryPolicy
 
DefaultConnectionRetryPolicy - Class in org.ovirt.vdsm.jsonrpc.client.utils.retry
Default implementation of connection level retry functionality.
DefaultConnectionRetryPolicy() - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.retry.DefaultConnectionRetryPolicy
 
disconnect(String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
disconnect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 

E

emitOnMessageReceived(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
emitOnMessageReceived(Message) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
END_OF_MESSAGE - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
error(Map<String, String>) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Listener
 
error() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
ERROR_KEY - Static variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
 
EventDecomposer - Class in org.ovirt.vdsm.jsonrpc.client
Decomposes events as Map.
EventDecomposer() - Constructor for class org.ovirt.vdsm.jsonrpc.client.EventDecomposer
 
eventListeners - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
EventPublisher - Class in org.ovirt.vdsm.jsonrpc.client.events
Jsonrpc implementation of Publisher
EventPublisher(ExecutorService) - Constructor for class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
 
EventSubscriber - Class in org.ovirt.vdsm.jsonrpc.client.events
Subscription id contains <receiver>.<component>.<operation_id>.<unique_id>.
EventSubscriber(String) - Constructor for class org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
 
execute(Message) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.CommandExecutor
 
execute() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.OneTimeCallback
 

F

fromByteArray(byte[]) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
 
fromByteArray(byte[]) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
 
fromByteArray(byte[]) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
Validates and builds JsonRpcResponse based on provided json node.
fromJson(JsonNode) - Static method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
Creates JsonRpcError representation from provided JsonNode message.
fromJsonNode(JsonNode) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
Validates and builds JsonRpcEvent based on provided json node.
fromJsonNode(JsonNode) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
Validates and builds JsonRpcRequest based on provided json node.
fromJsonNode(JsonNode) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
Validates and builds JsonRpcResponse based on provided json node.
fromMethodAndParams(String, Map<String, Object>) - Static method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
Create notification object for the method and params.

G

get() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
 
get(long, TimeUnit) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
 
get() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
 
get(long, TimeUnit) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
 
get() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ChainedOperation
 
get(long, TimeUnit) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ChainedOperation
 
getAddress(String, int) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
getCall() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
 
getClient() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.MessageContext
 
getClient() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
 
getClient() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
 
getClientId() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
getClientRetryPolicy() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
 
getCode() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
 
getCommand() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
getCommandExecutor(String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.CommandFactory
 
getConnectionId() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
 
getConnectionId() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
getContent() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
getContentLength() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
getContext() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
 
getData() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
 
getEncoding() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
getError() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
 
getEventQueue() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
 
getEventQueue() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
getExceptions() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
getFilteredId() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
 
getHeaders() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
getHostname() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
 
getHostname() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
getId() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
 
getId() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
 
getId() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
 
getId() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
 
getId() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
 
getIdentifier() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
getIncomingHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
getKeyManagers() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ManagerProvider
 
getMessage() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
 
getMessage() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.MessageContext
 
getMethod() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
 
getMethod() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
 
getNumberOfAttempts() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
 
getOutgoingHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
getParams() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
 
getParams() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
 
getParsedId() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
 
getPeerCertificates() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
getPeerCertificates() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
 
getPlainId() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
 
getPort() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
 
getPostConnectCallback() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
getPostConnectCallback() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
 
getPostConnectCallback() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClient
 
getPublisher() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
 
getReactor(ManagerProvider, ReactorType) - Static method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory
Provides instance of Reactor based on ManagerProvider availability and type provided.
getReactorName() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
 
getReactorName() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompReactor
 
getReactorName() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompReactor
 
getRequest() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
 
getRequestQueue() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
 
getRequestQueue() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
getResponseQueue() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
 
getResponseQueue() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
getResult() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
 
getResult() - Method in interface org.ovirt.vdsm.jsonrpc.client.utils.ChainedOperation.Operation
 
getRetryNumber() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
getRetryPolicy() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
 
getRetryPolicy() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
getRetryTimeOut() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
getSelectionKey() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
getSSLContext() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ManagerProvider
 
getSSLEngine() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
 
getSubscriber() - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
 
getSubscriptionId() - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
 
getTimeout(int, TimeUnit) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
getTimeout() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
 
getTimeout() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
 
getTimeUnit() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
getTimeUnit() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
 
getTrustManagers() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ManagerProvider
 
getWorker(int) - Static method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory
 

H

handshakeInProgress() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
 
HEADER_ACCEPT - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
HEADER_ACK - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
HEADER_CONTENT_LENGTH - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
HEADER_CONTENT_TYPE - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
HEADER_DESTINATION - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
HEADER_HEART_BEAT - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
HEADER_HOST - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
HEADER_ID - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
HEADER_MESSAGE - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
HEADER_RECEIPT - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
HEADER_RECEIPT_ID - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
HEADER_REPLY_TO - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
HEADER_TRANSACTION - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
headerBuffer - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
HEARTBEAT_FRAME - Static variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 

I

ibuff - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
isCancelled() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
 
isCancelled() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
 
isCancelled() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ChainedOperation
 
isCancelled() - Method in interface org.ovirt.vdsm.jsonrpc.client.utils.ChainedOperation.Operation
 
isClosed() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
 
isDone() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.BatchCall
 
isDone() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.Call
 
isDone() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ChainedOperation
 
isDone() - Method in interface org.ovirt.vdsm.jsonrpc.client.utils.ChainedOperation.Operation
 
isEmpty(String) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
isError() - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseDecomposer
 
isExceptionRetryable(Exception) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
 
isIncomingHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
isInInit() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
isInInit() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
 
isInInit() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClient
 
isOpen() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
isOutgoingHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
isResetConnection() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
 

J

JsonRpcCall - Interface in org.ovirt.vdsm.jsonrpc.client.internal
Abstraction for single and batch calls to be updated when response arrives.
JsonRpcClient - Class in org.ovirt.vdsm.jsonrpc.client
ReactorClient wrapper which provides ability to send single or batched requests.
JsonRpcClient(ReactorClient, ResponseTracker) - Constructor for class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
Wraps ReactorClient to hide response update details.
JsonRpcError - Class in org.ovirt.vdsm.jsonrpc.client.internal
Java bean representing error information from json message.
JsonRpcError(int, String, JsonNode) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
 
JsonRpcEvent - Class in org.ovirt.vdsm.jsonrpc.client
Java bean representation of an event.
JsonRpcEvent(String, JsonNode) - Constructor for class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
Creates notification object.
JsonRpcRequest - Class in org.ovirt.vdsm.jsonrpc.client
Java bean representation of the request.
JsonRpcRequest(String, JsonNode, JsonNode) - Constructor for class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
Creates request object.
JsonRpcResponse - Class in org.ovirt.vdsm.jsonrpc.client
Java bean representing response object.
JsonRpcResponse(JsonNode, JsonNode, JsonNode) - Constructor for class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
Creates response object.
jsonToByteArray(JsonNode) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
jsonToByteArray(List<JsonRpcRequest>) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
JsonUtils - Class in org.ovirt.vdsm.jsonrpc.client.utils
Utility class for json marshalling.
JsonUtils() - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 

K

key - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 

L

Listener - Interface in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
 
LockWrapper - Class in org.ovirt.vdsm.jsonrpc.client.utils
Lock wrapper object which allows to use try-finally block to auto unlock internal Lock.
LockWrapper(Lock) - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.LockWrapper
 
logException(Logger, String, Throwable) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 

M

ManagerProvider - Class in org.ovirt.vdsm.jsonrpc.client.reactors
Provides abstraction for obtaining TrustManagers and KeyManagers.
ManagerProvider() - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.ManagerProvider
 
mapValues(JsonNode) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
match(JsonRpcEvent) - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
Matches current subscriptions to an event and returns a Set containing all subscriptions that match for this event processing.
Message - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
 
Message() - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
message() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
message - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
Message.Command - Enum in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
 
MESSAGE_FORMAT - Static variable in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
 
MessageContext - Class in org.ovirt.vdsm.jsonrpc.client.internal
Context containing a message and client.
MessageContext(JsonRpcClient, byte[]) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.MessageContext
 

N

nioEngine - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
 

O

onAcccept(ReactorClient) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener.EventListener
 
onComplete() - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
 
onComplete() - Method in interface org.reactivestreams.Subscriber
Successful terminal state.
onError(Throwable) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
 
onError(Throwable) - Method in interface org.reactivestreams.Subscriber
Failed terminal state.
OneTimeCallback - Class in org.ovirt.vdsm.jsonrpc.client.utils
 
OneTimeCallback() - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.OneTimeCallback
 
onMessageReceived(byte[]) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient.MessageListener
 
onNext(Map<String, Object>) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
 
onNext(T) - Method in interface org.reactivestreams.Subscriber
Data notification sent by the Publisher in response to requests to Subscription.request(int).
onSubscribe(Subscription) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
 
onSubscribe(Subscription) - Method in interface org.reactivestreams.Subscriber
Invoked after calling Publisher.subscribe(Subscriber).
org.ovirt.vdsm.jsonrpc.client - package org.ovirt.vdsm.jsonrpc.client
 
org.ovirt.vdsm.jsonrpc.client.events - package org.ovirt.vdsm.jsonrpc.client.events
 
org.ovirt.vdsm.jsonrpc.client.internal - package org.ovirt.vdsm.jsonrpc.client.internal
 
org.ovirt.vdsm.jsonrpc.client.reactors - package org.ovirt.vdsm.jsonrpc.client.reactors
 
org.ovirt.vdsm.jsonrpc.client.reactors.stomp - package org.ovirt.vdsm.jsonrpc.client.reactors.stomp
 
org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl - package org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
 
org.ovirt.vdsm.jsonrpc.client.utils - package org.ovirt.vdsm.jsonrpc.client.utils
 
org.ovirt.vdsm.jsonrpc.client.utils.retry - package org.ovirt.vdsm.jsonrpc.client.utils.retry
 
org.reactivestreams - package org.reactivestreams
 
outbox - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 

P

parse(byte[]) - Static method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
parse(String) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
performAction() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
performPendingOperations() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ReactorScheduler
 
PlainClient - Class in org.ovirt.vdsm.jsonrpc.client.reactors
ReactorClient implementation to provide not encrypted communication.
PlainClient(Reactor, Selector, String, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
 
PlainClient(Reactor, Selector, String, int, SocketChannel) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
 
policy - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
 
postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
Transport specific post connection functionality.
postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
 
postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
 
postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompListener
 
postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClient
 
postConnect(OneTimeCallback) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompListener
 
postDisconnect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
 
postDisconnect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
Cleans resources after disconnect.
postDisconnect() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
 
process(JsonRpcEvent) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
This method is used by @link ResponseWorker to submit an @link JsonRpcEvent for processing.
process() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
process() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
 
process() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
 
processIncoming() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
Process incoming channel.
processIncoming() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
processIssue(JsonRpcResponse) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
 
processOutgoing() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
processResponse(JsonRpcResponse) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
 
publish(String, Map<String, Object>) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
 
publish(String, Map<String, Object>) - Method in interface org.reactivestreams.Publisher
Request Publisher to send data.
Publisher<T,S extends Subscriber<T>> - Interface in org.reactivestreams
 
putEvent(JsonRpcEvent) - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
Queues not processed event for later processing.

Q

queueFuture(Future<?>) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
 
queueFuture(Future<?>) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ReactorScheduler
 

R

Reactor - Class in org.ovirt.vdsm.jsonrpc.client.reactors
Provides Reactor abstraction which reacts on incoming messages and let ReactorClient process them.
Reactor() - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
 
reactor - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
ReactorClient - Class in org.ovirt.vdsm.jsonrpc.client.reactors
Abstract implementation of JsonRpcClient which handles low level networking.
ReactorClient(Reactor, String, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
ReactorClient.MessageListener - Interface in org.ovirt.vdsm.jsonrpc.client.reactors
 
ReactorFactory - Class in org.ovirt.vdsm.jsonrpc.client.reactors
Factory class which provide single instance of Reactors or ResponseWorker within single loading scope.
ReactorFactory() - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory
 
ReactorListener - Class in org.ovirt.vdsm.jsonrpc.client.reactors
NioListener provides a way to react on incoming messages.
ReactorListener(Reactor, InetSocketAddress, Selector, ReactorListener.EventListener) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener
 
ReactorListener.EventListener - Interface in org.ovirt.vdsm.jsonrpc.client.reactors
 
ReactorScheduler - Class in org.ovirt.vdsm.jsonrpc.client.utils
Utility class used for processing FutureTasks.
ReactorScheduler() - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.ReactorScheduler
 
ReactorType - Enum in org.ovirt.vdsm.jsonrpc.client.reactors
 
read(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
 
read(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
Reads provided buffer.
read(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
 
read(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
 
receipt() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
recieve(Message, SelectionKey) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Reciever
 
Reciever - Interface in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
 
reduceGracePeriod(int) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
register(ReactorClient) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
Registers new client with ResponseWorker.
registerCall(JsonRpcRequest, JsonRpcCall) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
 
registerTrackingRequest(JsonRpcRequest, ResponseTracking) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
 
remove(SubscriptionHolder) - Method in class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
Used during removal of a subscription.
removeCall(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
 
removeCall(Future<JsonRpcResponse>) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
 
removeEventListener(ReactorClient.MessageListener) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
request(int) - Method in interface org.reactivestreams.Subscription
No events will be sent by a Publisher until demand is signaled via this method.
RequestAlreadySentException - Exception in org.ovirt.vdsm.jsonrpc.client
Exception used to inform user that there is an attempt to sent the same request second time.
RequestAlreadySentException() - Constructor for exception org.ovirt.vdsm.jsonrpc.client.RequestAlreadySentException
 
RequestAlreadySentException(String) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.RequestAlreadySentException
 
RequestAlreadySentException(Throwable) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.RequestAlreadySentException
 
RequestAlreadySentException(String, Throwable) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.RequestAlreadySentException
 
RequestAlreadySentException(String, Throwable, boolean, boolean) - Constructor for exception org.ovirt.vdsm.jsonrpc.client.RequestAlreadySentException
 
RequestBuilder - Class in org.ovirt.vdsm.jsonrpc.client
Utility class which helps to build JsonRpcRequest by providing information like method name and parameters.
RequestBuilder(String) - Constructor for class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
Creates builder with required methodName.
resetExecution() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.OneTimeCallback
 
ResponseBuilder - Class in org.ovirt.vdsm.jsonrpc.client
Utility class which helps to build JsonRpcResponse by providing information like response or error.
ResponseBuilder(JsonNode) - Constructor for class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
Creates builder with required response id.
ResponseDecomposer - Class in org.ovirt.vdsm.jsonrpc.client
Decomposes of the response as objects which type is provided.
ResponseDecomposer(JsonRpcResponse) - Constructor for class org.ovirt.vdsm.jsonrpc.client.ResponseDecomposer
Creates decomposer for a response.
ResponseTracker - Class in org.ovirt.vdsm.jsonrpc.client.internal
Response tracker thread is responsible for tracking and retrying requests.
ResponseTracker() - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
 
ResponseTracking - Class in org.ovirt.vdsm.jsonrpc.client.utils
 
ResponseTracking(JsonRpcRequest, JsonRpcCall, RetryContext, long, ReactorClient, boolean) - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
 
ResponseWorker - Class in org.ovirt.vdsm.jsonrpc.client.internal
ResponseWorker is responsible to process responses for all the JsonRpcClient and it is produced by ReactorFactory.
ResponseWorker(int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
 
Retryable<T> - Class in org.ovirt.vdsm.jsonrpc.client.utils.retry
Wrapper of any Callable which retries call method execution based on provided RetryPolicy.
Retryable(Callable<T>, ClientPolicy) - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.retry.Retryable
 
RetryContext - Class in org.ovirt.vdsm.jsonrpc.client.utils.retry
RetryConext represents current execution retry state.
RetryContext(ClientPolicy) - Constructor for class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
 
run() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker
 
run() - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
 
run() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
Main loop for message processing.

S

scheduleTask(Callable<T>) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
selector - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
 
selector - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
 
send() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
send(byte[]) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Sender
 
send(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
Sender - Interface in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
 
sendHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
Client sends protocol specific heartbeat message
sendHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
sendMessage(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
Sends message using provided byte array.
sendMessage(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
 
sendMessage(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompListener
 
sendMessage(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClient
 
sendMessage(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompListener
 
sendNow(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
ServerListener - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl
 
ServerListener(Sender) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.ServerListener
 
setClientPolicy(ClientPolicy) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
setClientPolicy(ClientPolicy) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompListener
 
setClientPolicy(ClientPolicy) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompListener
 
setClientRetryPolicy(ClientPolicy) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
 
setCode(int) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
 
setData(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
 
setError(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
 
setEventQueue(String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
 
setId(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
 
setId(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
 
setIdentifier(String) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
setIncomingHeartbeat(int) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
setIncomingHeartbeat(boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
setMessage(String) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.JsonRpcError
 
setMethod(String) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
 
setMethod(String) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
 
setOutgoingHeartbeat(int) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
setOutgoingHeartbeat(boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
setParams(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
 
setParams(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
 
setResetConnection(boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
 
setResult(JsonNode) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
 
setRetryPolicy(ClientPolicy) - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcClient
 
setTimeout(long) - Method in class org.ovirt.vdsm.jsonrpc.client.utils.ResponseTracking
 
setTimeUnit(TimeUnit) - Method in class org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy
 
SSLClient - Class in org.ovirt.vdsm.jsonrpc.client.reactors
ReactorClient implementation to provide encrypted communication.
SSLClient(Reactor, Selector, String, int, SSLContext) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
 
SSLClient(Reactor, Selector, String, int, SSLContext, SocketChannel) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
 
SSLEngineNioHelper - Class in org.ovirt.vdsm.jsonrpc.client.reactors
Helper object responsible for low level ssl communication.
SSLEngineNioHelper(SocketChannel, SSLEngine, OneTimeCallback, SSLClient) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
 
SSLStompClient - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
 
SSLStompClient(Reactor, Selector, String, int, SSLContext) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
 
SSLStompListener - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
 
SSLStompListener(Reactor, Selector, String, int, SocketChannel, SSLContext) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompListener
 
SSLStompReactor - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
 
SSLStompReactor(SSLContext) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompReactor
 
StompClient - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
 
StompClient(Reactor, Selector, String, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClient
 
StompClientPolicy - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
 
StompClientPolicy(int, int, int, Class<? extends Exception>, String, String) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
 
StompClientPolicy(int, int, int, int, List<Class<? extends Exception>>, String, String) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
 
StompClientPolicy(int, int, int, String, String) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompClientPolicy
 
StompCommonClient - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
 
StompCommonClient(Reactor, String, int) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
StompListener - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
 
StompListener(Reactor, Selector, String, int, SocketChannel) - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompListener
 
StompReactor - Class in org.ovirt.vdsm.jsonrpc.client.reactors.stomp
 
StompReactor() - Constructor for class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompReactor
 
subscribe(EventSubscriber) - Method in class org.ovirt.vdsm.jsonrpc.client.events.EventPublisher
 
subscribe() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
subscribe(S) - Method in interface org.reactivestreams.Publisher
Request Publisher to start streaming data.
subscribed - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
Subscriber<T> - Interface in org.reactivestreams
Will receive call to Subscriber.onSubscribe(Subscription) once after passing an instance of Subscriber to Publisher.subscribe(Subscriber).
Subscription - Interface in org.reactivestreams
A Subscription represents a one-to-one lifecycle of a Subscriber subscribing to a Publisher.
SUBSCRIPTION_ALL - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 
SubscriptionHolder - Class in org.ovirt.vdsm.jsonrpc.client.events
Holds subscription information such as amount of messages requested by EventSubscriber.
SubscriptionHolder(EventSubscriber, AtomicInteger) - Constructor for class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionHolder
Creates a holder which subscriber instance and count and it prepares subscription id representation for event matching.
subscriptionIds - Variable in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
SubscriptionMatcher - Class in org.ovirt.vdsm.jsonrpc.client.events
Matcher is responsible for holding all subscriptions and match them to incoming events.
SubscriptionMatcher() - Constructor for class org.ovirt.vdsm.jsonrpc.client.events.SubscriptionMatcher
 
swapHeartbeat(String) - Static method in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 

T

toByteArray() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
 
toJson() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
 
toJson() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
 
toString() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcEvent
 
toString() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcRequest
 
toString() - Method in class org.ovirt.vdsm.jsonrpc.client.JsonRpcResponse
 
toString() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
trimEndOfMessage() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 

U

unsubscribe() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
update(String) - Method in interface org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Listener
 
update(Message) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.ServerListener
 
updateInterestedOps() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient
 
updateInterestedOps() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
Updates selection key's operation set.
updateInterestedOps() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
 
updateLastIncomingHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
updateLastOutgoingHeartbeat() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
 
updatePolicyWithHeartbeat(String, boolean) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
UTF8 - Static variable in class org.ovirt.vdsm.jsonrpc.client.utils.JsonUtils
 

V

validate() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
Validates policy when it is set.
validate() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
 
valueOf(String) - Static method in enum org.ovirt.vdsm.jsonrpc.client.reactors.ReactorType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.ovirt.vdsm.jsonrpc.client.reactors.ReactorType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message.Command
Returns an array containing the constants of this enum type, in the order they are declared.

W

waitOperation() - Method in class org.ovirt.vdsm.jsonrpc.client.utils.retry.RetryContext
 
wakeup() - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
 
withAdditionalContent(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
withContent(byte[]) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
withError(Map<String, Object>) - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
Adds error Map to the response.
withHeader(String, String) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
withHeaders(Map<String, String>) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Message
 
withOptionalParameter(String, String) - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
Adds parameter which is optional by method runtime and if not provided default value will be used during method execution.
withOptionalParameter(String, Object) - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
Adds parameter which is optional by method runtime and if not provided default value will be used during method execution.
withOptionalParameterAsList(String, List) - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
Adds List of values which is optional by method runtime and if not provided default value will be used during method execution.
withOptionalParameterAsMap(String, Map) - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
Adds Map of values which is optional by method runtime and if not provided default value will be used during method execution.
withParameter(String, String) - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
Adds parameter which is required by method runtime.
withParameter(String, Object) - Method in class org.ovirt.vdsm.jsonrpc.client.RequestBuilder
Adds parameter which is required by method runtime.
withResult(Map<String, Object>) - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
Adds result Map to the response.
withResult(String) - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
Adds result String to the response.
withResult(List<Object>) - Method in class org.ovirt.vdsm.jsonrpc.client.ResponseBuilder
Adds result List to the response.
write(ByteBuffer) - Method in class org.ovirt.vdsm.jsonrpc.client.reactors.SSLEngineNioHelper
 
A B C D E F G H I J K L M N O P Q R S T U V W 
Skip navigation links

Copyright © 2016. All rights reserved.