public interface StoreServer
Modifier and Type | Interface and Description |
---|---|
static class |
StoreServer.Abstract
Abstract store server.
|
Modifier and Type | Method and Description |
---|---|
void |
addNoticeListener(NoticeListener noticeListener)
Adds a notice listener.
|
PointBinding[] |
bind(PointBinding.Request[] bindRequests)
Binds point names to their UUID.
|
void |
disableSuspend()
Disables suspend.
|
void |
enableSuspend()
Enables suspend.
|
Metadata |
getMetadata()
Gets the metadata.
|
int |
getResponseLimit()
Gets the response limit.
|
Collection<State.Group> |
getStateGroups()
Gets the state groups.
|
StoreStats |
getStats()
Gets the store stats.
|
boolean |
isMemory()
Asks if this is a memory store.
|
Optional<Archiver> |
newArchiver()
Returns a new archiver.
|
boolean |
probe()
Probes the state of the server.
|
Optional<StoreValues> |
pull(StoreValuesQuery query,
long timeout,
StoreSessionImpl storeSession,
Optional<Identity> identity)
Pulls points values.
|
int |
purge(UUID[] pointUUIDs,
TimeInterval timeInterval,
Optional<Identity> identity)
Purges points values.
|
void |
removeNoticeListener(NoticeListener noticeListener)
Removes a notice listener.
|
Optional<State> |
resolveForPointUUID(State state,
Optional<UUID> pointUUID)
Resolves a state for a point UUID.
|
void |
resumeUpdates()
Resume updates.
|
StoreValues[] |
select(StoreValuesQuery[] queries,
Optional<Identity> identity)
Selects point values.
|
void |
start()
Starts this server
|
void |
stop()
Stops this server
|
String |
supportedValueTypeCodes()
Returns a string of supported value type codes.
|
boolean |
supportsCount()
Asks if the server supports count.
|
boolean |
supportsDelete()
Asks if the server supports delete.
|
boolean |
supportsDeliver()
Asks if the server supports deliver.
|
boolean |
supportsPull()
Asks if the server supports pull.
|
boolean |
supportsPurge()
Asks if the server supports purge.
|
boolean |
supportsSubscribe()
Asks if the server supports subscribe.
|
void |
suspendUpdates()
Suspends updates.
|
void |
unbind(PointBinding[] bindings)
Unbinds.
|
Exception[] |
update(PointValue[] pointValues,
Optional<Identity> identity)
Updates point values.
|
void addNoticeListener(@Nonnull NoticeListener noticeListener)
noticeListener
- The notice listener.@Nullable @CheckReturnValue PointBinding[] bind(@Nonnull PointBinding.Request[] bindRequests)
bindRequests
- The bind requests.void disableSuspend() throws InterruptedException
InterruptedException
- When interrupted.void enableSuspend()
@Nonnull @CheckReturnValue Metadata getMetadata()
@CheckReturnValue int getResponseLimit()
@Nonnull @CheckReturnValue Collection<State.Group> getStateGroups()
@Nonnull @CheckReturnValue StoreStats getStats()
@CheckReturnValue boolean isMemory()
@Nonnull @CheckReturnValue Optional<Archiver> newArchiver()
@CheckReturnValue boolean probe()
@Nonnull @CheckReturnValue Optional<StoreValues> pull(@Nonnull StoreValuesQuery query, long timeout, @Nonnull StoreSessionImpl storeSession, @Nonnull Optional<Identity> identity) throws SessionException
query
- The store query.timeout
- A time limit in millis to wait for the first value
(negative for infinite).storeSession
- The store session implementation.identity
- The optional requesting identity.SessionException
- On session exception.Store.pull(StoreValuesQuery, long)
int purge(@Nonnull UUID[] pointUUIDs, @Nonnull TimeInterval timeInterval, @Nonnull Optional<Identity> identity) throws ServiceNotAvailableException
pointUUIDs
- The UUID of the points to purge.timeInterval
- A time interval.identity
- The optional requesting identity.ServiceNotAvailableException
- On service not available.void removeNoticeListener(@Nonnull NoticeListener noticeListener)
noticeListener
- The notice listener.@Nonnull @CheckReturnValue Optional<State> resolveForPointUUID(@Nonnull State state, @Nonnull Optional<UUID> pointUUID)
state
- The state.pointUUID
- The optional point UUID.void resumeUpdates()
@Nonnull @CheckReturnValue StoreValues[] select(@Nonnull StoreValuesQuery[] queries, @Nonnull Optional<Identity> identity) throws SessionException
queries
- A store query array.identity
- The optional requesting identity.SessionException
- On session exception.void start()
void stop()
@Nonnull @CheckReturnValue String supportedValueTypeCodes() throws SessionException
SessionException
- On session exception.@CheckReturnValue boolean supportsCount()
@CheckReturnValue boolean supportsDelete()
@CheckReturnValue boolean supportsDeliver()
@CheckReturnValue boolean supportsPull()
@CheckReturnValue boolean supportsPurge()
@CheckReturnValue boolean supportsSubscribe()
void suspendUpdates()
void unbind(@Nonnull PointBinding[] bindings)
bindings
- The point bindings.@Nullable @CheckReturnValue Exception[] update(@Nonnull PointValue[] pointValues, @Nonnull Optional<Identity> identity) throws ServiceNotAvailableException
pointValues
- The point values.identity
- The optional requesting identity.ServiceNotAvailableException
- On service not available.Copyright © 2003-2019 Serge Brisson. All Rights Reserved.