Package | Description |
---|---|
com.gigaspaces.admin.security | |
com.gigaspaces.cluster.activeelection | |
com.gigaspaces.cluster.activeelection.core | |
com.gigaspaces.internal.naming | |
com.gigaspaces.internal.service | |
com.j_spaces.kernel |
Provides GigaSpaces low level services
|
com.sun.jini.reggie |
Provides implementations of
ServiceRegistrar . |
net.jini.core.lookup | |
net.jini.lookup |
Standard utility classes for managing the join state of a service
and the service discovery duties of a client or service.
|
org.openspaces.pu.container.servicegrid.deploy |
A package including the ability to deploy a processing unit onto the Service Grid.
|
Modifier and Type | Method and Description |
---|---|
void |
AuthenticationListener.serviceAuthenticated(ServiceItem serviceItem,
boolean isLoginSucceed,
Authentication authentication,
String failureMessage) |
Modifier and Type | Method and Description |
---|---|
int |
PriorityElectionFilter.compareTo(ServiceItem service1,
ServiceItem service2) |
ICandidateEntry |
PriorityElectionFilter.getCandidateEntry(ServiceItem service) |
Modifier and Type | Method and Description |
---|---|
boolean |
PriorityElectionFilter.isAcceptable(ActiveElectionState.State aquireState,
List<ServiceItem> candidateSrv)
This method provides the condition to advance the manage member to
aquireState
state. |
Modifier and Type | Method and Description |
---|---|
protected ServiceItem |
ActiveElectionManager.findActive()
Find an ACTIVE service with the election template.
|
ServiceItem |
ActiveElectionEvent.getActiveServiceItem() |
ServiceItem |
SplitBrainServiceEntry.getService() |
protected ServiceItem |
ActiveElectionManager.pollStateUntilAvailable(ActiveElectionState.State pollingState)
Poll the desired service state on naming service while available, when the
pollingState is not available make an attempt to find an ACTIVE state, if ACTIVE
was found notify the IActiveElectionListener
and return the active service. |
Modifier and Type | Method and Description |
---|---|
protected List<ServiceItem> |
ActiveElectionManager.lookup(ActiveElectionState.State state,
int maxMatches)
Lookup the services with desired state.
|
Modifier and Type | Method and Description |
---|---|
int |
IActiveElectionDecisionFilter.compareTo(ServiceItem service1,
ServiceItem service2) |
ICandidateEntry |
IActiveElectionDecisionFilter.getCandidateEntry(ServiceItem service) |
protected void |
ActiveElectionManager.notifyListenerOnActive(ServiceItem activeService)
notify the
IActiveElectionListener about
elected ACTIVE service or an ACTIVE on split-brain occurrence. |
void |
ActiveElectionManager.onActiveDiscoveryCheckExtraBackup(ServiceItem activeServiceItem)
A backup Space verifies that it is a replication target of an active primary Space.
|
Modifier and Type | Method and Description |
---|---|
boolean |
IActiveElectionDecisionFilter.isAcceptable(ActiveElectionState.State advanceState,
List<ServiceItem> candidateSrv)
Returns
true if the managed service is acceptable to advance the state to
advanceState . |
protected void |
ActiveElectionManager.onSplitBrain(List<ServiceItem> splitActives)
The callback method from
SplitBrainController
on 2 or more identified ACTIVE services. |
Constructor and Description |
---|
SplitBrainServiceEntry(ServiceItem service,
ServiceReplicationStatus replicationStatus,
ICandidateEntry electionPriorityEntry) |
Modifier and Type | Method and Description |
---|---|
ServiceItem[] |
INamingService.lookup(ServiceTemplate srvTemplate,
int maxMatches,
ServiceItemFilter filter)
Queries the naming service in the managed set for service(s) that match the input criteria.
|
ServiceItem[] |
LookupNamingService.lookup(ServiceTemplate srvTemplate,
int maxMatches,
ServiceItemFilter filter) |
Modifier and Type | Method and Description |
---|---|
static SecuredService |
ServiceItemUtils.getSecuredService(ServiceItem serviceItem) |
static SecuredService |
ServiceItemUtils.getSecuredServiceIfRelevant(ServiceItem serviceItem) |
static String |
ServiceItemUtils.getSpaceMemberName(ServiceItem serviceItem) |
static IDirectSpaceProxy |
ServiceItemUtils.getSpaceProxy(ServiceItem serviceItem) |
static IDirectSpaceProxy |
ServiceItemUtils.getSpaceProxyIfRelevant(ServiceItem serviceItem) |
Modifier and Type | Method and Description |
---|---|
static String |
JSpaceUtilities.getJMXConnectionUrl(ServiceItem serviceItem)
Get the String value found in the JMXConnection entry, or null if the attribute set does not
include a JMXConnection
|
static Entry |
JSpaceUtilities.getServiceItemLookupAttributeName(ServiceItem serviceItem,
Class<? extends Entry> entryClass) |
static boolean |
JSpaceUtilities.isJMXRemotePortDefined(ServiceItem serviceItem) |
Modifier and Type | Method and Description |
---|---|
ServiceItem |
Item.get()
Convert back to a ServiceItem.
|
ServiceItem |
RegistrarEvent.getServiceItem()
Returns the new state of the item, or null if the item was deleted from the lookup service.
|
static ServiceItem[] |
Item.toServiceItem(ArrayList reps)
Converts an ArrayList of Item to an array of ServiceItem.
|
Constructor and Description |
---|
Item(ServiceItem item)
Converts a ServiceItem to an Item.
|
Modifier and Type | Field and Description |
---|---|
ServiceItem[] |
ServiceMatches.items
Matching items (up to maxMatches from lookup method).
|
Modifier and Type | Method and Description |
---|---|
abstract ServiceItem |
ServiceEvent.getServiceItem()
Returns the new state of the item, or null if the item was deleted from the lookup service.
|
Modifier and Type | Method and Description |
---|---|
ServiceRegistration |
ServiceRegistrar.register(ServiceItem item,
long leaseDuration)
Register a new service or re-register an existing service.
|
Constructor and Description |
---|
ServiceMatches(ServiceItem[] items,
int totalMatches)
Simple constructor.
|
Modifier and Type | Method and Description |
---|---|
ServiceItem |
ServiceDiscoveryEvent.getPostEventServiceItem()
Returns an instance of a
ServiceItem containing the service reference
corresponding to the given event. |
ServiceItem |
ServiceDiscoveryEvent.getPreEventServiceItem()
Returns an instance of a
ServiceItem containing the service reference
corresponding to the given event. |
ServiceItem |
LookupCache.lookup(ServiceItemFilter filter)
Finds a
ServiceItem object that satisfies the given filter
parameter. |
ServiceItem[] |
LookupCache.lookup(ServiceItemFilter filter,
int maxMatches)
Finds an array of instances of
ServiceItem that each satisfy the given
filter parameter. |
ServiceItem[] |
ServiceDiscoveryManager.lookup(ServiceTemplate tmpl,
int minMatches,
int maxMatches,
ServiceItemFilter filter,
long waitDur)
Queries each available lookup service in the managed set for service(s) that match the input
criteria.
|
ServiceItem[] |
ServiceDiscoveryManager.lookup(ServiceTemplate tmpl,
int maxMatches,
ServiceItemFilter filter)
Queries each available lookup service in the managed set for service(s) that match the input
criteria.
|
ServiceItem |
ServiceDiscoveryManager.lookup(ServiceTemplate tmpl,
ServiceItemFilter filter)
Queries each available lookup service in the set of lookup services managed by the
ServiceDiscoveryManager (the managed set) for a service reference that
matches criteria defined by the entity that invokes this method. |
ServiceItem |
ServiceDiscoveryManager.lookup(ServiceTemplate tmpl,
ServiceItemFilter filter,
long waitDur)
Queries each available lookup service in the managed set for a service that matches the input
criteria.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ServiceItemFilter.check(ServiceItem item)
This method defines the implementation of the additional selection criteria (additional
matching and/or proxy preparation) to apply to a
ServiceItem object found through standard template matching. |
Constructor and Description |
---|
ServiceDiscoveryEvent(Object source,
ServiceItem preEventItem,
ServiceItem postEventItem)
The constructor of
ServiceDiscoveryEvent takes three arguments:
An instance of Object corresponding to the instance of
LookupCache from which the given event originated |
Modifier and Type | Method and Description |
---|---|
static ServiceItem[] |
ServiceFinder.find(String name,
Class type,
long wait,
String[] groups,
LookupLocator[] locators) |
Copyright © GigaSpaces.