Class DataService


  • public class DataService
    extends java.lang.Object
    • Field Detail

      • activeTxn

        public java.util.concurrent.atomic.AtomicLong activeTxn
        Counter of active transactions
      • totalTxn

        public java.util.concurrent.atomic.AtomicLong totalTxn
        Cumulative counter of transactions
    • Method Detail

      • getEndpointSet

        public EndpointSet getEndpointSet​(java.lang.String endpointName)
        Return the EndpointSet for the operations for named use.
      • getEndpointSet

        public EndpointSet getEndpointSet()
        Return the EndpointSet for the operations for unnamed use.
      • getEndpoints

        public java.util.Collection<Endpoint> getEndpoints()
        Return a collection of all endpoints for this DataService.
      • forEachEndpoint

        public void forEachEndpoint​(java.util.function.Consumer<Endpoint> action)
        Execute an action for each Endpoint.
      • getEndpoints

        public java.util.List<Endpoint> getEndpoints​(Operation operation)
      • allowUpdate

        public boolean allowUpdate()
      • goOffline

        public void goOffline()
      • setEndpointProcessors

        public void setEndpointProcessors​(OperationRegistry operationRegistry)
        Set any ActionService processors is currently unset.
      • goActive

        public void goActive()
      • isAcceptingRequests

        public boolean isAcceptingRequests()
      • getRequests

        public long getRequests()
      • getRequestsGood

        public long getRequestsGood()
      • getRequestsBad

        public long getRequestsBad()
      • startTxn

        public void startTxn​(TxnType mode)
      • finishTxn

        public void finishTxn()
      • shutdown

        public void shutdown()
        Shutdown and never use again.
      • authPolicy

        public AuthPolicy authPolicy()
        Returning null implies no authorization control