com.google.pubsub.v1

Interface SubscriberGrpc.Subscriber

All Known Implementing Classes:

SubscriberGrpc.SubscriberStub

Enclosing class:

SubscriberGrpc

public static interface SubscriberGrpc.Subscriber

Method Summary

Modifier and Type	Method and Description
void	acknowledge(AcknowledgeRequest request, io.grpc.stub.StreamObserver<Empty> responseObserver)
void	createSubscription(Subscription request, io.grpc.stub.StreamObserver<Subscription> responseObserver)
void	deleteSubscription(DeleteSubscriptionRequest request, io.grpc.stub.StreamObserver<Empty> responseObserver)
void	getSubscription(GetSubscriptionRequest request, io.grpc.stub.StreamObserver<Subscription> responseObserver)
void	listSubscriptions(ListSubscriptionsRequest request, io.grpc.stub.StreamObserver<ListSubscriptionsResponse> responseObserver)
void	modifyAckDeadline(ModifyAckDeadlineRequest request, io.grpc.stub.StreamObserver<Empty> responseObserver)
void	modifyPushConfig(ModifyPushConfigRequest request, io.grpc.stub.StreamObserver<Empty> responseObserver)
void	pull(PullRequest request, io.grpc.stub.StreamObserver<PullResponse> responseObserver)

Method Detail

createSubscription

void createSubscription(Subscription request,
                        io.grpc.stub.StreamObserver<Subscription> responseObserver)

getSubscription

void getSubscription(GetSubscriptionRequest request,
                     io.grpc.stub.StreamObserver<Subscription> responseObserver)

listSubscriptions

void listSubscriptions(ListSubscriptionsRequest request,
                       io.grpc.stub.StreamObserver<ListSubscriptionsResponse> responseObserver)

deleteSubscription

void deleteSubscription(DeleteSubscriptionRequest request,
                        io.grpc.stub.StreamObserver<Empty> responseObserver)

modifyAckDeadline

void modifyAckDeadline(ModifyAckDeadlineRequest request,
                       io.grpc.stub.StreamObserver<Empty> responseObserver)

acknowledge

void acknowledge(AcknowledgeRequest request,
                 io.grpc.stub.StreamObserver<Empty> responseObserver)

pull

void pull(PullRequest request,
          io.grpc.stub.StreamObserver<PullResponse> responseObserver)

modifyPushConfig

void modifyPushConfig(ModifyPushConfigRequest request,
                      io.grpc.stub.StreamObserver<Empty> responseObserver)