Package io.etcd.jetcd.api

Class VertxWatchGrpc.WatchVertxImplBase

java.lang.Object

io.etcd.jetcd.api.VertxWatchGrpc.WatchVertxImplBase

All Implemented Interfaces:

io.grpc.BindableService

Enclosing class:

VertxWatchGrpc

public abstract static class VertxWatchGrpc.WatchVertxImplBase
extends java.lang.Object
implements io.grpc.BindableService

Constructor Summary

Constructors

Constructor	Description
WatchVertxImplBase()

Method Summary

Modifier and Type	Method	Description
io.grpc.ServerServiceDefinition	bindService()
io.vertx.core.Future<WatchResponse>	progress(WatchProgressRequest request)	Range gets the keys in the range from the key-value store.
void	watch(io.vertx.core.streams.ReadStream<WatchRequest> request, io.vertx.core.streams.WriteStream<WatchResponse> response)	Put puts the given key into the key-value store.
VertxWatchGrpc.WatchVertxImplBase	withCompression(java.lang.String compression)	Set whether the server will try to use a compressed response.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WatchVertxImplBase

public WatchVertxImplBase()

Method Detail

withCompression

public VertxWatchGrpc.WatchVertxImplBase withCompression(java.lang.String compression)

Set whether the server will try to use a compressed response.

Parameters:

compression - the compression, e.g gzip

progress

public io.vertx.core.Future<WatchResponse> progress(WatchProgressRequest request)

  Range gets the keys in the range from the key-value store.
 

watch

public void watch(io.vertx.core.streams.ReadStream<WatchRequest> request,
                  io.vertx.core.streams.WriteStream<WatchResponse> response)

  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.
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService