Represents a Subscriber
Inheritance
$protobuf.rpc.Service > protos.google.pubsub.v1.SubscriberPackage
@google-cloud/pubsubConstructors
(constructor)(rpcImpl, requestDelimited, responseDelimited)
constructor(rpcImpl: $protobuf.RPCImpl, requestDelimited?: boolean, responseDelimited?: boolean);
Constructs a new Subscriber service.
Name | Description |
rpcImpl |
$protobuf.RPCImpl
RPC implementation |
requestDelimited |
boolean
Whether requests are length-delimited |
responseDelimited |
boolean
Whether responses are length-delimited |
Methods
acknowledge(request, callback)
public acknowledge(request: google.pubsub.v1.IAcknowledgeRequest, callback: google.pubsub.v1.Subscriber.AcknowledgeCallback): void;
Calls Acknowledge.
Name | Description |
request |
IAcknowledgeRequest
AcknowledgeRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.AcknowledgeCallback
Node-style callback called with the error, if any, and Empty |
Type | Description |
void |
acknowledge(request)
public acknowledge(request: google.pubsub.v1.IAcknowledgeRequest): Promise<google.protobuf.Empty>;
Calls Acknowledge.
Name | Description |
request |
IAcknowledgeRequest
AcknowledgeRequest message or plain object |
Type | Description |
Promise<google.protobuf.Empty> | Promise |
create(rpcImpl, requestDelimited, responseDelimited)
public static create(rpcImpl: $protobuf.RPCImpl, requestDelimited?: boolean, responseDelimited?: boolean): Subscriber;
Creates new Subscriber service using the specified rpc implementation.
Name | Description |
rpcImpl |
$protobuf.RPCImpl
RPC implementation |
requestDelimited |
boolean
Whether requests are length-delimited |
responseDelimited |
boolean
Whether responses are length-delimited |
Type | Description |
Subscriber | RPC service. Useful where requests and/or responses are streamed. |
createSnapshot(request, callback)
public createSnapshot(request: google.pubsub.v1.ICreateSnapshotRequest, callback: google.pubsub.v1.Subscriber.CreateSnapshotCallback): void;
Calls CreateSnapshot.
Name | Description |
request |
ICreateSnapshotRequest
CreateSnapshotRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.CreateSnapshotCallback
Node-style callback called with the error, if any, and Snapshot |
Type | Description |
void |
createSnapshot(request)
public createSnapshot(request: google.pubsub.v1.ICreateSnapshotRequest): Promise<google.pubsub.v1.Snapshot>;
Calls CreateSnapshot.
Name | Description |
request |
ICreateSnapshotRequest
CreateSnapshotRequest message or plain object |
Type | Description |
Promise<google.pubsub.v1.Snapshot> | Promise |
createSubscription(request, callback)
public createSubscription(request: google.pubsub.v1.ISubscription, callback: google.pubsub.v1.Subscriber.CreateSubscriptionCallback): void;
Calls CreateSubscription.
Name | Description |
request |
ISubscription
Subscription message or plain object |
callback |
google.pubsub.v1.Subscriber.CreateSubscriptionCallback
Node-style callback called with the error, if any, and Subscription |
Type | Description |
void |
createSubscription(request)
public createSubscription(request: google.pubsub.v1.ISubscription): Promise<google.pubsub.v1.Subscription>;
Calls CreateSubscription.
Name | Description |
request |
ISubscription
Subscription message or plain object |
Type | Description |
Promise<google.pubsub.v1.Subscription> | Promise |
deleteSnapshot(request, callback)
public deleteSnapshot(request: google.pubsub.v1.IDeleteSnapshotRequest, callback: google.pubsub.v1.Subscriber.DeleteSnapshotCallback): void;
Calls DeleteSnapshot.
Name | Description |
request |
IDeleteSnapshotRequest
DeleteSnapshotRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.DeleteSnapshotCallback
Node-style callback called with the error, if any, and Empty |
Type | Description |
void |
deleteSnapshot(request)
public deleteSnapshot(request: google.pubsub.v1.IDeleteSnapshotRequest): Promise<google.protobuf.Empty>;
Calls DeleteSnapshot.
Name | Description |
request |
IDeleteSnapshotRequest
DeleteSnapshotRequest message or plain object |
Type | Description |
Promise<google.protobuf.Empty> | Promise |
deleteSubscription(request, callback)
public deleteSubscription(request: google.pubsub.v1.IDeleteSubscriptionRequest, callback: google.pubsub.v1.Subscriber.DeleteSubscriptionCallback): void;
Calls DeleteSubscription.
Name | Description |
request |
IDeleteSubscriptionRequest
DeleteSubscriptionRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.DeleteSubscriptionCallback
Node-style callback called with the error, if any, and Empty |
Type | Description |
void |
deleteSubscription(request)
public deleteSubscription(request: google.pubsub.v1.IDeleteSubscriptionRequest): Promise<google.protobuf.Empty>;
Calls DeleteSubscription.
Name | Description |
request |
IDeleteSubscriptionRequest
DeleteSubscriptionRequest message or plain object |
Type | Description |
Promise<google.protobuf.Empty> | Promise |
getSnapshot(request, callback)
public getSnapshot(request: google.pubsub.v1.IGetSnapshotRequest, callback: google.pubsub.v1.Subscriber.GetSnapshotCallback): void;
Calls GetSnapshot.
Name | Description |
request |
google.pubsub.v1.IGetSnapshotRequest
GetSnapshotRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.GetSnapshotCallback
Node-style callback called with the error, if any, and Snapshot |
Type | Description |
void |
getSnapshot(request)
public getSnapshot(request: google.pubsub.v1.IGetSnapshotRequest): Promise<google.pubsub.v1.Snapshot>;
Calls GetSnapshot.
Name | Description |
request |
google.pubsub.v1.IGetSnapshotRequest
GetSnapshotRequest message or plain object |
Type | Description |
Promise<google.pubsub.v1.Snapshot> | Promise |
getSubscription(request, callback)
public getSubscription(request: google.pubsub.v1.IGetSubscriptionRequest, callback: google.pubsub.v1.Subscriber.GetSubscriptionCallback): void;
Calls GetSubscription.
Name | Description |
request |
IGetSubscriptionRequest
GetSubscriptionRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.GetSubscriptionCallback
Node-style callback called with the error, if any, and Subscription |
Type | Description |
void |
getSubscription(request)
public getSubscription(request: google.pubsub.v1.IGetSubscriptionRequest): Promise<google.pubsub.v1.Subscription>;
Calls GetSubscription.
Name | Description |
request |
IGetSubscriptionRequest
GetSubscriptionRequest message or plain object |
Type | Description |
Promise<google.pubsub.v1.Subscription> | Promise |
listSnapshots(request, callback)
public listSnapshots(request: google.pubsub.v1.IListSnapshotsRequest, callback: google.pubsub.v1.Subscriber.ListSnapshotsCallback): void;
Calls ListSnapshots.
Name | Description |
request |
IListSnapshotsRequest
ListSnapshotsRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.ListSnapshotsCallback
Node-style callback called with the error, if any, and ListSnapshotsResponse |
Type | Description |
void |
listSnapshots(request)
public listSnapshots(request: google.pubsub.v1.IListSnapshotsRequest): Promise<google.pubsub.v1.ListSnapshotsResponse>;
Calls ListSnapshots.
Name | Description |
request |
IListSnapshotsRequest
ListSnapshotsRequest message or plain object |
Type | Description |
Promise<google.pubsub.v1.ListSnapshotsResponse> | Promise |
listSubscriptions(request, callback)
public listSubscriptions(request: google.pubsub.v1.IListSubscriptionsRequest, callback: google.pubsub.v1.Subscriber.ListSubscriptionsCallback): void;
Calls ListSubscriptions.
Name | Description |
request |
IListSubscriptionsRequest
ListSubscriptionsRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.ListSubscriptionsCallback
Node-style callback called with the error, if any, and ListSubscriptionsResponse |
Type | Description |
void |
listSubscriptions(request)
public listSubscriptions(request: google.pubsub.v1.IListSubscriptionsRequest): Promise<google.pubsub.v1.ListSubscriptionsResponse>;
Calls ListSubscriptions.
Name | Description |
request |
IListSubscriptionsRequest
ListSubscriptionsRequest message or plain object |
Type | Description |
Promise<google.pubsub.v1.ListSubscriptionsResponse> | Promise |
modifyAckDeadline(request, callback)
public modifyAckDeadline(request: google.pubsub.v1.IModifyAckDeadlineRequest, callback: google.pubsub.v1.Subscriber.ModifyAckDeadlineCallback): void;
Calls ModifyAckDeadline.
Name | Description |
request |
IModifyAckDeadlineRequest
ModifyAckDeadlineRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.ModifyAckDeadlineCallback
Node-style callback called with the error, if any, and Empty |
Type | Description |
void |
modifyAckDeadline(request)
public modifyAckDeadline(request: google.pubsub.v1.IModifyAckDeadlineRequest): Promise<google.protobuf.Empty>;
Calls ModifyAckDeadline.
Name | Description |
request |
IModifyAckDeadlineRequest
ModifyAckDeadlineRequest message or plain object |
Type | Description |
Promise<google.protobuf.Empty> | Promise |
modifyPushConfig(request, callback)
public modifyPushConfig(request: google.pubsub.v1.IModifyPushConfigRequest, callback: google.pubsub.v1.Subscriber.ModifyPushConfigCallback): void;
Calls ModifyPushConfig.
Name | Description |
request |
IModifyPushConfigRequest
ModifyPushConfigRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.ModifyPushConfigCallback
Node-style callback called with the error, if any, and Empty |
Type | Description |
void |
modifyPushConfig(request)
public modifyPushConfig(request: google.pubsub.v1.IModifyPushConfigRequest): Promise<google.protobuf.Empty>;
Calls ModifyPushConfig.
Name | Description |
request |
IModifyPushConfigRequest
ModifyPushConfigRequest message or plain object |
Type | Description |
Promise<google.protobuf.Empty> | Promise |
pull(request, callback)
public pull(request: google.pubsub.v1.IPullRequest, callback: google.pubsub.v1.Subscriber.PullCallback): void;
Calls Pull.
Name | Description |
request |
IPullRequest
PullRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.PullCallback
Node-style callback called with the error, if any, and PullResponse |
Type | Description |
void |
pull(request)
public pull(request: google.pubsub.v1.IPullRequest): Promise<google.pubsub.v1.PullResponse>;
Calls Pull.
Name | Description |
request |
IPullRequest
PullRequest message or plain object |
Type | Description |
Promise<google.pubsub.v1.PullResponse> | Promise |
seek(request, callback)
public seek(request: google.pubsub.v1.ISeekRequest, callback: google.pubsub.v1.Subscriber.SeekCallback): void;
Calls Seek.
Name | Description |
request |
ISeekRequest
SeekRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.SeekCallback
Node-style callback called with the error, if any, and SeekResponse |
Type | Description |
void |
seek(request)
public seek(request: google.pubsub.v1.ISeekRequest): Promise<google.pubsub.v1.SeekResponse>;
Calls Seek.
Name | Description |
request |
ISeekRequest
SeekRequest message or plain object |
Type | Description |
Promise<google.pubsub.v1.SeekResponse> | Promise |
streamingPull(request, callback)
public streamingPull(request: google.pubsub.v1.IStreamingPullRequest, callback: google.pubsub.v1.Subscriber.StreamingPullCallback): void;
Calls StreamingPull.
Name | Description |
request |
IStreamingPullRequest
StreamingPullRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.StreamingPullCallback
Node-style callback called with the error, if any, and StreamingPullResponse |
Type | Description |
void |
streamingPull(request)
public streamingPull(request: google.pubsub.v1.IStreamingPullRequest): Promise<google.pubsub.v1.StreamingPullResponse>;
Calls StreamingPull.
Name | Description |
request |
IStreamingPullRequest
StreamingPullRequest message or plain object |
Type | Description |
Promise<google.pubsub.v1.StreamingPullResponse> | Promise |
updateSnapshot(request, callback)
public updateSnapshot(request: google.pubsub.v1.IUpdateSnapshotRequest, callback: google.pubsub.v1.Subscriber.UpdateSnapshotCallback): void;
Calls UpdateSnapshot.
Name | Description |
request |
IUpdateSnapshotRequest
UpdateSnapshotRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.UpdateSnapshotCallback
Node-style callback called with the error, if any, and Snapshot |
Type | Description |
void |
updateSnapshot(request)
public updateSnapshot(request: google.pubsub.v1.IUpdateSnapshotRequest): Promise<google.pubsub.v1.Snapshot>;
Calls UpdateSnapshot.
Name | Description |
request |
IUpdateSnapshotRequest
UpdateSnapshotRequest message or plain object |
Type | Description |
Promise<google.pubsub.v1.Snapshot> | Promise |
updateSubscription(request, callback)
public updateSubscription(request: google.pubsub.v1.IUpdateSubscriptionRequest, callback: google.pubsub.v1.Subscriber.UpdateSubscriptionCallback): void;
Calls UpdateSubscription.
Name | Description |
request |
IUpdateSubscriptionRequest
UpdateSubscriptionRequest message or plain object |
callback |
google.pubsub.v1.Subscriber.UpdateSubscriptionCallback
Node-style callback called with the error, if any, and Subscription |
Type | Description |
void |
updateSubscription(request)
public updateSubscription(request: google.pubsub.v1.IUpdateSubscriptionRequest): Promise<google.pubsub.v1.Subscription>;
Calls UpdateSubscription.
Name | Description |
request |
IUpdateSubscriptionRequest
UpdateSubscriptionRequest message or plain object |
Type | Description |
Promise<google.pubsub.v1.Subscription> | Promise |