Package | Description |
---|---|
org.rvpf.base.store | |
org.rvpf.store.client |
Store client common definitions.
|
org.rvpf.store.server |
Store server common definitions.
|
org.rvpf.store.server.polator | |
org.rvpf.store.server.rmi |
RMI session support.
|
org.rvpf.store.server.the |
TheStore server.
|
org.rvpf.store.server.the.bdb |
TheStore BDB-JE back-end.
|
org.rvpf.store.server.the.memory | |
org.rvpf.store.server.the.sql |
TheStore JDBC back-end.
|
Modifier and Type | Method and Description |
---|---|
StoreValues |
StoreSessionProxy.deliver(int limit,
long timeout)
Delivers point value events.
|
StoreValues |
StoreSession.deliver(int limit,
long timeout)
Delivers point value events.
|
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.
|
StoreValues |
StoreSessionProxy.ValuesIterator.getStoreValues()
Gets the store values.
|
StoreValues |
StoreSessionProxy.pull(StoreValuesQuery query,
long timeout)
Pulls points values.
|
StoreValues |
StoreSession.pull(StoreValuesQuery query,
long timeout)
Pulls points values.
|
StoreValues |
Store.pull(StoreValuesQuery query,
long timeout)
Pulls points values.
|
StoreValues |
Store.select(StoreValuesQuery query)
Selects the store values for a store query.
|
StoreValues[] |
StoreSessionProxy.select(StoreValuesQuery[] queries)
Selects point values.
|
StoreValues[] |
StoreSession.select(StoreValuesQuery[] queries)
Selects point values.
|
StoreValues[] |
StoreSessionProxy.subscribe(UUID[] pointUUIDs)
Subscribes to point values events.
|
StoreValues[] |
StoreSession.subscribe(UUID[] pointUUIDs)
Subscribes to point values events.
|
Modifier and Type | Method and Description |
---|---|
Optional<StoreValues> |
StoreSessionProxy.getResponse()
Gets the response.
|
Optional<StoreValues> |
Store.nextValues()
Returns the next store values to our store queries.
|
List<StoreValues> |
StoreSessionProxy.select(Collection<StoreValuesQuery> queries)
Selects point values.
|
Optional<StoreValues> |
StoreSessionProxy.select(StoreValuesQuery storeQuery)
Selects point values.
|
List<StoreValues> |
StoreSessionProxy.subscribe(Collection<UUID> pointUUIDs)
Subscribes to point values events.
|
Optional<StoreValues> |
StoreSessionProxy.subscribe(UUID pointUUID)
Subscribes to a point values events.
|
Modifier and Type | Method and Description |
---|---|
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.
|
StoreValues |
RMIStore.pull(StoreValuesQuery query,
long timeout)
Pulls points values.
|
StoreValues |
AbstractStore.pull(StoreValuesQuery query,
long timeout)
Pulls points 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.
|
Modifier and Type | Method and Description |
---|---|
Optional<StoreValues> |
RMIStore.nextValues()
Returns the next store values to our store queries.
|
Optional<StoreValues> |
AbstractSink.nextValues()
Returns the next store values to our store queries.
|
Modifier and Type | Method and Description |
---|---|
StoreValues |
StoreCursor.createResponse(Optional<Identity> identity)
Creates a store values response.
|
StoreValues |
StoreCursor.createResponse(StoreValuesQuery query,
Optional<Identity> identity)
Creates a store values response to a store query.
|
StoreValues[] |
StoreServer.select(StoreValuesQuery[] queries,
Optional<Identity> identity)
Selects point values.
|
protected StoreValues |
StoreServer.Abstract.unknownQueryPoint(StoreValuesQuery query)
Returns an appropriate response for an unknown query point.
|
protected StoreValues |
StoreServer.Abstract.unsupportedPullQuery()
Returns an appropriate response for unsupported pull query.
|
Modifier and Type | Method and Description |
---|---|
Optional<StoreValues> |
StoreServer.pull(StoreValuesQuery query,
long timeout,
StoreSessionImpl storeSession,
Optional<Identity> identity)
Pulls points values.
|
Optional<StoreValues> |
StoreServer.Abstract.pull(StoreValuesQuery query,
long timeout,
StoreSessionImpl storeSession,
Optional<Identity> identity)
Pulls points values.
|
Modifier and Type | Method and Description |
---|---|
void |
StoreStats.addQueryResponse(Optional<StoreValues> response,
long time)
Adds query response stats.
|
Modifier and Type | Method and Description |
---|---|
StoreValues |
Polator.polate(StoreValuesQuery polatedQuery,
StoreCursor storeCursor,
Identity identity)
Inter/extra-polates values for a store query.
|
StoreValues |
Polator.Abstract.polate(StoreValuesQuery polatedQuery,
StoreCursor storeCursor,
Identity identity)
Inter/extra-polates values for a store query.
|
Modifier and Type | Method and Description |
---|---|
StoreValues |
StoreSessionImpl.deliver(int limit,
long timeout)
Delivers point value events.
|
StoreValues |
StoreSessionImpl.pull(StoreValuesQuery query,
long timeout)
Pulls points values.
|
StoreValues[] |
StoreSessionImpl.select(StoreValuesQuery[] queries)
Selects point values.
|
StoreValues[] |
StoreSessionImpl.subscribe(UUID[] pointUUIDs)
Subscribes to point values events.
|
Modifier and Type | Method and Description |
---|---|
StoreValues |
BackEnd.createResponse(StoreValuesQuery query,
Optional<Identity> identity)
Creates store values for a store query.
|
Modifier and Type | Method and Description |
---|---|
StoreValues |
BDBBackEnd.createResponse(StoreValuesQuery query,
Optional<Identity> identity)
Creates store values for a store query.
|
Modifier and Type | Method and Description |
---|---|
StoreValues |
MemoryBackEnd.createResponse(StoreValuesQuery query,
Optional<Identity> identity)
Creates store values for a store query.
|
Modifier and Type | Method and Description |
---|---|
StoreValues |
SQLBackEnd.createResponse(StoreValuesQuery query,
Optional<Identity> identity)
Creates store values for a store query.
|
Copyright © 2003-2019 Serge Brisson. All Rights Reserved.