Package com.tangosol.net
package com.tangosol.net
Contains basic cluster interfaces and factories.
-
ClassDescriptionAbstract base of the BackingMapManager implementations.An abstract base for Invocable and PriorityTask implementations.An abstract base for PriorityTask implementations.An abstract base for ServiceLoadBalancer implementations.An Action represents a controllable action or behavior that a Service might perform.ActionPolicy defines which aspects of a Service's behavior are currently allowed.The AddressProvider is a subclass interface of
SocketAddressProvider
which returnsInetSocketAddress
fromAddressProvider.getNextAddress()
.A factory forAddressProvider
objects.AsyncNamedCache<K,V> AsynchronousNamedCache
.AsyncNamedMap<K,V> AsynchronousNamedMap
.An immutable option for creating and configuringAsyncNamedMap
s.A configuration option which determines the ordering of async operations.The BackingMapContext provides an execution context to server side agents such asEntryProcessors
andEntryAggregators
.A callback interface used by CacheService implementations.The BackingMapManager context is used by the CacheService to pass information to the BackingMapManager during the service initialization.Factory for the Coherence™ cache product.CacheFactoryBuilder provides the means for building and managing configurable cache factories across class loaders in a pluggable fashion.Deprecated.A CacheService is a clustered service providing a collection of named Maps that hold resources shared among members of a cluster.CacheAction represents a type of action taken by a CacheService.The Cluster interface represents a collection of services that operate in a clustered network environment.MemberTimeoutAction is taken by the cluster service to remove members from the cluster who have exceeded a network timeout (e.g. packet-timeout).The ClusterDependencies interface defines externally provided dependencies for aCluster
.A provider of nw service instances.Deprecated.This class represents access to a clustered resource such as a Service or NamedCache.A builder to buildCoherence
instances.An interface implemented by listeners ofCoherenceLifecycleEvents
.An enum representing the different modes that aCoherence
instance can run in.The immutable configuration for aCoherence
instance.A builder to build aCoherenceConfiguration
instance.A simple immutable implementation ofCoherenceConfiguration
.An implementation of aSession
allowing applications to use the new operator to create aSession
via the defaultSessionProvider
.CompositeActionPolicy represents the "intersection" of two policies.CompositeAddressProvider is a composite of one or more AddressProviders or addresses that also implements the Set interface.An Iterator over the addresses in this AddressProvider.CompositeSocketAddressProvider is a composite of one or more SocketAddressProviders.Deprecated.As of Coherence 3.7DeflaterOutputShell enforces the "end" call for the corresponding Deflater object.InflaterInputShell enforces the "end" call for the corresponding Inflater object.ConfigurableAddressProvider is an implementation of the AddressProvider interface based on a static list of addresses configured in an XML element that contains one or more items in the following format:A stateful holder for an obtaining an InetSocketAddress object.Deprecated.An interface for cache factory.ConfigurableLocalAddressProvider is an AddressProvider which is only capable of returning local addresses.ConfigurableQuorumPolicy provides a Quorum-basedActionPolicy
for services based on the cluster-configuration.ClusterQuorumPolicy defines an action policy that is applicable to the cluster.MembershipQuorumPolicy is a quorum policy that is stateless and based solely on service membership sizes.A quorum rule defines a set of allowable actions beyond the rule's threshold size.PartitionedCacheQuorumPolicy defines a configurable quorum policy that is applicable to a DistributedCacheService.Action Rules forConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy
Notification is a simple struct carrying the notification info.ProxyQuorumPolicy defines a configurable quorum policy that is applicable to a proxy service.Provides an OutputStream on top of a DatagramPacket.DatagramSocketProivder defines an interface for creating datagram and multicast sockets.DefaultCacheFactoryBuilder
is the default implementation ofCacheFactoryBuilder
.DefaultCacheServer is a simple command line facility and convenience API that starts all services that are declared as requiring an "autostart" in the configurable factory XML descriptor.Deprecated.CacheInfo is a placeholder for cache attributes retrieved during parsing the corresponding cache mapping element.An AddressProvider that additionally allows to retrieve a human readable description of underlying addresses without doing a DNS lookup.A DistributedCacheService is a clustered cache service that partitions its data across cluster members that provide backing storage.ExtensibleConfigurableCacheFactory provides a facility to access caches declared in a "coherence-cache-config.xsd" compliant configuration file.TheExtensibleConfigurableCacheFactory.DefaultDependencies
is a simple implementation of theExtensibleConfigurableCacheFactory
ExtensibleConfigurableCacheFactory.Dependencies
interface.TheExtensibleConfigurableCacheFactory.DependenciesHelper
provides helper method for constructingExtensibleConfigurableCacheFactory.Dependencies
implementations forExtensibleConfigurableCacheFactory
s.The Manager class uses builders to create the required backing maps and provides client access to those maps.The PartitionedBackingMapManager is used by PartitionAwareBackingMap(s) to lazily configure the enclosing PABM based on the configuration settings of the enclosed maps.Communication facilities that provide an asynchronous (non-blocking) way of submitting data exchange requests commonly implement mechanisms of modulating the control flow for underlying data transfer units (e.g. messages or packets).A Guardable is a logical execution unit whose lifetime may be guarded by a Guardian.A Guardian is responsible for monitoring the registeredGuardable
objects.A GuardContext represents the lifecycle status of a Guardable.A concrete implementation of Guardian/Guardable interactions.Helper class that encapsulates common InetAddress functionality.The RoutableFilter evaluates to true for any InetAddress which is externally routable.SubnetMaskFilter evaluates to true for any address with matches the pattern for the masked bitsA base class forPasswordProvider
implementations that read the contents of anInputStream
to obtain a password.The Invocable object is a cluster-portable object that can be invoked on any set of remote members and each can optionally register a return value for the invocation.The InvocableInOrder interface allows to control the ordering in which the results of Invocable tasks are returned back to the caller by the Invocation service with a thread pool.The InvocationObserver is an object that asynchronously receives notification of results from the execution of Invocable objects.The InvocationService is a Service for delivering executable objects to cluster members for distributed invocation.A non-sticky HTTP load-balancer.An AddressPort is an immutable combination of an IP address and a port number.A Queue is used to effeciently queue up items for daemon threads to work on.A SocketHandler is an abstract daemon thread.MapViewBuilder<K,V> TheViewBuilder
provides a means toMapViewBuilder.build()
amap view
using a fluent pattern / style.The Member interface represents a cluster member.An event which indicates that membership has changed: a Member has joined a Member is leaving a Member has left A MemberEvent object is sent as an argument to the MemberListener interface methods.The MemberIdentity interface represents the identity of a cluster member.A provider of values for a member's identity.The listener interface for receiving MemberEvents.NamedCache<K,V> A Map-based data-structure that manages entries across one or more processes.NamedCollection defines a common base interface for various named collection types.The Option interface defines the root interface of all NamedCollection Options.NamedMap<K,V> A Map-based data-structure that manages entries across one or more processes.An immutable option for requesting and configuringNamedMap
s.A NameService is a service that accepts connections from external clients (e.g.An object which implementsNameService.LookupCallback
can be registered with aNameService
viaNameService.addLookupCallback(com.tangosol.net.NameService.LookupCallback)
to perform a lookup on names that were not found in the NameService's directory.An object which implementsNameService.RequestContext
stores information about the NameService request.During thelookup
call, if the retrieved object isNameService.Resolvable
, then the result of theresolve
call is returned.NonBlockingInvocable is anInvocable
that can be executed asynchronously.TCP based non-blocking datagram socket implementation.A specialization ofTcpDatagramSocket.Impl
which provides non-blocking functionality, seeNonBlockingTcpDatagramSocket.Impl.send(DatagramPacket)
.OperationalContext is an interface for providing Oracle Coherence operational configuration.ATopicService
which provides globally ordered topics.A PartitionedService is aware of a mapping of keys to partitions and of partitions to cluster members.PartitionedAction represents a type of action taken by a PartitionedService.A PartitionedAction representing the recovery of orphaned partitions from the persistent storage, or the assignment of empty partitions if the persistent storage is unavailable or lost.PasswordProvider allows Coherence users to plug in their own mechanism to determine the appropriate password.Ping is a simple utility for testing if a machine is reachable.The PriorityTask interface allows to control the ordering in which a service schedules tasks for execution using a thread pool and limit their execution times to a specified duration.A ProxyService is a clustered service that accepts connections from external clients (e.g.ProxyAction represents a type of action taken by a ProxyService.A RefreshableAddressProvider is an AddressProvider implementation that wraps another AddressProvider and refresh the address list of the provider asynchronously.A resource that is activated and then at a later time be released.Signals that a request execution in a distributed environment failed to complete successfully.Signals that a request was not allowed to complete due to the related service action being disallowed by the corresponding ActionPolicy.Signals that a request execution in a distributed environment did not complete in a pre-determined amount of time.Implementation ofCacheFactoryBuilder
that manages multiple instances ofConfigurableCacheFactory
.This interface is used to derive a scope name used to create an instance ofConfigurableCacheFactory
.This Service interface represents a controllable service that operates in a clustered network environment.MemberJoinAction is taken to allow a new member to join a clustered Service.The ServiceDependencies interface defines externally provided dependencies forclustered services
.ServiceFailurePolicy is used to control how a Guardable associated with a service is managed by its Guardian after the configured timeout.The ServiceInfo represents information about a Service that operates in a clustered network environment.A ServiceLoad encapsulates information about the current utilization of a Service.A ServiceLoadBalancer is a pluggable strategy for controlling the client load across individual members of a clustered Service.TheServiceMonitor
is a facility that keeps registered services alive.Signals that a request was not able to execute because the underlying service has been stopped.A thread-safe mechanism to request Coherence-based resources, likeNamedCache
s, from a deployed module.Deprecated.since 20.12Session.Option
has been replaced bySessionConfiguration
A class that can provide the configuration options for aSession
.A builder to build aSessionConfiguration.ConfigurableCacheFactorySessionConfig
.An immutableSessionConfiguration
to configure aSession
that wraps an underlyingConfigurableCacheFactory
.CreatesSession
s for use by applications requiring Coherence-based resources, includingNamedCache
s, often for specificClassLoader
s, for deployed modules.A context used by providers.Deprecated.Implemented by suppliers of aSessionProvider
.Deprecated.since 20.12 there is no replacement for this classA simple ServiceLoadBalancer implementation.TheSimpleServiceMonitor
starts and monitors services that are registered for monitoring.Implementation ofCacheFactoryBuilder
that maintains a singleConfigurableCacheFactory
instance regardless of the requesting ClassLoader if a URI is not provided.The SocketAddressProvider is an interface that serves as a means to provide addresses to a consumer.SocketOptions provides a means to configure the various aspects of Sockets.SocketProvider defines an abstraction for creating various types of sockets.The SocketProviderFactory produces SocketProviders.DefaultDependencies is a basic implementation of the Dependencies interface.Dependencies specifies all dependency requirements of the SocketProviderFactory.Enumeration of Provider types.SystemDatagramSocketProvider produces JVM default datagram socketsTCP based datagram socket implementation.A specialized version ofDatagramSocketImpl
.TcpDatagramSocketProvider produces datagram sockets that uses TCP sockets underneath for unicast communication.DefaultDependenceis is a basic implementation of the Dependencies interface providing "setter" methods for each property.Dependencies specifies all dependency requirements of the TcpDatagramSocketProvider.A ThreadPoolManager manages the thread pool information for a Coherence service thread pool.A ThreadPoolSizingStrategy is a pluggable strategy used by a Coherence service thread pool to manage its size.A TopicService is a service providing Topics that can be used for publish/subscribe functionality and message queue processing.AMemberIdentityProvider
that retrieves identity values from URLs, files, or class path resources.APasswordProvider
that reads the contents of a URL to obtain a password.Defines aNamedCollection.Option
for asserting the type of values used with aNamedTopic
.Defines aNamedCollection.Option
for asserting the type of values used with aNamedTopic
.ViewBuilder<K,V> TheViewBuilder
provides a means toViewBuilder.build()
aview
(ContinuousQueryCache
) using a fluent pattern / style.CacheService implementation that delegates to a wrapped CacheService instance.InvocationService implementation that delegates to a wrapped InvocationService instance.Service implementation that delegates to a wrapped Service instance.ASessionConfiguration
that delegates to anotherSessionConfiguration
.
PortableException