Skip navigation links
B C D E H I L P R S T U V W 

B

BoundedThreadPool - Class in com.karalabe.iris.common
 
BoundedThreadPool(int, int) - Constructor for class com.karalabe.iris.common.BoundedThreadPool
 
broadcast(String, byte[]) - Method in class com.karalabe.iris.Connection
Broadcasts a message to all members of a cluster.
broadcast(String, byte[]) - Method in class com.karalabe.iris.schemes.BroadcastScheme
 
broadcastMemory - Variable in class com.karalabe.iris.ServiceLimits
Memory allowance for pending broadcasts
BroadcastScheme - Class in com.karalabe.iris.schemes
 
BroadcastScheme(RelayProtocol, ServiceHandler, ServiceLimits, ContextualLogger) - Constructor for class com.karalabe.iris.schemes.BroadcastScheme
 
broadcastThreads - Variable in class com.karalabe.iris.ServiceLimits
Broadcast handlers to execute concurrently

C

close() - Method in class com.karalabe.iris.Connection
Gracefully terminates the connection removing all subscriptions and closing all active tunnels.
close() - Method in class com.karalabe.iris.schemes.BroadcastScheme
 
close() - Method in class com.karalabe.iris.schemes.PublishScheme
 
close() - Method in class com.karalabe.iris.schemes.RequestScheme
 
close() - Method in class com.karalabe.iris.schemes.TunnelScheme
 
close() - Method in class com.karalabe.iris.schemes.TunnelScheme.TunnelBridge
 
close() - Method in class com.karalabe.iris.Service
Unregisters the service instance from the Iris network, removing all subscriptions and closing all active tunnels.
close() - Method in class com.karalabe.iris.Tunnel
Closes the tunnel between the pair.
ClosedException - Exception in com.karalabe.iris.exceptions
Thrown whenever an operation is requested on- or interrupted by a closed connection or tunnel.
ClosedException() - Constructor for exception com.karalabe.iris.exceptions.ClosedException
Constructs a ClosedException with null as its error detail message.
ClosedException(String) - Constructor for exception com.karalabe.iris.exceptions.ClosedException
Constructs a ClosedException with the specified detail message.
ClosedException(String, Throwable) - Constructor for exception com.karalabe.iris.exceptions.ClosedException
Constructs a ClosedException with the specified detail message and cause.
ClosedException(Throwable) - Constructor for exception com.karalabe.iris.exceptions.ClosedException
Constructs a ClosedException with the specified cause and a detail message of (cause==null ? null : cause.toString()) (which typically contains the class and detail message of cause).
com.karalabe.iris - package com.karalabe.iris
Contains the public API into the Iris decentralized cloud messaging system.
com.karalabe.iris.common - package com.karalabe.iris.common
Mostly internal package containing utility classes for the library.
com.karalabe.iris.exceptions - package com.karalabe.iris.exceptions
Contains the custom exceptions used- and returned by the Iris binding.
com.karalabe.iris.protocol - package com.karalabe.iris.protocol
Internal package containing the Iris relay protocol implementation.
com.karalabe.iris.schemes - package com.karalabe.iris.schemes
Internal package containing the Iris communication scheme implementations.
Connection - Class in com.karalabe.iris
Message relay between the local app and the local iris node.
Connection(int) - Constructor for class com.karalabe.iris.Connection
Connects to the Iris network as a simple client.
ContextualLogger - Class in com.karalabe.iris.common
Provides helper methods to enter MDC contextual log messages.
ContextualLogger(Logger, String...) - Constructor for class com.karalabe.iris.common.ContextualLogger
Wraps an SLF4J logger with flexible context handling.
ContextualLogger(ContextualLogger, String...) - Constructor for class com.karalabe.iris.common.ContextualLogger
Creates a new contextual logger, by further specializing an existing one.

D

debug(String, String...) - Method in class com.karalabe.iris.common.ContextualLogger
Enters an MDC context tagged debug entry.

E

error(String, String...) - Method in class com.karalabe.iris.common.ContextualLogger
Enters an MDC context tagged error entry.
eventMemory - Variable in class com.karalabe.iris.TopicLimits
Memory allowance for pending events
eventThreads - Variable in class com.karalabe.iris.TopicLimits
Event handlers to execute concurrently

H

handleAllowance(int) - Method in class com.karalabe.iris.schemes.TunnelScheme.TunnelBridge
 
