Package | Description |
---|---|
org.rvpf.base.store | |
org.rvpf.base.value |
Point value classes.
|
org.rvpf.store.client |
Store client common definitions.
|
org.rvpf.store.server.archiver |
Modifier and Type | Method and Description |
---|---|
boolean |
Store.confirm(PointValue pointValue,
boolean confirmValue)
Confirms a point value.
|
void |
Store.connect()
Connects.
|
StoreValues |
Store.deliver(int limit,
long timeout)
Delivers subscribed point values from store update events.
|
StoreValues |
StoreValuesQuery.getResponse()
Gets the response from the point's store.
|
void |
Store.impersonate(Optional<String> user)
Impersonates an other user.
|
Optional<StoreValues> |
Store.nextValues()
Returns the next store values to our store queries.
|
boolean |
Store.probe()
Probes the state of the store session.
|
StoreValues |
Store.pull(StoreValuesQuery query,
long timeout)
Pulls points values.
|
int |
Store.purge(UUID[] pointUUIDs,
TimeInterval timeInterval)
Purges point values.
|
StoreValues |
Store.select(StoreValuesQuery query)
Selects the store values for a store query.
|
boolean |
Store.sendUpdates()
Sends the pending updates.
|
boolean |
Store.sendUpdates(Collection<PointValue> updates)
Sends updates.
|
boolean |
Store.subscribe(Collection<UUID> points)
Subscribes to point values store update events.
|
boolean |
Store.subscribe(UUID[] points)
Subscribes to point values store update events.
|
EnumSet<Externalizer.ValueType> |
Store.supportedValueTypes()
Gets the value types supported by this store.
|
boolean |
Store.supportsCount()
Asks if this store supports count.
|
boolean |
Store.supportsDelete()
Asks if this store supports delete.
|
boolean |
Store.supportsDeliver()
Asks if this store supports deliver.
|
boolean |
Store.supportsPull()
Asks if this store supports pull queries.
|
boolean |
Store.supportsPurge()
Asks if this store supports purge.
|
boolean |
Store.supportsSubscribe()
Asks if this store supports subscribe.
|
boolean |
Store.unsubscribe(UUID[] points)
Unsubscribes from points values events.
|
Modifier and Type | Method and Description |
---|---|
boolean |
PointValue.confirm(boolean confirmValue)
Confirms this.
|
boolean |
PointValue.updateStore()
Updates the store with this.
|
Modifier and Type | Method and Description |
---|---|
protected StoreAccessException |
AbstractStore.accessException(SessionException cause)
Returns an access exception.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractStore.bindPoints()
Binds points to their UUID.
|
protected void |
RMIStore.bindPoints(Set<Point> points)
Binds points to their UUID.
|
protected void |
RMISink.bindPoints(Set<Point> points)
Binds points to their UUID.
|
protected void |
AbstractStore.bindPoints(Set<Point> points)
Binds points to their UUID.
|
boolean |
RMIStore.confirm(PointValue pointValue,
boolean confirmValue)
Confirms a point value.
|
boolean |
AbstractStore.confirm(PointValue pointValue,
boolean confirmValue)
Confirms a point value.
|
void |
SOMSink.connect()
Connects.
|
void |
RMIStore.connect()
Connects.
|
void |
RMISink.connect()
Connects.
|
StoreValues |
RMIStore.deliver(int limit,
long timeout)
Delivers subscribed point values from store update events.
|
StoreValues |
AbstractStore.deliver(int limit,
long timeout)
Delivers subscribed point values from store update events.
|
void |
RMIStore.impersonate(Optional<String> user)
Impersonates an other user.
|
void |
AbstractStore.impersonate(Optional<String> user)
Impersonates an other user.
|
Optional<StoreValues> |
RMIStore.nextValues()
Returns the next store values to our store queries.
|
boolean |
SOMSink.probe()
Probes the state of the store session.
|
boolean |
RMIStore.probe()
Probes the state of the store session.
|
boolean |
RMISink.probe()
Probes the state of the store session.
|
StoreValues |
RMIStore.pull(StoreValuesQuery query,
long timeout)
Pulls points values.
|
StoreValues |
AbstractStore.pull(StoreValuesQuery query,
long timeout)
Pulls points values.
|
int |
RMIStore.purge(UUID[] pointUUIDs,
TimeInterval timeInterval)
Purges point values.
|
int |
AbstractStore.purge(UUID[] pointUUIDs,
TimeInterval timeInterval)
Purges point values.
|
StoreValues |
RMIStore.select(StoreValuesQuery query)
Selects the store values for a store query.
|
StoreValues |
AbstractSink.select(StoreValuesQuery query)
Selects the store values for a store query.
|
boolean |
AbstractStore.sendUpdates()
Sends the pending updates.
|
boolean |
SOMSink.sendUpdates(Collection<PointValue> updates)
Sends updates.
|
boolean |
RMIStore.sendUpdates(Collection<PointValue> updates)
Sends updates.
|
boolean |
RMISink.sendUpdates(Collection<PointValue> updates)
Sends updates.
|
boolean |
AbstractStore.subscribe(Collection<UUID> points)
Subscribes to point values store update events.
|
boolean |
RMIStore.subscribe(UUID[] points)
Subscribes to point values store update events.
|
boolean |
AbstractStore.subscribe(UUID[] points)
Subscribes to point values store update events.
|
protected String |
RMIStore.supportedValueTypeCodes()
Returns a string of supported value type codes.
|
protected String |
RMISink.supportedValueTypeCodes()
Returns a string of supported value type codes.
|
protected abstract String |
AbstractStore.supportedValueTypeCodes()
Returns a string of supported value type codes.
|
EnumSet<Externalizer.ValueType> |
AbstractStore.supportedValueTypes()
Gets the value types supported by this store.
|
boolean |
RMIStore.supportsCount()
Asks if this store supports count.
|
boolean |
AbstractStore.supportsCount()
Asks if this store supports count.
|
boolean |
RMIStore.supportsDelete()
Asks if this store supports delete.
|
boolean |
RMISink.supportsDelete()
Asks if this store supports delete.
|
boolean |
AbstractStore.supportsDelete()
Asks if this store supports delete.
|
boolean |
RMIStore.supportsDeliver()
Asks if this store supports deliver.
|
boolean |
AbstractStore.supportsDeliver()
Asks if this store supports deliver.
|
boolean |
RMIStore.supportsPull()
Asks if this store supports pull queries.
|
boolean |
AbstractStore.supportsPull()
Asks if this store supports pull queries.
|
boolean |
AbstractStore.supportsPurge()
Asks if this store supports purge.
|
boolean |
RMIStore.supportsSubscribe()
Asks if this store supports subscribe.
|
boolean |
AbstractStore.supportsSubscribe()
Asks if this store supports subscribe.
|
boolean |
RMIStore.unsubscribe(UUID[] points)
Unsubscribes from points values events.
|
boolean |
AbstractStore.unsubscribe(UUID[] points)
Unsubscribes from points values events.
|
Modifier and Type | Method and Description |
---|---|
boolean |
CleanUpArchiver.cleanUp(String storeName,
Metadata metadata,
KeyedGroups atticProperties)
Cleans up.
|
Copyright © 2003-2019 Serge Brisson. All Rights Reserved.