Package | Description |
---|---|
com.tangosol.application |
Contains classes supporting the Coherence Container.
|
com.tangosol.coherence.config.builder |
Defines the typical runtime configuration builders for the Coherence
configuration object model.
|
com.tangosol.coherence.config.scheme |
Defines the Coherence configuration object model classes and interfaces for
Caching and Service Schemes.
|
com.tangosol.net |
Contains basic cluster interfaces and factories.
|
com.tangosol.net.partition |
Contains interfaces and classes related to partitioned services.
|
com.tangosol.net.security |
Contains classes related to the Coherence Security Framework.
|
com.tangosol.util |
Contains various generic utilities.
|
Modifier and Type | Method and Description |
---|---|
static MapListener |
ContainerHelper.getContextAwareListener(Service service,
MapListener listener)
Wrap the specified MapListener in such a way that the returned listener
would dispatch events using the caller's context rather than context
associated with the specified Service.
|
static ContainerContext |
ContainerHelper.getSwitchCurrentContext(Service service)
Given the ContainerContext associated with the specified Service and
the current thread's context, return a ContainerContext instance that
should be used by the Service thread to perform actions on behalf
of the current thread's context.
|
static ContainerContext |
ContainerHelper.getSwitchServiceContext(Service service)
Given the ContainerContext associated with the specified Service and
the current thread's context, return a ContainerContext instance that
should be used by the current thread to perform actions on behalf
of the Service thread's context.
|
static void |
ContainerHelper.initializeThreadContext(Service service)
Initialize the thread context for the given Service.
|
Modifier and Type | Method and Description |
---|---|
Service |
ServiceBuilder.realizeService(com.tangosol.config.expression.ParameterResolver resolver,
ClassLoader loader,
Cluster cluster)
Realize (ensure) a Service.
|
Modifier and Type | Method and Description |
---|---|
Service |
AbstractServiceScheme.realizeService(com.tangosol.config.expression.ParameterResolver resolver,
ClassLoader loader,
Cluster cluster)
Realize (ensure) a Service.
|
Service |
CustomScheme.realizeService(com.tangosol.config.expression.ParameterResolver resolver,
ClassLoader loader,
Cluster cluster)
Realize (ensure) a Service.
|
Service |
RemoteCacheScheme.realizeService(com.tangosol.config.expression.ParameterResolver resolver,
ClassLoader loader,
Cluster cluster)
Realize (ensure) a Service.
|
Service |
RemoteInvocationScheme.realizeService(com.tangosol.config.expression.ParameterResolver resolver,
ClassLoader loader,
Cluster cluster)
Realize (ensure) a Service.
|
Service |
TransactionalScheme.realizeService(com.tangosol.config.expression.ParameterResolver resolver,
ClassLoader loader,
Cluster cluster)
Realize (ensure) a Service.
|
Service |
ViewScheme.realizeService(com.tangosol.config.expression.ParameterResolver resolver,
ClassLoader loader,
Cluster cluster) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractServiceScheme.injectScopeNameIntoService(Service service)
|
protected boolean |
CacheStoreScheme.isSerializerCompatible(Service serviceThis,
Service serviceThat)
Determines whether or not the serializers for the specified services are
compatible.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractServiceLoadBalancer<S extends Service,T extends ServiceLoad>
An abstract base for ServiceLoadBalancer implementations.
|
interface |
ServiceLoadBalancer<S extends Service,T extends ServiceLoad>
A ServiceLoadBalancer is a pluggable strategy for controlling the
client load across individual members of a clustered Service.
|
class |
SimpleServiceLoadBalancer<S extends Service,T extends ServiceLoad>
A simple ServiceLoadBalancer implementation.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CacheService
A CacheService is a clustered service providing a collection of named Maps
that hold resources shared among members of a cluster.
|
interface |
DistributedCacheService
A DistributedCacheService is a clustered cache service that partitions its
data across cluster members that provide backing storage.
|
interface |
FederatedCacheService
A FederatedCacheService is a distributed cache service that also replicates
data to other clusters/participants in the Federation.
|
interface |
InvocationService
The InvocationService is a Service for delivering executable objects to
cluster members for distributed invocation.
|
interface |
NameService
A NameService is a service that accepts connections from external clients
(e.g.
|
interface |
PartitionedService
A PartitionedService is aware of a mapping of keys to partitions and of
partitions to cluster members.
|
interface |
ProxyService
A ProxyService is a clustered service that accepts connections from
external clients (e.g.
|
Modifier and Type | Class and Description |
---|---|
class |
WrapperCacheService
CacheService implementation that delegates to a wrapped CacheService
instance.
|
class |
WrapperInvocationService
InvocationService implementation that delegates to a wrapped
InvocationService instance.
|
Modifier and Type | Field and Description |
---|---|
protected S |
AbstractServiceLoadBalancer.m_service
The containing Service.
|
protected Service |
ConfigurableQuorumPolicy.MembershipQuorumPolicy.m_service
The Service that this policy applies to.
|
protected Service |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.m_service
The cluster service.
|
protected Service |
WrapperService.m_service
The (wrapped) Service.
|
Modifier and Type | Field and Description |
---|---|
protected Map<Service,String> |
ExtensibleConfigurableCacheFactory.m_mapServices
Map used to hold references to services that are ensured by this
factory where values are non-scoped service names.
|
protected Map<Service,String> |
SimpleServiceMonitor.m_mapServices
A map of
Service s to be monitored with values being non-scoped service names. |
Modifier and Type | Method and Description |
---|---|
Service |
ExtensibleConfigurableCacheFactory.ensureService(ServiceScheme scheme)
Ensure the service for the specified scheme then start the service if
it isn't running.
|
Service |
ConfigurableCacheFactory.ensureService(String sServiceName)
Ensure a service for the given name.
|
Service |
DefaultConfigurableCacheFactory.ensureService(String sServiceName)
Deprecated.
Ensure a service for the given name.
|
Service |
ExtensibleConfigurableCacheFactory.ensureService(String sServiceName)
Ensure a service for the given name.
|
Service |
Cluster.ensureService(String sName,
String sType)
Obtains a Service object for the specified service name and type.
|
Service |
DefaultConfigurableCacheFactory.ensureService(XmlElement xmlScheme)
Deprecated.
Ensure the service for the specified scheme.
|
protected Service |
DefaultConfigurableCacheFactory.ensureServiceInternal(XmlElement xmlScheme)
Deprecated.
Ensure the service for the specified scheme.
|
Service |
ConfigurableQuorumPolicy.MembershipQuorumPolicy.getService()
Return the Service which this policy applies to.
|
Service |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.getService()
Return the Cluster service.
|
Service |
MemberEvent.getService()
Return the Service that fired the event
|
Service |
WrapperService.getService()
Return the wrapped Service.
|
static Service |
CacheFactory.getService(String sName)
Return an instance of a service configured by the current
ConfigurableCacheFactory.
|
Service |
Cluster.getService(String sName)
Returns a Service object for the specified service name.
|
Modifier and Type | Method and Description |
---|---|
Map<Service,String> |
ExtensibleConfigurableCacheFactory.getServiceMap()
Return a map of services that were successfully started by this
factory where values are corresponding non-scoped service names.
|
List<Service> |
DefaultCacheServer.startServices()
Start all services that are declared as requiring an "autostart" in
the configurable factory XML descriptor.
|
protected Map<Service,String> |
DefaultCacheServer.startServicesInternal()
Starts the services marked with autostart returning a map of a service
name to the started service.
|
protected Map<Service,String> |
DefaultCacheServer.GarServer.startServicesInternal()
Starts the services marked with autostart returning a map of a service
name to the started service.
|
Modifier and Type | Method and Description |
---|---|
void |
ActionPolicy.init(Service service)
Called when the specified service loads and configures this policy.
|
void |
CompositeActionPolicy.init(Service service)
Called when the specified service loads and configures this policy.
|
void |
ConfigurableQuorumPolicy.MembershipQuorumPolicy.init(Service service)
Called when the specified service loads and configures this policy.
|
void |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.init(Service service)
Called when the specified service loads and configures this policy.
|
boolean |
ActionPolicy.isAllowed(Service service,
Action action)
Evaluate if the specified action is currently allowed by this policy.
|
boolean |
CompositeActionPolicy.isAllowed(Service service,
Action action)
Evaluate if the specified action is currently allowed by this policy.
|
boolean |
ConfigurableQuorumPolicy.PartitionedCacheQuorumPolicy.isAllowed(Service service,
Action action)
Evaluate if the specified action is currently allowed by this policy.
|
boolean |
ConfigurableQuorumPolicy.ProxyQuorumPolicy.isAllowed(Service service,
Action action)
Evaluate if the specified action is currently allowed by this policy.
|
boolean |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.isAllowed(Service service,
Action action)
Evaluate if the specified action is currently allowed by this policy.
|
protected boolean |
DefaultConfigurableCacheFactory.isSerializerCompatible(Service serviceThis,
Service serviceThat)
Deprecated.
Determines whether or not the serializers for the specified services are
compatible.
|
void |
ServiceFailurePolicy.onGuardableRecovery(Guardable guardable,
Service service)
Take appropriate action after the specified guardable (associated with the
specified service) has missed a "soft-timeout" and has entered the
"RECOVERY" state.
|
void |
ServiceFailurePolicy.onGuardableTerminate(Guardable guardable,
Service service)
Take appropriate action after the specified guardable (associated with the
specified service) has missed a "hard-timeout" and has entered the
"TERMINATING" state.
|
protected void |
ConfigurableQuorumPolicy.MembershipQuorumPolicy.setService(Service service)
Set the service that this policy applies to.
|
void |
ConfigurableQuorumPolicy.ClusterQuorumPolicy.setService(Service service)
Set the Cluster service.
|
protected void |
DefaultConfigurableCacheFactory.startService(Service service)
Deprecated.
Start the given
Service . |
protected void |
ExtensibleConfigurableCacheFactory.startService(Service service)
Start the given
Service . |
Modifier and Type | Method and Description |
---|---|
void |
ServiceMonitor.registerServices(Map<Service,String> mapServices)
Adds a set of
Service s to be monitored providing life support. |
void |
SimpleServiceMonitor.registerServices(Map<Service,String> mapServices)
Adds a set of
Service s to be monitored providing life support. |
void |
ServiceMonitor.unregisterServices(Set<Service> setServices)
Removes the supplied set of
Service s from monitoring. |
void |
SimpleServiceMonitor.unregisterServices(Set<Service> setServices)
Removes the supplied set of
Service s from monitoring. |
Constructor and Description |
---|
WrapperService(Service service)
Create a new WrapperService that delegates to the given Service
instance.
|
Modifier and Type | Method and Description |
---|---|
void |
FailoverAccessPolicy.init(Service service)
Called when the specified service loads and configures this policy.
|
boolean |
FailoverAccessPolicy.isAllowed(Service service,
Action action)
Evaluate if the specified action is currently allowed by this policy.
|
Modifier and Type | Method and Description |
---|---|
Subject |
DefaultIdentityAsserter.assertIdentity(Object oToken,
Service service)
Asserts an identity based on a token-based identity assertion.
|
Subject |
IdentityAsserter.assertIdentity(Object oToken,
Service service)
Asserts an identity based on a token-based identity assertion.
|
Subject |
JAASIdentityAsserter.assertIdentity(Object oToken,
Service service)
Asserts an identity based on a token-based identity assertion.
|
Object |
DefaultIdentityTransformer.transformIdentity(Subject subject,
Service service)
Transform a Subject to a token that asserts an identity.
|
Object |
IdentityTransformer.transformIdentity(Subject subject,
Service service)
Transform a Subject to a token that asserts an identity.
|
Modifier and Type | Method and Description |
---|---|
void |
NullImplementation.NullActionPolicy.init(Service service)
Called when the specified service loads and configures this policy.
|
boolean |
NullImplementation.NullActionPolicy.isAllowed(Service service,
Action action)
Evaluate if the specified action is currently allowed by this policy.
|