handleBroadcast(byte[]) - Method in class com.karalabe.iris.schemes.BroadcastScheme
 
handleBroadcast(byte[]) - Method in interface com.karalabe.iris.ServiceHandler
Callback invoked whenever a broadcast message arrives designated to the cluster of which this particular service instance is part of.
handleClose(String) - Method in class com.karalabe.iris.schemes.TunnelScheme.TunnelBridge
 
handleDrop(Exception) - Method in interface com.karalabe.iris.ServiceHandler
Callback notifying the service that the local relay dropped its connection.
handleEvent(byte[]) - Method in interface com.karalabe.iris.TopicHandler
Callback invoked whenever an event is published to the topic subscribed to by this particular handler.
handlePublish(String, byte[]) - Method in class com.karalabe.iris.schemes.PublishScheme
 
handleReply(long, byte[], String) - Method in class com.karalabe.iris.schemes.RequestScheme
 
handleRequest(long, byte[], long) - Method in class com.karalabe.iris.schemes.RequestScheme
 
handleRequest(byte[]) - Method in interface com.karalabe.iris.ServiceHandler
Callback invoked whenever a request designated to the service's cluster is load-balanced to this particular service instance.
handleTransfer(int, byte[]) - Method in class com.karalabe.iris.schemes.TunnelScheme.TunnelBridge
 
handleTunnel(Tunnel) - Method in interface com.karalabe.iris.ServiceHandler
Callback invoked whenever a tunnel designated to the service's cluster is constructed from a remote node to this particular instance.
handleTunnelAllowance(long, int) - Method in class com.karalabe.iris.schemes.TunnelScheme
 
handleTunnelClose(long, String) - Method in class com.karalabe.iris.schemes.TunnelScheme
 
handleTunnelInit(long, long) - Method in class com.karalabe.iris.schemes.TunnelScheme
 
handleTunnelResult(long, long) - Method in class com.karalabe.iris.schemes.TunnelScheme
 
handleTunnelTransfer(long, int, byte[]) - Method in class com.karalabe.iris.schemes.TunnelScheme
 

I

info(String, String...) - Method in class com.karalabe.iris.common.ContextualLogger
Enters an MDC context tagged info entry.
init(Connection) - Method in interface com.karalabe.iris.ServiceHandler
Called once after the service is registered in the Iris network, but before and handlers are activated.
InitializationException - Exception in com.karalabe.iris.exceptions
Thrown if the user fails to initialize its own service.
InitializationException() - Constructor for exception com.karalabe.iris.exceptions.InitializationException
Constructs an InitializationException with null as its error detail message.
InitializationException(String) - Constructor for exception com.karalabe.iris.exceptions.InitializationException
Constructs an InitializationException with the specified detail message.
InitializationException(String, Throwable) - Constructor for exception com.karalabe.iris.exceptions.InitializationException
Constructs an InitializationException with the specified detail message and cause.
InitializationException(Throwable) - Constructor for exception com.karalabe.iris.exceptions.InitializationException
Constructs an InitializationException with the specified cause and a detail message of (cause==null ? null : cause.toString()) (which typically contains the class and detail message of cause).
isDebugEnabled() - Method in class com.karalabe.iris.common.ContextualLogger
Checks whether this logger should report debug levels.
isErrorEnabled() - Method in class com.karalabe.iris.common.ContextualLogger
Checks whether this logger should report error levels.
isInfoEnabled() - Method in class com.karalabe.iris.common.ContextualLogger
Checks whether this logger should report info levels.
isWarnEnabled() - Method in class com.karalabe.iris.common.ContextualLogger
Checks whether this logger should report warning levels.

L

loadContext() - Method in class com.karalabe.iris.common.ContextualLogger
Loads the context into the current thread's MDC.
logger() - Method in class com.karalabe.iris.Connection
Retrieves the contextual logger associated with the connection.

P

process(BroadcastScheme, RequestScheme, PublishScheme, TunnelScheme, Consumer<Exception>) - Method in class com.karalabe.iris.protocol.RelayProtocol
 
publish(String, byte[]) - Method in class com.karalabe.iris.Connection
Publishes an event asynchronously to topic.
publish(String, byte[]) - Method in class com.karalabe.iris.schemes.PublishScheme
 
PublishScheme - Class in com.karalabe.iris.schemes
 
PublishScheme(RelayProtocol, ContextualLogger) - Constructor for class com.karalabe.iris.schemes.PublishScheme
 

