Package | Description |
---|---|
org.apache.river.reggie |
Provides implementations of
ServiceRegistrar . |
Modifier and Type | Field and Description |
---|---|
private RegistrarImpl.SvcReg |
RegistrarImpl.SvcRegisteredLogObj.reg
The service registration.
|
protected RegistrarImpl.SvcReg |
RegistrarImpl.ItemIter.reg
Next item to return
|
Modifier and Type | Field and Description |
---|---|
private Iterator<RegistrarImpl.SvcReg> |
RegistrarImpl.AllItemIter.iter
Iterator over serviceByID
|
private Iterator<List<RegistrarImpl.SvcReg>> |
RegistrarImpl.ClassItemIter.iter
Values iterator for current HashMap
|
private Map<EntryClass,List<RegistrarImpl.SvcReg>> |
RegistrarImpl.serviceByEmptyAttr
Map from EntryClass to ArrayList(SvcReg).
|
private Map<ServiceID,RegistrarImpl.SvcReg> |
RegistrarImpl.serviceByID
Map from ServiceID to SvcReg.
|
private SortedSet<RegistrarImpl.SvcReg> |
RegistrarImpl.serviceByTime
Identity map from SvcReg to SvcReg, ordered by lease expiration.
|
private Map<String,Map<ServiceID,RegistrarImpl.SvcReg>> |
RegistrarImpl.serviceByTypeName
Map from String to HashMap mapping ServiceID to SvcReg.
|
private Iterator<RegistrarImpl.SvcReg> |
RegistrarImpl.SvcIterator.services
Iterator for list of matching services.
|
private List<RegistrarImpl.SvcReg> |
RegistrarImpl.AttrItemIter.svcs
SvcRegs obtained from serviceByAttr for chosen attr
|
private List<RegistrarImpl.SvcReg> |
RegistrarImpl.ClassItemIter.svcs
SvcRegs obtained from iter or serviceByEmptyAttr
|
Modifier and Type | Method and Description |
---|---|
private RegistrarImpl.SvcReg |
RegistrarImpl.checkLease(ServiceID serviceID,
Uuid leaseID,
long now) |
RegistrarImpl.SvcReg |
RegistrarImpl.ItemIter.nextReg()
Returns the next element in the iteration as a SvcReg.
|
Modifier and Type | Method and Description |
---|---|
private List<RegistrarImpl.SvcReg> |
RegistrarImpl.matchingServices(ServiceType[] types)
Returns a list of services that match all types passed in
|
Modifier and Type | Method and Description |
---|---|
private HashMap |
RegistrarImpl.addAttr(RegistrarImpl.SvcReg reg,
EntryClass eclass,
int fldidx,
Object value)
Put the service under the given attribute value for the given
defining class and field, if it isn't already there.
|
private void |
RegistrarImpl.addAttrs(RegistrarImpl.SvcReg reg,
EntryRep entry)
Put the service in the serviceByAttr map under all attribute values
in the given entry, or in the serviceByEmptyAttr map if the entry
has no attributes, add a new instance of the EntryClass, and update
entryClasses as necessary.
|
private void |
RegistrarImpl.addService(RegistrarImpl.SvcReg reg)
Add a service to our state.
|
private void |
RegistrarImpl.addServiceByTypes(ServiceType type,
RegistrarImpl.SvcReg reg)
Adds a service registration to types in its hierarchy
|
private void |
RegistrarImpl.deleteAttrs(RegistrarImpl.SvcReg reg,
EntryRep entry,
boolean checkDups)
If checkDups is false, delete the service (if present) from
serviceByAttr under all attribute values of the given entry or
from serviceByEmptyAttr if the entry has no attributes.
|
private void |
RegistrarImpl.deleteService(RegistrarImpl.SvcReg reg,
long now)
Delete given service, generating events as necessary.
|
private void |
RegistrarImpl.deleteServiceFromTypes(ServiceType type,
RegistrarImpl.SvcReg reg)
Deletes a service registration from types in its hierarchy
|
private static boolean |
RegistrarImpl.hasAttr(RegistrarImpl.SvcReg reg,
EntryClass eclass,
int fldidx,
Object value)
Test if the service has an entry of the given class or subclass
with a field of the given value.
|
private static boolean |
RegistrarImpl.hasEmptyAttr(RegistrarImpl.SvcReg reg,
EntryClass eclass)
Test if the service has an entry of the exact given class (assumed
to have no fields).
|
private void |
RegistrarImpl.updateAttrs(RegistrarImpl.SvcReg reg,
EntryRep entry,
Object[] values)
Store all non-null elements of values into the given entry,
and update serviceByAttr to match.
|
Constructor and Description |
---|
IDItemIter(Template tmpl,
RegistrarImpl.SvcReg reg)
tmpl.serviceID !
|
SvcRegisteredLogObj(RegistrarImpl.SvcReg reg)
Simple constructor
|
Constructor and Description |
---|
AllItemIter(Iterator<RegistrarImpl.SvcReg> it)
Assumes the empty template
|
AttrItemIter(Template tmpl,
List<RegistrarImpl.SvcReg> svcs)
tmpl.serviceID == null and
tmpl.serviceTypes is empty and
tmpl.attributeSetTemplates[setidx].fields[fldidx] !
|
SvcIterator(Template tmpl,
Iterator<RegistrarImpl.SvcReg> it)
tmpl.serviceID == null and
tmpl.serviceTypes is not empty
|
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.