Class VertxKVGrpc.KVVertxImplBase

  • All Implemented Interfaces:
    io.grpc.BindableService
    Enclosing class:
    VertxKVGrpc

    public abstract static class VertxKVGrpc.KVVertxImplBase
    extends java.lang.Object
    implements io.grpc.BindableService
    • Constructor Detail

      • KVVertxImplBase

        public KVVertxImplBase()
    • Method Detail

      • withCompression

        public VertxKVGrpc.KVVertxImplBase withCompression​(java.lang.String compression)
        Set whether the server will try to use a compressed response.
        Parameters:
        compression - the compression, e.g gzip
      • range

        public io.vertx.core.Future<RangeResponse> range​(RangeRequest request)
          Range gets the keys in the range from the key-value store.
         
      • put

        public io.vertx.core.Future<PutResponse> put​(PutRequest request)
          Put puts the given key into the key-value store.
          A put request increments the revision of the key-value store
          and generates one event in the event history.
         
      • deleteRange

        public io.vertx.core.Future<DeleteRangeResponse> deleteRange​(DeleteRangeRequest request)
          DeleteRange deletes the given range from the key-value store.
          A delete request increments the revision of the key-value store
          and generates a delete event in the event history for every deleted key.
         
      • txn

        public io.vertx.core.Future<TxnResponse> txn​(TxnRequest request)
          Txn processes multiple requests in a single transaction.
          A txn request increments the revision of the key-value store
          and generates events with the same revision for every completed request.
          It is not allowed to modify the same key several times within one txn.
         
      • compact

        public io.vertx.core.Future<CompactionResponse> compact​(CompactionRequest request)
          Compact compacts the event history in the etcd key-value store. The key-value
          store should be periodically compacted or the event history will continue to grow
          indefinitely.
         
      • bindService

        public final io.grpc.ServerServiceDefinition bindService()
        Specified by:
        bindService in interface io.grpc.BindableService