R

receive(long) - Method in class com.karalabe.iris.schemes.TunnelScheme.TunnelBridge
 
receive() - Method in class com.karalabe.iris.Tunnel
Retrieves a message from the tunnel, blocking until one is available.
receive(long) - Method in class com.karalabe.iris.Tunnel
Retrieves a message from the tunnel, blocking until one is available or the operation times out.
RelayProtocol - Class in com.karalabe.iris.protocol
 
RelayProtocol(int, String) - Constructor for class com.karalabe.iris.protocol.RelayProtocol
 
RemoteException - Exception in com.karalabe.iris.exceptions
Thrown whenever an error is returned from a remote service.
RemoteException() - Constructor for exception com.karalabe.iris.exceptions.RemoteException
Constructs a RemoteException with null as its error detail message.
RemoteException(String) - Constructor for exception com.karalabe.iris.exceptions.RemoteException
Constructs a RemoteException with the specified detail message.
RemoteException(String, Throwable) - Constructor for exception com.karalabe.iris.exceptions.RemoteException
Constructs a RemoteException with the specified detail message and cause.
RemoteException(Throwable) - Constructor for exception com.karalabe.iris.exceptions.RemoteException
Constructs a RemoteException with the specified cause and a detail message of (cause==null ? null : cause.toString()) (which typically contains the class and detail message of cause).
reply(long, byte[], String) - Method in class com.karalabe.iris.schemes.RequestScheme
 
request(String, byte[], long) - Method in class com.karalabe.iris.Connection
Executes a synchronous request to be serviced by a member of the specified cluster, load-balanced between all participant, returning the received reply.
request(String, byte[], long) - Method in class com.karalabe.iris.schemes.RequestScheme
 
requestMemory - Variable in class com.karalabe.iris.ServiceLimits
Memory allowance for pending requests
RequestScheme - Class in com.karalabe.iris.schemes
 
RequestScheme(RelayProtocol, ServiceHandler, ServiceLimits, ContextualLogger) - Constructor for class com.karalabe.iris.schemes.RequestScheme
 
requestThreads - Variable in class com.karalabe.iris.ServiceLimits
Request handlers to execute concurrently

S

schedule(Runnable, int) - Method in class com.karalabe.iris.common.BoundedThreadPool
 
send(byte[], long) - Method in class com.karalabe.iris.schemes.TunnelScheme.TunnelBridge
 
send(byte[]) - Method in class com.karalabe.iris.Tunnel
Sends a message over the tunnel to the remote pair, blocking until the local Iris node receives the message.
send(byte[], long) - Method in class com.karalabe.iris.Tunnel
Sends a message over the tunnel to the remote pair, blocking until the local Iris node receives the message or the operation times out.
sendBroadcast(String, byte[]) - Method in class com.karalabe.iris.protocol.RelayProtocol
 
sendClose() - Method in class com.karalabe.iris.protocol.RelayProtocol
 
sendPublish(String, byte[]) - Method in class com.karalabe.iris.protocol.RelayProtocol
 
sendReply(long, byte[], String) - Method in class com.karalabe.iris.protocol.RelayProtocol
 
sendRequest(long, String, byte[], long) - Method in class com.karalabe.iris.protocol.RelayProtocol
 
sendSubscribe(String) - Method in class com.karalabe.iris.protocol.RelayProtocol
 
sendTunnelAllowance(long, int) - Method in class com.karalabe.iris.protocol.RelayProtocol
 
sendTunnelClose(long) - Method in class com.karalabe.iris.protocol.RelayProtocol
 
sendTunnelConfirm(long, long) - Method in class com.karalabe.iris.protocol.RelayProtocol
 
sendTunnelInit(long, String, long) - Method in class com.karalabe.iris.protocol.RelayProtocol
 
sendTunnelTransfer(long, int, byte[]) - Method in class com.karalabe.iris.protocol.RelayProtocol
 
sendUnsubscribe(String) - Method in class com.karalabe.iris.protocol.RelayProtocol
 
Service - Class in com.karalabe.iris
Service instance belonging to a particular cluster in the network.
Service(int, String, ServiceHandler) - Constructor for class com.karalabe.iris.Service
Connects to the Iris network and registers a new service instance as a member of the specified service cluster.
Service(int, String, ServiceHandler, ServiceLimits) - Constructor for class com.karalabe.iris.Service
Connects to the Iris network and registers a new service instance as a member of the specified service cluster, overriding the default quality of service limits.
ServiceHandler - Interface in com.karalabe.iris
Callback interface for processing inbound messages designated to a particular service instance.
ServiceLimits - Class in com.karalabe.iris
User limits of the threading and memory usage of a registered service.
ServiceLimits() - Constructor for class com.karalabe.iris.ServiceLimits
 
