Class OctopusGrpc.OctopusFutureStub

java.lang.Object
io.grpc.stub.AbstractStub<OctopusGrpc.OctopusFutureStub>
io.grpc.stub.AbstractFutureStub<OctopusGrpc.OctopusFutureStub>
studio.o7.octopus.sdk.v1.OctopusGrpc.OctopusFutureStub
Enclosing class:
OctopusGrpc
public static final class OctopusGrpc.OctopusFutureStub extends io.grpc.stub.AbstractFutureStub<OctopusGrpc.OctopusFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service Octopus.

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

    io.grpc.stub.AbstractStub.StubFactory<T>

  • Method Summary

    Modifier and Type
    Method
    Description
    protected OctopusGrpc.OctopusFutureStub
    build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
     
    com.google.common.util.concurrent.ListenableFuture<Entry>
    call(Object request)
    Stores an object on key in the database and returns the stored version, including the revision and ID.
    com.google.common.util.concurrent.ListenableFuture<GetResponse>
    get(GetRequest request)
    Retrieves only one existing entry from the database matching a key.
    com.google.common.util.concurrent.ListenableFuture<QueryResponse>
    query(QueryRequest request)
    Retrieves existing entries from the database matching a key pattern.
    com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
    write(Object request)
    Stores an object on key.

    Methods inherited from class io.grpc.stub.AbstractFutureStub

    newStub, newStub

    Methods inherited from class io.grpc.stub.AbstractStub

    getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

    Methods inherited from class Object

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

  • Method Details

    • build

      protected OctopusGrpc.OctopusFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<OctopusGrpc.OctopusFutureStub>

    • query

      public com.google.common.util.concurrent.ListenableFuture<QueryResponse> query(QueryRequest request)
      
Retrieves existing entries from the database matching a
key pattern. Can optionally include expired (include all
revisions) objects and filter by creation time.

    • get

      public com.google.common.util.concurrent.ListenableFuture<GetResponse> get(GetRequest request)
      
Retrieves only one existing entry from the database matching a key.

    • write

      public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> write(Object request)
      
Stores an object on key.

    • call

      public com.google.common.util.concurrent.ListenableFuture<Entry> call(Object request)
      
Stores an object on key in the database and returns the
stored version, including the revision and ID.