Interface PersistentSubscriptionsGrpc.AsyncService
-
- All Known Implementing Classes:
PersistentSubscriptionsGrpc.PersistentSubscriptionsImplBase
- Enclosing class:
- PersistentSubscriptionsGrpc
public static interface PersistentSubscriptionsGrpc.AsyncService
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default void
create(Persistent.CreateReq request, io.grpc.stub.StreamObserver<Persistent.CreateResp> responseObserver)
default void
delete(Persistent.DeleteReq request, io.grpc.stub.StreamObserver<Persistent.DeleteResp> responseObserver)
default void
getInfo(Persistent.GetInfoReq request, io.grpc.stub.StreamObserver<Persistent.GetInfoResp> responseObserver)
default void
list(Persistent.ListReq request, io.grpc.stub.StreamObserver<Persistent.ListResp> responseObserver)
default io.grpc.stub.StreamObserver<Persistent.ReadReq>
read(io.grpc.stub.StreamObserver<Persistent.ReadResp> responseObserver)
default void
replayParked(Persistent.ReplayParkedReq request, io.grpc.stub.StreamObserver<Persistent.ReplayParkedResp> responseObserver)
default void
restartSubsystem(Shared.Empty request, io.grpc.stub.StreamObserver<Shared.Empty> responseObserver)
default void
update(Persistent.UpdateReq request, io.grpc.stub.StreamObserver<Persistent.UpdateResp> responseObserver)
-
-
-
Method Detail
-
create
default void create(Persistent.CreateReq request, io.grpc.stub.StreamObserver<Persistent.CreateResp> responseObserver)
-
update
default void update(Persistent.UpdateReq request, io.grpc.stub.StreamObserver<Persistent.UpdateResp> responseObserver)
-
delete
default void delete(Persistent.DeleteReq request, io.grpc.stub.StreamObserver<Persistent.DeleteResp> responseObserver)
-
read
default io.grpc.stub.StreamObserver<Persistent.ReadReq> read(io.grpc.stub.StreamObserver<Persistent.ReadResp> responseObserver)
-
getInfo
default void getInfo(Persistent.GetInfoReq request, io.grpc.stub.StreamObserver<Persistent.GetInfoResp> responseObserver)
-
replayParked
default void replayParked(Persistent.ReplayParkedReq request, io.grpc.stub.StreamObserver<Persistent.ReplayParkedResp> responseObserver)
-
list
default void list(Persistent.ListReq request, io.grpc.stub.StreamObserver<Persistent.ListResp> responseObserver)
-
restartSubsystem
default void restartSubsystem(Shared.Empty request, io.grpc.stub.StreamObserver<Shared.Empty> responseObserver)
-
-