Package com.eventstore.dbclient.proto.persistentsubscriptions

Interface PersistentSubscriptionsGrpc.AsyncService

All Known Implementing Classes:

PersistentSubscriptionsGrpc.PersistentSubscriptionsImplBase

Enclosing class:

PersistentSubscriptionsGrpc

public static interface PersistentSubscriptionsGrpc.AsyncService

Method Summary

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 Details

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)