subscribe(String, TopicHandler) - Method in class com.karalabe.iris.Connection
Subscribes to a topic using handler as the callback for arriving events.
subscribe(String, TopicHandler, TopicLimits) - Method in class com.karalabe.iris.Connection
Subscribes to a topic using handler as the callback for arriving events, and additionally sets some limits on the inbound event processing.
subscribe(String, TopicHandler, TopicLimits) - Method in class com.karalabe.iris.schemes.PublishScheme
 

T

terminate(boolean) - Method in class com.karalabe.iris.common.BoundedThreadPool
 
TimeoutException - Exception in com.karalabe.iris.exceptions
Thrown whenever a time-limited operation expires.
TimeoutException() - Constructor for exception com.karalabe.iris.exceptions.TimeoutException
Constructs a TimeoutException with null as its error detail message.
TimeoutException(String) - Constructor for exception com.karalabe.iris.exceptions.TimeoutException
Constructs a TimeoutException with the specified detail message.
TimeoutException(String, Throwable) - Constructor for exception com.karalabe.iris.exceptions.TimeoutException
Constructs a TimeoutException with the specified detail message and cause.
TimeoutException(Throwable) - Constructor for exception com.karalabe.iris.exceptions.TimeoutException
Constructs a TimeoutException with the specified cause and a detail message of (cause==null ? null : cause.toString()) (which typically contains the class and detail message of cause).
TopicHandler - Interface in com.karalabe.iris
Callback interface for processing events from a single subscribed topic.
TopicLimits - Class in com.karalabe.iris
User limits of the threading and memory usage of a subscription.
TopicLimits() - Constructor for class com.karalabe.iris.TopicLimits
 
truncate(byte[]) - Method in class com.karalabe.iris.common.ContextualLogger
Truncates a binary data blob to a capped size to prevent overloading the loggers.
tunnel(String, long) - Method in class com.karalabe.iris.Connection
Opens a direct tunnel to a member of a remote cluster, allowing pairwise- exclusive, order-guaranteed and throttled message passing between them.
tunnel(String, long) - Method in class com.karalabe.iris.schemes.TunnelScheme
 
Tunnel - Class in com.karalabe.iris
Communication stream between the local application and a remote endpoint.
TunnelBridge(long, int, ContextualLogger) - Constructor for class com.karalabe.iris.schemes.TunnelScheme.TunnelBridge
 
TunnelScheme - Class in com.karalabe.iris.schemes
 
TunnelScheme(RelayProtocol, ServiceHandler, ContextualLogger, Function<TunnelScheme.TunnelBridge, Tunnel>) - Constructor for class com.karalabe.iris.schemes.TunnelScheme
 
TunnelScheme.TunnelBridge - Class in com.karalabe.iris.schemes
 

U

unloadContext() - Method in class com.karalabe.iris.common.ContextualLogger
Unloads the context from the current thread's MDC.
unsubscribe(String) - Method in class com.karalabe.iris.Connection
Unsubscribes from topic, receiving no more event notifications for it.
unsubscribe(String) - Method in class com.karalabe.iris.schemes.PublishScheme
 

V

validateBroadcastPayload(byte[]) - Static method in class com.karalabe.iris.protocol.Validators
 
validateClusterAddress(String) - Static method in class com.karalabe.iris.protocol.Validators
 
validateClusterName(String) - Static method in class com.karalabe.iris.protocol.Validators
 
validatePublishPayload(byte[]) - Static method in class com.karalabe.iris.protocol.Validators
 
validateRequestPayload(byte[]) - Static method in class com.karalabe.iris.protocol.Validators
 
validateTopicName(String) - Static method in class com.karalabe.iris.protocol.Validators
 
validateTunnelPayload(byte[]) - Static method in class com.karalabe.iris.protocol.Validators
 
Validators - Class in com.karalabe.iris.protocol
 

W

warn(String, String...) - Method in class com.karalabe.iris.common.ContextualLogger
Enters an MDC context tagged warning entry.
B C D E H I L P R S T U V W 
Skip navigation links