public abstract class SubscriberServiceApiClientSubscriberServiceApi client wrapper, for convenient use.
Inheritance
System.Object > SubscriberServiceApiClientNamespace
Google.Cloud.PubSub.V1Assembly
Google.Cloud.PubSub.V1.dll
Remarks
The service that an application uses to manipulate subscriptions and to
consume messages from a subscription via the Pull method or by
establishing a bi-directional stream using the StreamingPull method.
Properties
DefaultEndpoint
public static string DefaultEndpoint { get; }The default endpoint for the SubscriberServiceApi service, which is a host of "pubsub.googleapis.com" and a port of 443.
| Property Value | |
|---|---|
| Type | Description |
System.String |
|
DefaultScopes
public static IReadOnlyList<string> DefaultScopes { get; }The default SubscriberServiceApi scopes.
| Property Value | |
|---|---|
| Type | Description |
System.Collections.Generic.IReadOnlyList<System.String> |
|
The default SubscriberServiceApi scopes are:
GrpcClient
public virtual Subscriber.SubscriberClient GrpcClient { get; }The underlying gRPC SubscriberServiceApi client
| Property Value | |
|---|---|
| Type | Description |
Subscriber.SubscriberClient |
|
Methods
Acknowledge(AcknowledgeRequest, CallSettings)
public virtual void Acknowledge(AcknowledgeRequest request, CallSettings callSettings = null)Acknowledges the messages associated with the ack_ids in the
AcknowledgeRequest. The Pub/Sub system can remove the relevant messages
from the subscription.
Acknowledging a message whose ack deadline has expired may succeed, but such a message may be redelivered later. Acknowledging a message more than once will not result in an error.
| Parameters | |
|---|---|
| Name | Description |
request |
AcknowledgeRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
Acknowledge(SubscriptionName, IEnumerable<String>, CallSettings)
public virtual void Acknowledge(SubscriptionName subscription, IEnumerable<string> ackIds, CallSettings callSettings = null)Acknowledges the messages associated with the ack_ids in the
AcknowledgeRequest. The Pub/Sub system can remove the relevant messages
from the subscription.
Acknowledging a message whose ack deadline has expired may succeed, but such a message may be redelivered later. Acknowledging a message more than once will not result in an error.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The subscription whose message is being acknowledged.
Format is |
ackIds |
System.Collections.Generic.IEnumerable<System.String>Required. The acknowledgment ID for the messages being acknowledged that
was returned by the Pub/Sub system in the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
Acknowledge(String, IEnumerable<String>, CallSettings)
public virtual void Acknowledge(string subscription, IEnumerable<string> ackIds, CallSettings callSettings = null)Acknowledges the messages associated with the ack_ids in the
AcknowledgeRequest. The Pub/Sub system can remove the relevant messages
from the subscription.
Acknowledging a message whose ack deadline has expired may succeed, but such a message may be redelivered later. Acknowledging a message more than once will not result in an error.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The subscription whose message is being acknowledged.
Format is |
ackIds |
System.Collections.Generic.IEnumerable<System.String>Required. The acknowledgment ID for the messages being acknowledged that
was returned by the Pub/Sub system in the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
AcknowledgeAsync(AcknowledgeRequest, CallSettings)
public virtual Task AcknowledgeAsync(AcknowledgeRequest request, CallSettings callSettings = null)Acknowledges the messages associated with the ack_ids in the
AcknowledgeRequest. The Pub/Sub system can remove the relevant messages
from the subscription.
Acknowledging a message whose ack deadline has expired may succeed, but such a message may be redelivered later. Acknowledging a message more than once will not result in an error.
| Parameters | |
|---|---|
| Name | Description |
request |
AcknowledgeRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
AcknowledgeAsync(AcknowledgeRequest, CancellationToken)
public virtual Task AcknowledgeAsync(AcknowledgeRequest request, CancellationToken cancellationToken)Acknowledges the messages associated with the ack_ids in the
AcknowledgeRequest. The Pub/Sub system can remove the relevant messages
from the subscription.
Acknowledging a message whose ack deadline has expired may succeed, but such a message may be redelivered later. Acknowledging a message more than once will not result in an error.
| Parameters | |
|---|---|
| Name | Description |
request |
AcknowledgeRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
AcknowledgeAsync(SubscriptionName, IEnumerable<String>, CallSettings)
public virtual Task AcknowledgeAsync(SubscriptionName subscription, IEnumerable<string> ackIds, CallSettings callSettings = null)Acknowledges the messages associated with the ack_ids in the
AcknowledgeRequest. The Pub/Sub system can remove the relevant messages
from the subscription.
Acknowledging a message whose ack deadline has expired may succeed, but such a message may be redelivered later. Acknowledging a message more than once will not result in an error.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The subscription whose message is being acknowledged.
Format is |
ackIds |
System.Collections.Generic.IEnumerable<System.String>Required. The acknowledgment ID for the messages being acknowledged that
was returned by the Pub/Sub system in the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
AcknowledgeAsync(SubscriptionName, IEnumerable<String>, CancellationToken)
public virtual Task AcknowledgeAsync(SubscriptionName subscription, IEnumerable<string> ackIds, CancellationToken cancellationToken)Acknowledges the messages associated with the ack_ids in the
AcknowledgeRequest. The Pub/Sub system can remove the relevant messages
from the subscription.
Acknowledging a message whose ack deadline has expired may succeed, but such a message may be redelivered later. Acknowledging a message more than once will not result in an error.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The subscription whose message is being acknowledged.
Format is |
ackIds |
System.Collections.Generic.IEnumerable<System.String>Required. The acknowledgment ID for the messages being acknowledged that
was returned by the Pub/Sub system in the |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
AcknowledgeAsync(String, IEnumerable<String>, CallSettings)
public virtual Task AcknowledgeAsync(string subscription, IEnumerable<string> ackIds, CallSettings callSettings = null)Acknowledges the messages associated with the ack_ids in the
AcknowledgeRequest. The Pub/Sub system can remove the relevant messages
from the subscription.
Acknowledging a message whose ack deadline has expired may succeed, but such a message may be redelivered later. Acknowledging a message more than once will not result in an error.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The subscription whose message is being acknowledged.
Format is |
ackIds |
System.Collections.Generic.IEnumerable<System.String>Required. The acknowledgment ID for the messages being acknowledged that
was returned by the Pub/Sub system in the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
AcknowledgeAsync(String, IEnumerable<String>, CancellationToken)
public virtual Task AcknowledgeAsync(string subscription, IEnumerable<string> ackIds, CancellationToken cancellationToken)Acknowledges the messages associated with the ack_ids in the
AcknowledgeRequest. The Pub/Sub system can remove the relevant messages
from the subscription.
Acknowledging a message whose ack deadline has expired may succeed, but such a message may be redelivered later. Acknowledging a message more than once will not result in an error.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The subscription whose message is being acknowledged.
Format is |
ackIds |
System.Collections.Generic.IEnumerable<System.String>Required. The acknowledgment ID for the messages being acknowledged that
was returned by the Pub/Sub system in the |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
Create()
public static SubscriberServiceApiClient Create()Synchronously creates a SubscriberServiceApiClient using the default credentials, endpoint and settings. To specify custom credentials or other settings, use SubscriberServiceApiClientBuilder.
| Returns | |
|---|---|
| Type | Description |
SubscriberServiceApiClient |
The created SubscriberServiceApiClient. |
CreateAsync(CancellationToken)
public static Task<SubscriberServiceApiClient> CreateAsync(CancellationToken cancellationToken = default(CancellationToken))Asynchronously creates a SubscriberServiceApiClient using the default credentials, endpoint and settings. To specify custom credentials or other settings, use SubscriberServiceApiClientBuilder.
| Parameter | |
|---|---|
| Name | Description |
cancellationToken |
System.Threading.CancellationTokenThe System.Threading.CancellationToken to use while creating the client. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<SubscriberServiceApiClient> |
The task representing the created SubscriberServiceApiClient. |
CreateSnapshot(CreateSnapshotRequest, CallSettings)
public virtual Snapshot CreateSnapshot(CreateSnapshotRequest request, CallSettings callSettings = null)Creates a snapshot from the requested subscription. Snapshots are used in
Seek operations,
which allow you to manage message acknowledgments in bulk. That is, you can
set the acknowledgment state of messages in an existing subscription to the
state captured by a snapshot.
If the snapshot already exists, returns ALREADY_EXISTS.
If the requested subscription doesn't exist, returns NOT_FOUND.
If the backlog in the subscription is too old -- and the resulting snapshot
would expire in less than 1 hour -- then FAILED_PRECONDITION is returned.
See also the Snapshot.expire_time field. If the name is not provided in
the request, the server will assign a random
name for this snapshot on the same project as the subscription, conforming
to the resource name format. The
generated name is populated in the returned Snapshot object. Note that for
REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
request |
CreateSnapshotRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Snapshot |
The RPC response. |
CreateSnapshot(SnapshotName, SubscriptionName, CallSettings)
public virtual Snapshot CreateSnapshot(SnapshotName name, SubscriptionName subscription, CallSettings callSettings = null)Creates a snapshot from the requested subscription. Snapshots are used in
Seek operations,
which allow you to manage message acknowledgments in bulk. That is, you can
set the acknowledgment state of messages in an existing subscription to the
state captured by a snapshot.
If the snapshot already exists, returns ALREADY_EXISTS.
If the requested subscription doesn't exist, returns NOT_FOUND.
If the backlog in the subscription is too old -- and the resulting snapshot
would expire in less than 1 hour -- then FAILED_PRECONDITION is returned.
See also the Snapshot.expire_time field. If the name is not provided in
the request, the server will assign a random
name for this snapshot on the same project as the subscription, conforming
to the resource name format. The
generated name is populated in the returned Snapshot object. Note that for
REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
name |
SnapshotNameRequired. User-provided name for this snapshot. If the name is not provided
in the request, the server will assign a random name for this snapshot on
the same project as the subscription. Note that for REST API requests, you
must specify a name. See the <a
href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource
name rules</a>. Format is |
subscription |
SubscriptionNameRequired. The subscription whose backlog the snapshot retains.
Specifically, the created snapshot is guaranteed to retain:
(a) The existing backlog on the subscription. More precisely, this is
defined as the messages in the subscription's backlog that are
unacknowledged upon the successful completion of the
|
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Snapshot |
The RPC response. |
CreateSnapshot(String, String, CallSettings)
public virtual Snapshot CreateSnapshot(string name, string subscription, CallSettings callSettings = null)Creates a snapshot from the requested subscription. Snapshots are used in
Seek operations,
which allow you to manage message acknowledgments in bulk. That is, you can
set the acknowledgment state of messages in an existing subscription to the
state captured by a snapshot.
If the snapshot already exists, returns ALREADY_EXISTS.
If the requested subscription doesn't exist, returns NOT_FOUND.
If the backlog in the subscription is too old -- and the resulting snapshot
would expire in less than 1 hour -- then FAILED_PRECONDITION is returned.
See also the Snapshot.expire_time field. If the name is not provided in
the request, the server will assign a random
name for this snapshot on the same project as the subscription, conforming
to the resource name format. The
generated name is populated in the returned Snapshot object. Note that for
REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
name |
System.StringRequired. User-provided name for this snapshot. If the name is not provided
in the request, the server will assign a random name for this snapshot on
the same project as the subscription. Note that for REST API requests, you
must specify a name. See the <a
href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource
name rules</a>. Format is |
subscription |
System.StringRequired. The subscription whose backlog the snapshot retains.
Specifically, the created snapshot is guaranteed to retain:
(a) The existing backlog on the subscription. More precisely, this is
defined as the messages in the subscription's backlog that are
unacknowledged upon the successful completion of the
|
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Snapshot |
The RPC response. |
CreateSnapshotAsync(CreateSnapshotRequest, CallSettings)
public virtual Task<Snapshot> CreateSnapshotAsync(CreateSnapshotRequest request, CallSettings callSettings = null)Creates a snapshot from the requested subscription. Snapshots are used in
Seek operations,
which allow you to manage message acknowledgments in bulk. That is, you can
set the acknowledgment state of messages in an existing subscription to the
state captured by a snapshot.
If the snapshot already exists, returns ALREADY_EXISTS.
If the requested subscription doesn't exist, returns NOT_FOUND.
If the backlog in the subscription is too old -- and the resulting snapshot
would expire in less than 1 hour -- then FAILED_PRECONDITION is returned.
See also the Snapshot.expire_time field. If the name is not provided in
the request, the server will assign a random
name for this snapshot on the same project as the subscription, conforming
to the resource name format. The
generated name is populated in the returned Snapshot object. Note that for
REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
request |
CreateSnapshotRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
CreateSnapshotAsync(CreateSnapshotRequest, CancellationToken)
public virtual Task<Snapshot> CreateSnapshotAsync(CreateSnapshotRequest request, CancellationToken cancellationToken)Creates a snapshot from the requested subscription. Snapshots are used in
Seek operations,
which allow you to manage message acknowledgments in bulk. That is, you can
set the acknowledgment state of messages in an existing subscription to the
state captured by a snapshot.
If the snapshot already exists, returns ALREADY_EXISTS.
If the requested subscription doesn't exist, returns NOT_FOUND.
If the backlog in the subscription is too old -- and the resulting snapshot
would expire in less than 1 hour -- then FAILED_PRECONDITION is returned.
See also the Snapshot.expire_time field. If the name is not provided in
the request, the server will assign a random
name for this snapshot on the same project as the subscription, conforming
to the resource name format. The
generated name is populated in the returned Snapshot object. Note that for
REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
request |
CreateSnapshotRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
CreateSnapshotAsync(SnapshotName, SubscriptionName, CallSettings)
public virtual Task<Snapshot> CreateSnapshotAsync(SnapshotName name, SubscriptionName subscription, CallSettings callSettings = null)Creates a snapshot from the requested subscription. Snapshots are used in
Seek operations,
which allow you to manage message acknowledgments in bulk. That is, you can
set the acknowledgment state of messages in an existing subscription to the
state captured by a snapshot.
If the snapshot already exists, returns ALREADY_EXISTS.
If the requested subscription doesn't exist, returns NOT_FOUND.
If the backlog in the subscription is too old -- and the resulting snapshot
would expire in less than 1 hour -- then FAILED_PRECONDITION is returned.
See also the Snapshot.expire_time field. If the name is not provided in
the request, the server will assign a random
name for this snapshot on the same project as the subscription, conforming
to the resource name format. The
generated name is populated in the returned Snapshot object. Note that for
REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
name |
SnapshotNameRequired. User-provided name for this snapshot. If the name is not provided
in the request, the server will assign a random name for this snapshot on
the same project as the subscription. Note that for REST API requests, you
must specify a name. See the <a
href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource
name rules</a>. Format is |
subscription |
SubscriptionNameRequired. The subscription whose backlog the snapshot retains.
Specifically, the created snapshot is guaranteed to retain:
(a) The existing backlog on the subscription. More precisely, this is
defined as the messages in the subscription's backlog that are
unacknowledged upon the successful completion of the
|
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
CreateSnapshotAsync(SnapshotName, SubscriptionName, CancellationToken)
public virtual Task<Snapshot> CreateSnapshotAsync(SnapshotName name, SubscriptionName subscription, CancellationToken cancellationToken)Creates a snapshot from the requested subscription. Snapshots are used in
Seek operations,
which allow you to manage message acknowledgments in bulk. That is, you can
set the acknowledgment state of messages in an existing subscription to the
state captured by a snapshot.
If the snapshot already exists, returns ALREADY_EXISTS.
If the requested subscription doesn't exist, returns NOT_FOUND.
If the backlog in the subscription is too old -- and the resulting snapshot
would expire in less than 1 hour -- then FAILED_PRECONDITION is returned.
See also the Snapshot.expire_time field. If the name is not provided in
the request, the server will assign a random
name for this snapshot on the same project as the subscription, conforming
to the resource name format. The
generated name is populated in the returned Snapshot object. Note that for
REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
name |
SnapshotNameRequired. User-provided name for this snapshot. If the name is not provided
in the request, the server will assign a random name for this snapshot on
the same project as the subscription. Note that for REST API requests, you
must specify a name. See the <a
href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource
name rules</a>. Format is |
subscription |
SubscriptionNameRequired. The subscription whose backlog the snapshot retains.
Specifically, the created snapshot is guaranteed to retain:
(a) The existing backlog on the subscription. More precisely, this is
defined as the messages in the subscription's backlog that are
unacknowledged upon the successful completion of the
|
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
CreateSnapshotAsync(String, String, CallSettings)
public virtual Task<Snapshot> CreateSnapshotAsync(string name, string subscription, CallSettings callSettings = null)Creates a snapshot from the requested subscription. Snapshots are used in
Seek operations,
which allow you to manage message acknowledgments in bulk. That is, you can
set the acknowledgment state of messages in an existing subscription to the
state captured by a snapshot.
If the snapshot already exists, returns ALREADY_EXISTS.
If the requested subscription doesn't exist, returns NOT_FOUND.
If the backlog in the subscription is too old -- and the resulting snapshot
would expire in less than 1 hour -- then FAILED_PRECONDITION is returned.
See also the Snapshot.expire_time field. If the name is not provided in
the request, the server will assign a random
name for this snapshot on the same project as the subscription, conforming
to the resource name format. The
generated name is populated in the returned Snapshot object. Note that for
REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
name |
System.StringRequired. User-provided name for this snapshot. If the name is not provided
in the request, the server will assign a random name for this snapshot on
the same project as the subscription. Note that for REST API requests, you
must specify a name. See the <a
href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource
name rules</a>. Format is |
subscription |
System.StringRequired. The subscription whose backlog the snapshot retains.
Specifically, the created snapshot is guaranteed to retain:
(a) The existing backlog on the subscription. More precisely, this is
defined as the messages in the subscription's backlog that are
unacknowledged upon the successful completion of the
|
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
CreateSnapshotAsync(String, String, CancellationToken)
public virtual Task<Snapshot> CreateSnapshotAsync(string name, string subscription, CancellationToken cancellationToken)Creates a snapshot from the requested subscription. Snapshots are used in
Seek operations,
which allow you to manage message acknowledgments in bulk. That is, you can
set the acknowledgment state of messages in an existing subscription to the
state captured by a snapshot.
If the snapshot already exists, returns ALREADY_EXISTS.
If the requested subscription doesn't exist, returns NOT_FOUND.
If the backlog in the subscription is too old -- and the resulting snapshot
would expire in less than 1 hour -- then FAILED_PRECONDITION is returned.
See also the Snapshot.expire_time field. If the name is not provided in
the request, the server will assign a random
name for this snapshot on the same project as the subscription, conforming
to the resource name format. The
generated name is populated in the returned Snapshot object. Note that for
REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
name |
System.StringRequired. User-provided name for this snapshot. If the name is not provided
in the request, the server will assign a random name for this snapshot on
the same project as the subscription. Note that for REST API requests, you
must specify a name. See the <a
href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource
name rules</a>. Format is |
subscription |
System.StringRequired. The subscription whose backlog the snapshot retains.
Specifically, the created snapshot is guaranteed to retain:
(a) The existing backlog on the subscription. More precisely, this is
defined as the messages in the subscription's backlog that are
unacknowledged upon the successful completion of the
|
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
CreateSubscription(Subscription, CallSettings)
public virtual Subscription CreateSubscription(Subscription request, CallSettings callSettings = null)Creates a subscription to a given topic. See the resource name rules.
If the subscription already exists, returns ALREADY_EXISTS.
If the corresponding topic doesn't exist, returns NOT_FOUND.
If the name is not provided in the request, the server will assign a random name for this subscription on the same project as the topic, conforming to the resource name format. The generated name is populated in the returned Subscription object. Note that for REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
request |
SubscriptionThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Subscription |
The RPC response. |
CreateSubscription(SubscriptionName, TopicName, PushConfig, Int32, CallSettings)
public virtual Subscription CreateSubscription(SubscriptionName name, TopicName topic, PushConfig pushConfig, int ackDeadlineSeconds, CallSettings callSettings = null)Creates a subscription to a given topic. See the resource name rules.
If the subscription already exists, returns ALREADY_EXISTS.
If the corresponding topic doesn't exist, returns NOT_FOUND.
If the name is not provided in the request, the server will assign a random name for this subscription on the same project as the topic, conforming to the resource name format. The generated name is populated in the returned Subscription object. Note that for REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
name |
SubscriptionNameRequired. The name of the subscription. It must have the format
|
topic |
TopicNameRequired. The name of the topic from which this subscription is receiving
messages. Format is |
pushConfig |
PushConfigIf push delivery is used with this subscription, this field is
used to configure it. An empty |
ackDeadlineSeconds |
System.Int32The approximate amount of time (on a best-effort basis) Pub/Sub waits for the subscriber to acknowledge receipt before resending the message. In the interval after the message is delivered and before it is acknowledged, it is considered to be <i>outstanding</i>. During that time period, the message will not be redelivered (on a best-effort basis). For pull subscriptions, this value is used as the initial value for the ack
deadline. To override this value for a given message, call
For push delivery, this value is also used to set the request timeout for the call to the push endpoint. If the subscriber never acknowledges the message, the Pub/Sub system will eventually redeliver the message. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Subscription |
The RPC response. |
CreateSubscription(String, String, PushConfig, Int32, CallSettings)
public virtual Subscription CreateSubscription(string name, string topic, PushConfig pushConfig, int ackDeadlineSeconds, CallSettings callSettings = null)Creates a subscription to a given topic. See the resource name rules.
If the subscription already exists, returns ALREADY_EXISTS.
If the corresponding topic doesn't exist, returns NOT_FOUND.
If the name is not provided in the request, the server will assign a random name for this subscription on the same project as the topic, conforming to the resource name format. The generated name is populated in the returned Subscription object. Note that for REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
name |
System.StringRequired. The name of the subscription. It must have the format
|
topic |
System.StringRequired. The name of the topic from which this subscription is receiving
messages. Format is |
pushConfig |
PushConfigIf push delivery is used with this subscription, this field is
used to configure it. An empty |
ackDeadlineSeconds |
System.Int32The approximate amount of time (on a best-effort basis) Pub/Sub waits for the subscriber to acknowledge receipt before resending the message. In the interval after the message is delivered and before it is acknowledged, it is considered to be <i>outstanding</i>. During that time period, the message will not be redelivered (on a best-effort basis). For pull subscriptions, this value is used as the initial value for the ack
deadline. To override this value for a given message, call
For push delivery, this value is also used to set the request timeout for the call to the push endpoint. If the subscriber never acknowledges the message, the Pub/Sub system will eventually redeliver the message. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Subscription |
The RPC response. |
CreateSubscriptionAsync(Subscription, CallSettings)
public virtual Task<Subscription> CreateSubscriptionAsync(Subscription request, CallSettings callSettings = null)Creates a subscription to a given topic. See the resource name rules.
If the subscription already exists, returns ALREADY_EXISTS.
If the corresponding topic doesn't exist, returns NOT_FOUND.
If the name is not provided in the request, the server will assign a random name for this subscription on the same project as the topic, conforming to the resource name format. The generated name is populated in the returned Subscription object. Note that for REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
request |
SubscriptionThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |
CreateSubscriptionAsync(Subscription, CancellationToken)
public virtual Task<Subscription> CreateSubscriptionAsync(Subscription request, CancellationToken cancellationToken)Creates a subscription to a given topic. See the resource name rules.
If the subscription already exists, returns ALREADY_EXISTS.
If the corresponding topic doesn't exist, returns NOT_FOUND.
If the name is not provided in the request, the server will assign a random name for this subscription on the same project as the topic, conforming to the resource name format. The generated name is populated in the returned Subscription object. Note that for REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
request |
SubscriptionThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |
CreateSubscriptionAsync(SubscriptionName, TopicName, PushConfig, Int32, CallSettings)
public virtual Task<Subscription> CreateSubscriptionAsync(SubscriptionName name, TopicName topic, PushConfig pushConfig, int ackDeadlineSeconds, CallSettings callSettings = null)Creates a subscription to a given topic. See the resource name rules.
If the subscription already exists, returns ALREADY_EXISTS.
If the corresponding topic doesn't exist, returns NOT_FOUND.
If the name is not provided in the request, the server will assign a random name for this subscription on the same project as the topic, conforming to the resource name format. The generated name is populated in the returned Subscription object. Note that for REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
name |
SubscriptionNameRequired. The name of the subscription. It must have the format
|
topic |
TopicNameRequired. The name of the topic from which this subscription is receiving
messages. Format is |
pushConfig |
PushConfigIf push delivery is used with this subscription, this field is
used to configure it. An empty |
ackDeadlineSeconds |
System.Int32The approximate amount of time (on a best-effort basis) Pub/Sub waits for the subscriber to acknowledge receipt before resending the message. In the interval after the message is delivered and before it is acknowledged, it is considered to be <i>outstanding</i>. During that time period, the message will not be redelivered (on a best-effort basis). For pull subscriptions, this value is used as the initial value for the ack
deadline. To override this value for a given message, call
For push delivery, this value is also used to set the request timeout for the call to the push endpoint. If the subscriber never acknowledges the message, the Pub/Sub system will eventually redeliver the message. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |
CreateSubscriptionAsync(SubscriptionName, TopicName, PushConfig, Int32, CancellationToken)
public virtual Task<Subscription> CreateSubscriptionAsync(SubscriptionName name, TopicName topic, PushConfig pushConfig, int ackDeadlineSeconds, CancellationToken cancellationToken)Creates a subscription to a given topic. See the resource name rules.
If the subscription already exists, returns ALREADY_EXISTS.
If the corresponding topic doesn't exist, returns NOT_FOUND.
If the name is not provided in the request, the server will assign a random name for this subscription on the same project as the topic, conforming to the resource name format. The generated name is populated in the returned Subscription object. Note that for REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
name |
SubscriptionNameRequired. The name of the subscription. It must have the format
|
topic |
TopicNameRequired. The name of the topic from which this subscription is receiving
messages. Format is |
pushConfig |
PushConfigIf push delivery is used with this subscription, this field is
used to configure it. An empty |
ackDeadlineSeconds |
System.Int32The approximate amount of time (on a best-effort basis) Pub/Sub waits for the subscriber to acknowledge receipt before resending the message. In the interval after the message is delivered and before it is acknowledged, it is considered to be <i>outstanding</i>. During that time period, the message will not be redelivered (on a best-effort basis). For pull subscriptions, this value is used as the initial value for the ack
deadline. To override this value for a given message, call
For push delivery, this value is also used to set the request timeout for the call to the push endpoint. If the subscriber never acknowledges the message, the Pub/Sub system will eventually redeliver the message. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |
CreateSubscriptionAsync(String, String, PushConfig, Int32, CallSettings)
public virtual Task<Subscription> CreateSubscriptionAsync(string name, string topic, PushConfig pushConfig, int ackDeadlineSeconds, CallSettings callSettings = null)Creates a subscription to a given topic. See the resource name rules.
If the subscription already exists, returns ALREADY_EXISTS.
If the corresponding topic doesn't exist, returns NOT_FOUND.
If the name is not provided in the request, the server will assign a random name for this subscription on the same project as the topic, conforming to the resource name format. The generated name is populated in the returned Subscription object. Note that for REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
name |
System.StringRequired. The name of the subscription. It must have the format
|
topic |
System.StringRequired. The name of the topic from which this subscription is receiving
messages. Format is |
pushConfig |
PushConfigIf push delivery is used with this subscription, this field is
used to configure it. An empty |
ackDeadlineSeconds |
System.Int32The approximate amount of time (on a best-effort basis) Pub/Sub waits for the subscriber to acknowledge receipt before resending the message. In the interval after the message is delivered and before it is acknowledged, it is considered to be <i>outstanding</i>. During that time period, the message will not be redelivered (on a best-effort basis). For pull subscriptions, this value is used as the initial value for the ack
deadline. To override this value for a given message, call
For push delivery, this value is also used to set the request timeout for the call to the push endpoint. If the subscriber never acknowledges the message, the Pub/Sub system will eventually redeliver the message. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |
CreateSubscriptionAsync(String, String, PushConfig, Int32, CancellationToken)
public virtual Task<Subscription> CreateSubscriptionAsync(string name, string topic, PushConfig pushConfig, int ackDeadlineSeconds, CancellationToken cancellationToken)Creates a subscription to a given topic. See the resource name rules.
If the subscription already exists, returns ALREADY_EXISTS.
If the corresponding topic doesn't exist, returns NOT_FOUND.
If the name is not provided in the request, the server will assign a random name for this subscription on the same project as the topic, conforming to the resource name format. The generated name is populated in the returned Subscription object. Note that for REST API requests, you must specify a name in the request.
| Parameters | |
|---|---|
| Name | Description |
name |
System.StringRequired. The name of the subscription. It must have the format
|
topic |
System.StringRequired. The name of the topic from which this subscription is receiving
messages. Format is |
pushConfig |
PushConfigIf push delivery is used with this subscription, this field is
used to configure it. An empty |
ackDeadlineSeconds |
System.Int32The approximate amount of time (on a best-effort basis) Pub/Sub waits for the subscriber to acknowledge receipt before resending the message. In the interval after the message is delivered and before it is acknowledged, it is considered to be <i>outstanding</i>. During that time period, the message will not be redelivered (on a best-effort basis). For pull subscriptions, this value is used as the initial value for the ack
deadline. To override this value for a given message, call
For push delivery, this value is also used to set the request timeout for the call to the push endpoint. If the subscriber never acknowledges the message, the Pub/Sub system will eventually redeliver the message. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |
DeleteSnapshot(DeleteSnapshotRequest, CallSettings)
public virtual void DeleteSnapshot(DeleteSnapshotRequest request, CallSettings callSettings = null)Removes an existing snapshot. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. When the snapshot is deleted, all messages retained in the snapshot are immediately dropped. After a snapshot is deleted, a new one may be created with the same name, but the new one has no association with the old snapshot or its subscription, unless the same subscription is specified.
| Parameters | |
|---|---|
| Name | Description |
request |
DeleteSnapshotRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
DeleteSnapshot(SnapshotName, CallSettings)
public virtual void DeleteSnapshot(SnapshotName snapshot, CallSettings callSettings = null)Removes an existing snapshot. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. When the snapshot is deleted, all messages retained in the snapshot are immediately dropped. After a snapshot is deleted, a new one may be created with the same name, but the new one has no association with the old snapshot or its subscription, unless the same subscription is specified.
| Parameters | |
|---|---|
| Name | Description |
snapshot |
SnapshotNameRequired. The name of the snapshot to delete.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
DeleteSnapshot(String, CallSettings)
public virtual void DeleteSnapshot(string snapshot, CallSettings callSettings = null)Removes an existing snapshot. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. When the snapshot is deleted, all messages retained in the snapshot are immediately dropped. After a snapshot is deleted, a new one may be created with the same name, but the new one has no association with the old snapshot or its subscription, unless the same subscription is specified.
| Parameters | |
|---|---|
| Name | Description |
snapshot |
System.StringRequired. The name of the snapshot to delete.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
DeleteSnapshotAsync(DeleteSnapshotRequest, CallSettings)
public virtual Task DeleteSnapshotAsync(DeleteSnapshotRequest request, CallSettings callSettings = null)Removes an existing snapshot. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. When the snapshot is deleted, all messages retained in the snapshot are immediately dropped. After a snapshot is deleted, a new one may be created with the same name, but the new one has no association with the old snapshot or its subscription, unless the same subscription is specified.
| Parameters | |
|---|---|
| Name | Description |
request |
DeleteSnapshotRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
DeleteSnapshotAsync(DeleteSnapshotRequest, CancellationToken)
public virtual Task DeleteSnapshotAsync(DeleteSnapshotRequest request, CancellationToken cancellationToken)Removes an existing snapshot. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. When the snapshot is deleted, all messages retained in the snapshot are immediately dropped. After a snapshot is deleted, a new one may be created with the same name, but the new one has no association with the old snapshot or its subscription, unless the same subscription is specified.
| Parameters | |
|---|---|
| Name | Description |
request |
DeleteSnapshotRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
DeleteSnapshotAsync(SnapshotName, CallSettings)
public virtual Task DeleteSnapshotAsync(SnapshotName snapshot, CallSettings callSettings = null)Removes an existing snapshot. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. When the snapshot is deleted, all messages retained in the snapshot are immediately dropped. After a snapshot is deleted, a new one may be created with the same name, but the new one has no association with the old snapshot or its subscription, unless the same subscription is specified.
| Parameters | |
|---|---|
| Name | Description |
snapshot |
SnapshotNameRequired. The name of the snapshot to delete.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
DeleteSnapshotAsync(SnapshotName, CancellationToken)
public virtual Task DeleteSnapshotAsync(SnapshotName snapshot, CancellationToken cancellationToken)Removes an existing snapshot. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. When the snapshot is deleted, all messages retained in the snapshot are immediately dropped. After a snapshot is deleted, a new one may be created with the same name, but the new one has no association with the old snapshot or its subscription, unless the same subscription is specified.
| Parameters | |
|---|---|
| Name | Description |
snapshot |
SnapshotNameRequired. The name of the snapshot to delete.
Format is |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
DeleteSnapshotAsync(String, CallSettings)
public virtual Task DeleteSnapshotAsync(string snapshot, CallSettings callSettings = null)Removes an existing snapshot. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. When the snapshot is deleted, all messages retained in the snapshot are immediately dropped. After a snapshot is deleted, a new one may be created with the same name, but the new one has no association with the old snapshot or its subscription, unless the same subscription is specified.
| Parameters | |
|---|---|
| Name | Description |
snapshot |
System.StringRequired. The name of the snapshot to delete.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
DeleteSnapshotAsync(String, CancellationToken)
public virtual Task DeleteSnapshotAsync(string snapshot, CancellationToken cancellationToken)Removes an existing snapshot. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. When the snapshot is deleted, all messages retained in the snapshot are immediately dropped. After a snapshot is deleted, a new one may be created with the same name, but the new one has no association with the old snapshot or its subscription, unless the same subscription is specified.
| Parameters | |
|---|---|
| Name | Description |
snapshot |
System.StringRequired. The name of the snapshot to delete.
Format is |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
DeleteSubscription(DeleteSubscriptionRequest, CallSettings)
public virtual void DeleteSubscription(DeleteSubscriptionRequest request, CallSettings callSettings = null)Deletes an existing subscription. All messages retained in the subscription
are immediately dropped. Calls to Pull after deletion will return
NOT_FOUND. After a subscription is deleted, a new one may be created with
the same name, but the new one has no association with the old
subscription or its topic unless the same topic is specified.
| Parameters | |
|---|---|
| Name | Description |
request |
DeleteSubscriptionRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
DeleteSubscription(SubscriptionName, CallSettings)
public virtual void DeleteSubscription(SubscriptionName subscription, CallSettings callSettings = null)Deletes an existing subscription. All messages retained in the subscription
are immediately dropped. Calls to Pull after deletion will return
NOT_FOUND. After a subscription is deleted, a new one may be created with
the same name, but the new one has no association with the old
subscription or its topic unless the same topic is specified.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The subscription to delete.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
DeleteSubscription(String, CallSettings)
public virtual void DeleteSubscription(string subscription, CallSettings callSettings = null)Deletes an existing subscription. All messages retained in the subscription
are immediately dropped. Calls to Pull after deletion will return
NOT_FOUND. After a subscription is deleted, a new one may be created with
the same name, but the new one has no association with the old
subscription or its topic unless the same topic is specified.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The subscription to delete.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
DeleteSubscriptionAsync(DeleteSubscriptionRequest, CallSettings)
public virtual Task DeleteSubscriptionAsync(DeleteSubscriptionRequest request, CallSettings callSettings = null)Deletes an existing subscription. All messages retained in the subscription
are immediately dropped. Calls to Pull after deletion will return
NOT_FOUND. After a subscription is deleted, a new one may be created with
the same name, but the new one has no association with the old
subscription or its topic unless the same topic is specified.
| Parameters | |
|---|---|
| Name | Description |
request |
DeleteSubscriptionRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
DeleteSubscriptionAsync(DeleteSubscriptionRequest, CancellationToken)
public virtual Task DeleteSubscriptionAsync(DeleteSubscriptionRequest request, CancellationToken cancellationToken)Deletes an existing subscription. All messages retained in the subscription
are immediately dropped. Calls to Pull after deletion will return
NOT_FOUND. After a subscription is deleted, a new one may be created with
the same name, but the new one has no association with the old
subscription or its topic unless the same topic is specified.
| Parameters | |
|---|---|
| Name | Description |
request |
DeleteSubscriptionRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
DeleteSubscriptionAsync(SubscriptionName, CallSettings)
public virtual Task DeleteSubscriptionAsync(SubscriptionName subscription, CallSettings callSettings = null)Deletes an existing subscription. All messages retained in the subscription
are immediately dropped. Calls to Pull after deletion will return
NOT_FOUND. After a subscription is deleted, a new one may be created with
the same name, but the new one has no association with the old
subscription or its topic unless the same topic is specified.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The subscription to delete.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
DeleteSubscriptionAsync(SubscriptionName, CancellationToken)
public virtual Task DeleteSubscriptionAsync(SubscriptionName subscription, CancellationToken cancellationToken)Deletes an existing subscription. All messages retained in the subscription
are immediately dropped. Calls to Pull after deletion will return
NOT_FOUND. After a subscription is deleted, a new one may be created with
the same name, but the new one has no association with the old
subscription or its topic unless the same topic is specified.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The subscription to delete.
Format is |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
DeleteSubscriptionAsync(String, CallSettings)
public virtual Task DeleteSubscriptionAsync(string subscription, CallSettings callSettings = null)Deletes an existing subscription. All messages retained in the subscription
are immediately dropped. Calls to Pull after deletion will return
NOT_FOUND. After a subscription is deleted, a new one may be created with
the same name, but the new one has no association with the old
subscription or its topic unless the same topic is specified.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The subscription to delete.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
DeleteSubscriptionAsync(String, CancellationToken)
public virtual Task DeleteSubscriptionAsync(string subscription, CancellationToken cancellationToken)Deletes an existing subscription. All messages retained in the subscription
are immediately dropped. Calls to Pull after deletion will return
NOT_FOUND. After a subscription is deleted, a new one may be created with
the same name, but the new one has no association with the old
subscription or its topic unless the same topic is specified.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The subscription to delete.
Format is |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
GetIamPolicy(IResourceName, CallSettings)
public virtual Policy GetIamPolicy(IResourceName resource, CallSettings callSettings = null)Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set.
| Parameters | |
|---|---|
| Name | Description |
resource |
Google.Api.Gax.IResourceNameREQUIRED: The resource for which the policy is being requested. See the operation documentation for the appropriate value for this field. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Cloud.Iam.V1.Policy |
The RPC response. |
GetIamPolicy(GetIamPolicyRequest, CallSettings)
public virtual Policy GetIamPolicy(GetIamPolicyRequest request, CallSettings callSettings = null)Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set.
| Parameters | |
|---|---|
| Name | Description |
request |
Google.Cloud.Iam.V1.GetIamPolicyRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Cloud.Iam.V1.Policy |
The RPC response. |
GetIamPolicy(String, CallSettings)
public virtual Policy GetIamPolicy(string resource, CallSettings callSettings = null)Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set.
| Parameters | |
|---|---|
| Name | Description |
resource |
System.StringREQUIRED: The resource for which the policy is being requested. See the operation documentation for the appropriate value for this field. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Cloud.Iam.V1.Policy |
The RPC response. |
GetIamPolicyAsync(IResourceName, CallSettings)
public virtual Task<Policy> GetIamPolicyAsync(IResourceName resource, CallSettings callSettings = null)Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set.
| Parameters | |
|---|---|
| Name | Description |
resource |
Google.Api.Gax.IResourceNameREQUIRED: The resource for which the policy is being requested. See the operation documentation for the appropriate value for this field. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.Policy> |
A Task containing the RPC response. |
GetIamPolicyAsync(IResourceName, CancellationToken)
public virtual Task<Policy> GetIamPolicyAsync(IResourceName resource, CancellationToken cancellationToken)Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set.
| Parameters | |
|---|---|
| Name | Description |
resource |
Google.Api.Gax.IResourceNameREQUIRED: The resource for which the policy is being requested. See the operation documentation for the appropriate value for this field. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.Policy> |
A Task containing the RPC response. |
GetIamPolicyAsync(GetIamPolicyRequest, CallSettings)
public virtual Task<Policy> GetIamPolicyAsync(GetIamPolicyRequest request, CallSettings callSettings = null)Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set.
| Parameters | |
|---|---|
| Name | Description |
request |
Google.Cloud.Iam.V1.GetIamPolicyRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.Policy> |
A Task containing the RPC response. |
GetIamPolicyAsync(GetIamPolicyRequest, CancellationToken)
public virtual Task<Policy> GetIamPolicyAsync(GetIamPolicyRequest request, CancellationToken cancellationToken)Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set.
| Parameters | |
|---|---|
| Name | Description |
request |
Google.Cloud.Iam.V1.GetIamPolicyRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.Policy> |
A Task containing the RPC response. |
GetIamPolicyAsync(String, CallSettings)
public virtual Task<Policy> GetIamPolicyAsync(string resource, CallSettings callSettings = null)Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set.
| Parameters | |
|---|---|
| Name | Description |
resource |
System.StringREQUIRED: The resource for which the policy is being requested. See the operation documentation for the appropriate value for this field. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.Policy> |
A Task containing the RPC response. |
GetIamPolicyAsync(String, CancellationToken)
public virtual Task<Policy> GetIamPolicyAsync(string resource, CancellationToken cancellationToken)Gets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set.
| Parameters | |
|---|---|
| Name | Description |
resource |
System.StringREQUIRED: The resource for which the policy is being requested. See the operation documentation for the appropriate value for this field. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.Policy> |
A Task containing the RPC response. |
GetSnapshot(GetSnapshotRequest, CallSettings)
public virtual Snapshot GetSnapshot(GetSnapshotRequest request, CallSettings callSettings = null)Gets the configuration details of a snapshot. Snapshots are used in <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
request |
GetSnapshotRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Snapshot |
The RPC response. |
GetSnapshot(SnapshotName, CallSettings)
public virtual Snapshot GetSnapshot(SnapshotName snapshot, CallSettings callSettings = null)Gets the configuration details of a snapshot. Snapshots are used in <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
snapshot |
SnapshotNameRequired. The name of the snapshot to get.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Snapshot |
The RPC response. |
GetSnapshot(String, CallSettings)
public virtual Snapshot GetSnapshot(string snapshot, CallSettings callSettings = null)Gets the configuration details of a snapshot. Snapshots are used in <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
snapshot |
System.StringRequired. The name of the snapshot to get.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Snapshot |
The RPC response. |
GetSnapshotAsync(GetSnapshotRequest, CallSettings)
public virtual Task<Snapshot> GetSnapshotAsync(GetSnapshotRequest request, CallSettings callSettings = null)Gets the configuration details of a snapshot. Snapshots are used in <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
request |
GetSnapshotRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
GetSnapshotAsync(GetSnapshotRequest, CancellationToken)
public virtual Task<Snapshot> GetSnapshotAsync(GetSnapshotRequest request, CancellationToken cancellationToken)Gets the configuration details of a snapshot. Snapshots are used in <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
request |
GetSnapshotRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
GetSnapshotAsync(SnapshotName, CallSettings)
public virtual Task<Snapshot> GetSnapshotAsync(SnapshotName snapshot, CallSettings callSettings = null)Gets the configuration details of a snapshot. Snapshots are used in <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
snapshot |
SnapshotNameRequired. The name of the snapshot to get.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
GetSnapshotAsync(SnapshotName, CancellationToken)
public virtual Task<Snapshot> GetSnapshotAsync(SnapshotName snapshot, CancellationToken cancellationToken)Gets the configuration details of a snapshot. Snapshots are used in <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
snapshot |
SnapshotNameRequired. The name of the snapshot to get.
Format is |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
GetSnapshotAsync(String, CallSettings)
public virtual Task<Snapshot> GetSnapshotAsync(string snapshot, CallSettings callSettings = null)Gets the configuration details of a snapshot. Snapshots are used in <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
snapshot |
System.StringRequired. The name of the snapshot to get.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
GetSnapshotAsync(String, CancellationToken)
public virtual Task<Snapshot> GetSnapshotAsync(string snapshot, CancellationToken cancellationToken)Gets the configuration details of a snapshot. Snapshots are used in <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
snapshot |
System.StringRequired. The name of the snapshot to get.
Format is |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
GetSubscription(GetSubscriptionRequest, CallSettings)
public virtual Subscription GetSubscription(GetSubscriptionRequest request, CallSettings callSettings = null)Gets the configuration details of a subscription.
| Parameters | |
|---|---|
| Name | Description |
request |
GetSubscriptionRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Subscription |
The RPC response. |
GetSubscription(SubscriptionName, CallSettings)
public virtual Subscription GetSubscription(SubscriptionName subscription, CallSettings callSettings = null)Gets the configuration details of a subscription.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The name of the subscription to get.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Subscription |
The RPC response. |
GetSubscription(String, CallSettings)
public virtual Subscription GetSubscription(string subscription, CallSettings callSettings = null)Gets the configuration details of a subscription.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The name of the subscription to get.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Subscription |
The RPC response. |
GetSubscriptionAsync(GetSubscriptionRequest, CallSettings)
public virtual Task<Subscription> GetSubscriptionAsync(GetSubscriptionRequest request, CallSettings callSettings = null)Gets the configuration details of a subscription.
| Parameters | |
|---|---|
| Name | Description |
request |
GetSubscriptionRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |
GetSubscriptionAsync(GetSubscriptionRequest, CancellationToken)
public virtual Task<Subscription> GetSubscriptionAsync(GetSubscriptionRequest request, CancellationToken cancellationToken)Gets the configuration details of a subscription.
| Parameters | |
|---|---|
| Name | Description |
request |
GetSubscriptionRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |
GetSubscriptionAsync(SubscriptionName, CallSettings)
public virtual Task<Subscription> GetSubscriptionAsync(SubscriptionName subscription, CallSettings callSettings = null)Gets the configuration details of a subscription.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The name of the subscription to get.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |
GetSubscriptionAsync(SubscriptionName, CancellationToken)
public virtual Task<Subscription> GetSubscriptionAsync(SubscriptionName subscription, CancellationToken cancellationToken)Gets the configuration details of a subscription.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The name of the subscription to get.
Format is |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |
GetSubscriptionAsync(String, CallSettings)
public virtual Task<Subscription> GetSubscriptionAsync(string subscription, CallSettings callSettings = null)Gets the configuration details of a subscription.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The name of the subscription to get.
Format is |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |
GetSubscriptionAsync(String, CancellationToken)
public virtual Task<Subscription> GetSubscriptionAsync(string subscription, CancellationToken cancellationToken)Gets the configuration details of a subscription.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The name of the subscription to get.
Format is |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |
ListSnapshots(ProjectName, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListSnapshotsResponse, Snapshot> ListSnapshots(ProjectName project, string pageToken = null, int? pageSize = default(int? ), CallSettings callSettings = null)Lists the existing snapshots. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
project |
Google.Api.Gax.ResourceNames.ProjectNameRequired. The name of the project in which to list snapshots.
Format is |
pageToken |
System.StringThe token returned from the previous request. A value of |
pageSize |
System.Nullable<System.Int32>The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Api.Gax.PagedEnumerable<ListSnapshotsResponse, Snapshot> |
A pageable sequence of Snapshot resources. |
ListSnapshots(ListSnapshotsRequest, CallSettings)
public virtual PagedEnumerable<ListSnapshotsResponse, Snapshot> ListSnapshots(ListSnapshotsRequest request, CallSettings callSettings = null)Lists the existing snapshots. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
request |
ListSnapshotsRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Api.Gax.PagedEnumerable<ListSnapshotsResponse, Snapshot> |
A pageable sequence of Snapshot resources. |
ListSnapshots(String, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListSnapshotsResponse, Snapshot> ListSnapshots(string project, string pageToken = null, int? pageSize = default(int? ), CallSettings callSettings = null)Lists the existing snapshots. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
project |
System.StringRequired. The name of the project in which to list snapshots.
Format is |
pageToken |
System.StringThe token returned from the previous request. A value of |
pageSize |
System.Nullable<System.Int32>The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Api.Gax.PagedEnumerable<ListSnapshotsResponse, Snapshot> |
A pageable sequence of Snapshot resources. |
ListSnapshotsAsync(ProjectName, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListSnapshotsResponse, Snapshot> ListSnapshotsAsync(ProjectName project, string pageToken = null, int? pageSize = default(int? ), CallSettings callSettings = null)Lists the existing snapshots. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
project |
Google.Api.Gax.ResourceNames.ProjectNameRequired. The name of the project in which to list snapshots.
Format is |
pageToken |
System.StringThe token returned from the previous request. A value of |
pageSize |
System.Nullable<System.Int32>The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Api.Gax.PagedAsyncEnumerable<ListSnapshotsResponse, Snapshot> |
A pageable asynchronous sequence of Snapshot resources. |
ListSnapshotsAsync(ListSnapshotsRequest, CallSettings)
public virtual PagedAsyncEnumerable<ListSnapshotsResponse, Snapshot> ListSnapshotsAsync(ListSnapshotsRequest request, CallSettings callSettings = null)Lists the existing snapshots. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
request |
ListSnapshotsRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Api.Gax.PagedAsyncEnumerable<ListSnapshotsResponse, Snapshot> |
A pageable asynchronous sequence of Snapshot resources. |
ListSnapshotsAsync(String, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListSnapshotsResponse, Snapshot> ListSnapshotsAsync(string project, string pageToken = null, int? pageSize = default(int? ), CallSettings callSettings = null)Lists the existing snapshots. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
project |
System.StringRequired. The name of the project in which to list snapshots.
Format is |
pageToken |
System.StringThe token returned from the previous request. A value of |
pageSize |
System.Nullable<System.Int32>The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Api.Gax.PagedAsyncEnumerable<ListSnapshotsResponse, Snapshot> |
A pageable asynchronous sequence of Snapshot resources. |
ListSubscriptions(ProjectName, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListSubscriptionsResponse, Subscription> ListSubscriptions(ProjectName project, string pageToken = null, int? pageSize = default(int? ), CallSettings callSettings = null)Lists matching subscriptions.
| Parameters | |
|---|---|
| Name | Description |
project |
Google.Api.Gax.ResourceNames.ProjectNameRequired. The name of the project in which to list subscriptions.
Format is |
pageToken |
System.StringThe token returned from the previous request. A value of |
pageSize |
System.Nullable<System.Int32>The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Api.Gax.PagedEnumerable<ListSubscriptionsResponse, Subscription> |
A pageable sequence of Subscription resources. |
ListSubscriptions(ListSubscriptionsRequest, CallSettings)
public virtual PagedEnumerable<ListSubscriptionsResponse, Subscription> ListSubscriptions(ListSubscriptionsRequest request, CallSettings callSettings = null)Lists matching subscriptions.
| Parameters | |
|---|---|
| Name | Description |
request |
ListSubscriptionsRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Api.Gax.PagedEnumerable<ListSubscriptionsResponse, Subscription> |
A pageable sequence of Subscription resources. |
ListSubscriptions(String, String, Nullable<Int32>, CallSettings)
public virtual PagedEnumerable<ListSubscriptionsResponse, Subscription> ListSubscriptions(string project, string pageToken = null, int? pageSize = default(int? ), CallSettings callSettings = null)Lists matching subscriptions.
| Parameters | |
|---|---|
| Name | Description |
project |
System.StringRequired. The name of the project in which to list subscriptions.
Format is |
pageToken |
System.StringThe token returned from the previous request. A value of |
pageSize |
System.Nullable<System.Int32>The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Api.Gax.PagedEnumerable<ListSubscriptionsResponse, Subscription> |
A pageable sequence of Subscription resources. |
ListSubscriptionsAsync(ProjectName, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListSubscriptionsResponse, Subscription> ListSubscriptionsAsync(ProjectName project, string pageToken = null, int? pageSize = default(int? ), CallSettings callSettings = null)Lists matching subscriptions.
| Parameters | |
|---|---|
| Name | Description |
project |
Google.Api.Gax.ResourceNames.ProjectNameRequired. The name of the project in which to list subscriptions.
Format is |
pageToken |
System.StringThe token returned from the previous request. A value of |
pageSize |
System.Nullable<System.Int32>The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Api.Gax.PagedAsyncEnumerable<ListSubscriptionsResponse, Subscription> |
A pageable asynchronous sequence of Subscription resources. |
ListSubscriptionsAsync(ListSubscriptionsRequest, CallSettings)
public virtual PagedAsyncEnumerable<ListSubscriptionsResponse, Subscription> ListSubscriptionsAsync(ListSubscriptionsRequest request, CallSettings callSettings = null)Lists matching subscriptions.
| Parameters | |
|---|---|
| Name | Description |
request |
ListSubscriptionsRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Api.Gax.PagedAsyncEnumerable<ListSubscriptionsResponse, Subscription> |
A pageable asynchronous sequence of Subscription resources. |
ListSubscriptionsAsync(String, String, Nullable<Int32>, CallSettings)
public virtual PagedAsyncEnumerable<ListSubscriptionsResponse, Subscription> ListSubscriptionsAsync(string project, string pageToken = null, int? pageSize = default(int? ), CallSettings callSettings = null)Lists matching subscriptions.
| Parameters | |
|---|---|
| Name | Description |
project |
System.StringRequired. The name of the project in which to list subscriptions.
Format is |
pageToken |
System.StringThe token returned from the previous request. A value of |
pageSize |
System.Nullable<System.Int32>The size of page to request. The response will not be larger than this, but may be smaller. A value of
|
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Api.Gax.PagedAsyncEnumerable<ListSubscriptionsResponse, Subscription> |
A pageable asynchronous sequence of Subscription resources. |
ModifyAckDeadline(ModifyAckDeadlineRequest, CallSettings)
public virtual void ModifyAckDeadline(ModifyAckDeadlineRequest request, CallSettings callSettings = null)Modifies the ack deadline for a specific message. This method is useful
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted. Note that this does not modify the
subscription-level ackDeadlineSeconds used for subsequent messages.
| Parameters | |
|---|---|
| Name | Description |
request |
ModifyAckDeadlineRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
ModifyAckDeadline(SubscriptionName, IEnumerable<String>, Int32, CallSettings)
public virtual void ModifyAckDeadline(SubscriptionName subscription, IEnumerable<string> ackIds, int ackDeadlineSeconds, CallSettings callSettings = null)Modifies the ack deadline for a specific message. This method is useful
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted. Note that this does not modify the
subscription-level ackDeadlineSeconds used for subsequent messages.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The name of the subscription.
Format is |
ackIds |
System.Collections.Generic.IEnumerable<System.String>Required. List of acknowledgment IDs. |
ackDeadlineSeconds |
System.Int32Required. The new ack deadline with respect to the time this request was
sent to the Pub/Sub system. For example, if the value is 10, the new ack
deadline will expire 10 seconds after the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
ModifyAckDeadline(String, IEnumerable<String>, Int32, CallSettings)
public virtual void ModifyAckDeadline(string subscription, IEnumerable<string> ackIds, int ackDeadlineSeconds, CallSettings callSettings = null)Modifies the ack deadline for a specific message. This method is useful
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted. Note that this does not modify the
subscription-level ackDeadlineSeconds used for subsequent messages.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The name of the subscription.
Format is |
ackIds |
System.Collections.Generic.IEnumerable<System.String>Required. List of acknowledgment IDs. |
ackDeadlineSeconds |
System.Int32Required. The new ack deadline with respect to the time this request was
sent to the Pub/Sub system. For example, if the value is 10, the new ack
deadline will expire 10 seconds after the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
ModifyAckDeadlineAsync(ModifyAckDeadlineRequest, CallSettings)
public virtual Task ModifyAckDeadlineAsync(ModifyAckDeadlineRequest request, CallSettings callSettings = null)Modifies the ack deadline for a specific message. This method is useful
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted. Note that this does not modify the
subscription-level ackDeadlineSeconds used for subsequent messages.
| Parameters | |
|---|---|
| Name | Description |
request |
ModifyAckDeadlineRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
ModifyAckDeadlineAsync(ModifyAckDeadlineRequest, CancellationToken)
public virtual Task ModifyAckDeadlineAsync(ModifyAckDeadlineRequest request, CancellationToken cancellationToken)Modifies the ack deadline for a specific message. This method is useful
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted. Note that this does not modify the
subscription-level ackDeadlineSeconds used for subsequent messages.
| Parameters | |
|---|---|
| Name | Description |
request |
ModifyAckDeadlineRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
ModifyAckDeadlineAsync(SubscriptionName, IEnumerable<String>, Int32, CallSettings)
public virtual Task ModifyAckDeadlineAsync(SubscriptionName subscription, IEnumerable<string> ackIds, int ackDeadlineSeconds, CallSettings callSettings = null)Modifies the ack deadline for a specific message. This method is useful
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted. Note that this does not modify the
subscription-level ackDeadlineSeconds used for subsequent messages.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The name of the subscription.
Format is |
ackIds |
System.Collections.Generic.IEnumerable<System.String>Required. List of acknowledgment IDs. |
ackDeadlineSeconds |
System.Int32Required. The new ack deadline with respect to the time this request was
sent to the Pub/Sub system. For example, if the value is 10, the new ack
deadline will expire 10 seconds after the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
ModifyAckDeadlineAsync(SubscriptionName, IEnumerable<String>, Int32, CancellationToken)
public virtual Task ModifyAckDeadlineAsync(SubscriptionName subscription, IEnumerable<string> ackIds, int ackDeadlineSeconds, CancellationToken cancellationToken)Modifies the ack deadline for a specific message. This method is useful
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted. Note that this does not modify the
subscription-level ackDeadlineSeconds used for subsequent messages.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The name of the subscription.
Format is |
ackIds |
System.Collections.Generic.IEnumerable<System.String>Required. List of acknowledgment IDs. |
ackDeadlineSeconds |
System.Int32Required. The new ack deadline with respect to the time this request was
sent to the Pub/Sub system. For example, if the value is 10, the new ack
deadline will expire 10 seconds after the |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
ModifyAckDeadlineAsync(String, IEnumerable<String>, Int32, CallSettings)
public virtual Task ModifyAckDeadlineAsync(string subscription, IEnumerable<string> ackIds, int ackDeadlineSeconds, CallSettings callSettings = null)Modifies the ack deadline for a specific message. This method is useful
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted. Note that this does not modify the
subscription-level ackDeadlineSeconds used for subsequent messages.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The name of the subscription.
Format is |
ackIds |
System.Collections.Generic.IEnumerable<System.String>Required. List of acknowledgment IDs. |
ackDeadlineSeconds |
System.Int32Required. The new ack deadline with respect to the time this request was
sent to the Pub/Sub system. For example, if the value is 10, the new ack
deadline will expire 10 seconds after the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
ModifyAckDeadlineAsync(String, IEnumerable<String>, Int32, CancellationToken)
public virtual Task ModifyAckDeadlineAsync(string subscription, IEnumerable<string> ackIds, int ackDeadlineSeconds, CancellationToken cancellationToken)Modifies the ack deadline for a specific message. This method is useful
to indicate that more time is needed to process a message by the
subscriber, or to make the message available for redelivery if the
processing was interrupted. Note that this does not modify the
subscription-level ackDeadlineSeconds used for subsequent messages.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The name of the subscription.
Format is |
ackIds |
System.Collections.Generic.IEnumerable<System.String>Required. List of acknowledgment IDs. |
ackDeadlineSeconds |
System.Int32Required. The new ack deadline with respect to the time this request was
sent to the Pub/Sub system. For example, if the value is 10, the new ack
deadline will expire 10 seconds after the |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
ModifyPushConfig(ModifyPushConfigRequest, CallSettings)
public virtual void ModifyPushConfig(ModifyPushConfigRequest request, CallSettings callSettings = null)Modifies the PushConfig for a specified subscription.
This may be used to change a push subscription to a pull one (signified by
an empty PushConfig) or vice versa, or change the endpoint URL and other
attributes of a push subscription. Messages will accumulate for delivery
continuously through the call regardless of changes to the PushConfig.
| Parameters | |
|---|---|
| Name | Description |
request |
ModifyPushConfigRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
ModifyPushConfig(SubscriptionName, PushConfig, CallSettings)
public virtual void ModifyPushConfig(SubscriptionName subscription, PushConfig pushConfig, CallSettings callSettings = null)Modifies the PushConfig for a specified subscription.
This may be used to change a push subscription to a pull one (signified by
an empty PushConfig) or vice versa, or change the endpoint URL and other
attributes of a push subscription. Messages will accumulate for delivery
continuously through the call regardless of changes to the PushConfig.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The name of the subscription.
Format is |
pushConfig |
PushConfigRequired. The push configuration for future deliveries. An empty |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
ModifyPushConfig(String, PushConfig, CallSettings)
public virtual void ModifyPushConfig(string subscription, PushConfig pushConfig, CallSettings callSettings = null)Modifies the PushConfig for a specified subscription.
This may be used to change a push subscription to a pull one (signified by
an empty PushConfig) or vice versa, or change the endpoint URL and other
attributes of a push subscription. Messages will accumulate for delivery
continuously through the call regardless of changes to the PushConfig.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The name of the subscription.
Format is |
pushConfig |
PushConfigRequired. The push configuration for future deliveries. An empty |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
ModifyPushConfigAsync(ModifyPushConfigRequest, CallSettings)
public virtual Task ModifyPushConfigAsync(ModifyPushConfigRequest request, CallSettings callSettings = null)Modifies the PushConfig for a specified subscription.
This may be used to change a push subscription to a pull one (signified by
an empty PushConfig) or vice versa, or change the endpoint URL and other
attributes of a push subscription. Messages will accumulate for delivery
continuously through the call regardless of changes to the PushConfig.
| Parameters | |
|---|---|
| Name | Description |
request |
ModifyPushConfigRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
ModifyPushConfigAsync(ModifyPushConfigRequest, CancellationToken)
public virtual Task ModifyPushConfigAsync(ModifyPushConfigRequest request, CancellationToken cancellationToken)Modifies the PushConfig for a specified subscription.
This may be used to change a push subscription to a pull one (signified by
an empty PushConfig) or vice versa, or change the endpoint URL and other
attributes of a push subscription. Messages will accumulate for delivery
continuously through the call regardless of changes to the PushConfig.
| Parameters | |
|---|---|
| Name | Description |
request |
ModifyPushConfigRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
ModifyPushConfigAsync(SubscriptionName, PushConfig, CallSettings)
public virtual Task ModifyPushConfigAsync(SubscriptionName subscription, PushConfig pushConfig, CallSettings callSettings = null)Modifies the PushConfig for a specified subscription.
This may be used to change a push subscription to a pull one (signified by
an empty PushConfig) or vice versa, or change the endpoint URL and other
attributes of a push subscription. Messages will accumulate for delivery
continuously through the call regardless of changes to the PushConfig.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The name of the subscription.
Format is |
pushConfig |
PushConfigRequired. The push configuration for future deliveries. An empty |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
ModifyPushConfigAsync(SubscriptionName, PushConfig, CancellationToken)
public virtual Task ModifyPushConfigAsync(SubscriptionName subscription, PushConfig pushConfig, CancellationToken cancellationToken)Modifies the PushConfig for a specified subscription.
This may be used to change a push subscription to a pull one (signified by
an empty PushConfig) or vice versa, or change the endpoint URL and other
attributes of a push subscription. Messages will accumulate for delivery
continuously through the call regardless of changes to the PushConfig.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The name of the subscription.
Format is |
pushConfig |
PushConfigRequired. The push configuration for future deliveries. An empty |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
ModifyPushConfigAsync(String, PushConfig, CallSettings)
public virtual Task ModifyPushConfigAsync(string subscription, PushConfig pushConfig, CallSettings callSettings = null)Modifies the PushConfig for a specified subscription.
This may be used to change a push subscription to a pull one (signified by
an empty PushConfig) or vice versa, or change the endpoint URL and other
attributes of a push subscription. Messages will accumulate for delivery
continuously through the call regardless of changes to the PushConfig.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The name of the subscription.
Format is |
pushConfig |
PushConfigRequired. The push configuration for future deliveries. An empty |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
ModifyPushConfigAsync(String, PushConfig, CancellationToken)
public virtual Task ModifyPushConfigAsync(string subscription, PushConfig pushConfig, CancellationToken cancellationToken)Modifies the PushConfig for a specified subscription.
This may be used to change a push subscription to a pull one (signified by
an empty PushConfig) or vice versa, or change the endpoint URL and other
attributes of a push subscription. Messages will accumulate for delivery
continuously through the call regardless of changes to the PushConfig.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The name of the subscription.
Format is |
pushConfig |
PushConfigRequired. The push configuration for future deliveries. An empty |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A Task containing the RPC response. |
Pull(PullRequest, CallSettings)
public virtual PullResponse Pull(PullRequest request, CallSettings callSettings = null)Pulls messages from the server. The server may return UNAVAILABLE if
there are too many concurrent pull requests pending for the given
subscription.
| Parameters | |
|---|---|
| Name | Description |
request |
PullRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
PullResponse |
The RPC response. |
Pull(SubscriptionName, Boolean, Int32, CallSettings)
public virtual PullResponse Pull(SubscriptionName subscription, bool returnImmediately, int maxMessages, CallSettings callSettings = null)Pulls messages from the server. The server may return UNAVAILABLE if
there are too many concurrent pull requests pending for the given
subscription.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The subscription from which messages should be pulled.
Format is |
returnImmediately |
System.BooleanOptional. If this field set to true, the system will respond immediately
even if it there are no messages available to return in the |
maxMessages |
System.Int32Required. The maximum number of messages to return for this request. Must be a positive integer. The Pub/Sub system may return fewer than the number specified. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
PullResponse |
The RPC response. |
Pull(String, Boolean, Int32, CallSettings)
public virtual PullResponse Pull(string subscription, bool returnImmediately, int maxMessages, CallSettings callSettings = null)Pulls messages from the server. The server may return UNAVAILABLE if
there are too many concurrent pull requests pending for the given
subscription.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The subscription from which messages should be pulled.
Format is |
returnImmediately |
System.BooleanOptional. If this field set to true, the system will respond immediately
even if it there are no messages available to return in the |
maxMessages |
System.Int32Required. The maximum number of messages to return for this request. Must be a positive integer. The Pub/Sub system may return fewer than the number specified. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
PullResponse |
The RPC response. |
PullAsync(PullRequest, CallSettings)
public virtual Task<PullResponse> PullAsync(PullRequest request, CallSettings callSettings = null)Pulls messages from the server. The server may return UNAVAILABLE if
there are too many concurrent pull requests pending for the given
subscription.
| Parameters | |
|---|---|
| Name | Description |
request |
PullRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<PullResponse> |
A Task containing the RPC response. |
PullAsync(PullRequest, CancellationToken)
public virtual Task<PullResponse> PullAsync(PullRequest request, CancellationToken cancellationToken)Pulls messages from the server. The server may return UNAVAILABLE if
there are too many concurrent pull requests pending for the given
subscription.
| Parameters | |
|---|---|
| Name | Description |
request |
PullRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<PullResponse> |
A Task containing the RPC response. |
PullAsync(SubscriptionName, Boolean, Int32, CallSettings)
public virtual Task<PullResponse> PullAsync(SubscriptionName subscription, bool returnImmediately, int maxMessages, CallSettings callSettings = null)Pulls messages from the server. The server may return UNAVAILABLE if
there are too many concurrent pull requests pending for the given
subscription.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The subscription from which messages should be pulled.
Format is |
returnImmediately |
System.BooleanOptional. If this field set to true, the system will respond immediately
even if it there are no messages available to return in the |
maxMessages |
System.Int32Required. The maximum number of messages to return for this request. Must be a positive integer. The Pub/Sub system may return fewer than the number specified. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<PullResponse> |
A Task containing the RPC response. |
PullAsync(SubscriptionName, Boolean, Int32, CancellationToken)
public virtual Task<PullResponse> PullAsync(SubscriptionName subscription, bool returnImmediately, int maxMessages, CancellationToken cancellationToken)Pulls messages from the server. The server may return UNAVAILABLE if
there are too many concurrent pull requests pending for the given
subscription.
| Parameters | |
|---|---|
| Name | Description |
subscription |
SubscriptionNameRequired. The subscription from which messages should be pulled.
Format is |
returnImmediately |
System.BooleanOptional. If this field set to true, the system will respond immediately
even if it there are no messages available to return in the |
maxMessages |
System.Int32Required. The maximum number of messages to return for this request. Must be a positive integer. The Pub/Sub system may return fewer than the number specified. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<PullResponse> |
A Task containing the RPC response. |
PullAsync(String, Boolean, Int32, CallSettings)
public virtual Task<PullResponse> PullAsync(string subscription, bool returnImmediately, int maxMessages, CallSettings callSettings = null)Pulls messages from the server. The server may return UNAVAILABLE if
there are too many concurrent pull requests pending for the given
subscription.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The subscription from which messages should be pulled.
Format is |
returnImmediately |
System.BooleanOptional. If this field set to true, the system will respond immediately
even if it there are no messages available to return in the |
maxMessages |
System.Int32Required. The maximum number of messages to return for this request. Must be a positive integer. The Pub/Sub system may return fewer than the number specified. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<PullResponse> |
A Task containing the RPC response. |
PullAsync(String, Boolean, Int32, CancellationToken)
public virtual Task<PullResponse> PullAsync(string subscription, bool returnImmediately, int maxMessages, CancellationToken cancellationToken)Pulls messages from the server. The server may return UNAVAILABLE if
there are too many concurrent pull requests pending for the given
subscription.
| Parameters | |
|---|---|
| Name | Description |
subscription |
System.StringRequired. The subscription from which messages should be pulled.
Format is |
returnImmediately |
System.BooleanOptional. If this field set to true, the system will respond immediately
even if it there are no messages available to return in the |
maxMessages |
System.Int32Required. The maximum number of messages to return for this request. Must be a positive integer. The Pub/Sub system may return fewer than the number specified. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<PullResponse> |
A Task containing the RPC response. |
Seek(SeekRequest, CallSettings)
public virtual SeekResponse Seek(SeekRequest request, CallSettings callSettings = null)Seeks an existing subscription to a point in time or to a given snapshot, whichever is provided in the request. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. Note that both the subscription and the snapshot must be on the same topic.
| Parameters | |
|---|---|
| Name | Description |
request |
SeekRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
SeekResponse |
The RPC response. |
SeekAsync(SeekRequest, CallSettings)
public virtual Task<SeekResponse> SeekAsync(SeekRequest request, CallSettings callSettings = null)Seeks an existing subscription to a point in time or to a given snapshot, whichever is provided in the request. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. Note that both the subscription and the snapshot must be on the same topic.
| Parameters | |
|---|---|
| Name | Description |
request |
SeekRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<SeekResponse> |
A Task containing the RPC response. |
SeekAsync(SeekRequest, CancellationToken)
public virtual Task<SeekResponse> SeekAsync(SeekRequest request, CancellationToken cancellationToken)Seeks an existing subscription to a point in time or to a given snapshot, whichever is provided in the request. Snapshots are used in Seek operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot. Note that both the subscription and the snapshot must be on the same topic.
| Parameters | |
|---|---|
| Name | Description |
request |
SeekRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<SeekResponse> |
A Task containing the RPC response. |
SetIamPolicy(IResourceName, Policy, CallSettings)
public virtual Policy SetIamPolicy(IResourceName resource, Policy policy, CallSettings callSettings = null)Sets the access control policy on the specified resource. Replaces any existing policy.
Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
| Parameters | |
|---|---|
| Name | Description |
resource |
Google.Api.Gax.IResourceNameREQUIRED: The resource for which the policy is being specified. See the operation documentation for the appropriate value for this field. |
policy |
Google.Cloud.Iam.V1.PolicyREQUIRED: The complete policy to be applied to the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Cloud.Iam.V1.Policy |
The RPC response. |
SetIamPolicy(SetIamPolicyRequest, CallSettings)
public virtual Policy SetIamPolicy(SetIamPolicyRequest request, CallSettings callSettings = null)Sets the access control policy on the specified resource. Replaces any existing policy.
Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
| Parameters | |
|---|---|
| Name | Description |
request |
Google.Cloud.Iam.V1.SetIamPolicyRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Cloud.Iam.V1.Policy |
The RPC response. |
SetIamPolicy(String, Policy, CallSettings)
public virtual Policy SetIamPolicy(string resource, Policy policy, CallSettings callSettings = null)Sets the access control policy on the specified resource. Replaces any existing policy.
Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
| Parameters | |
|---|---|
| Name | Description |
resource |
System.StringREQUIRED: The resource for which the policy is being specified. See the operation documentation for the appropriate value for this field. |
policy |
Google.Cloud.Iam.V1.PolicyREQUIRED: The complete policy to be applied to the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Cloud.Iam.V1.Policy |
The RPC response. |
SetIamPolicyAsync(IResourceName, Policy, CallSettings)
public virtual Task<Policy> SetIamPolicyAsync(IResourceName resource, Policy policy, CallSettings callSettings = null)Sets the access control policy on the specified resource. Replaces any existing policy.
Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
| Parameters | |
|---|---|
| Name | Description |
resource |
Google.Api.Gax.IResourceNameREQUIRED: The resource for which the policy is being specified. See the operation documentation for the appropriate value for this field. |
policy |
Google.Cloud.Iam.V1.PolicyREQUIRED: The complete policy to be applied to the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.Policy> |
A Task containing the RPC response. |
SetIamPolicyAsync(IResourceName, Policy, CancellationToken)
public virtual Task<Policy> SetIamPolicyAsync(IResourceName resource, Policy policy, CancellationToken cancellationToken)Sets the access control policy on the specified resource. Replaces any existing policy.
Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
| Parameters | |
|---|---|
| Name | Description |
resource |
Google.Api.Gax.IResourceNameREQUIRED: The resource for which the policy is being specified. See the operation documentation for the appropriate value for this field. |
policy |
Google.Cloud.Iam.V1.PolicyREQUIRED: The complete policy to be applied to the |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.Policy> |
A Task containing the RPC response. |
SetIamPolicyAsync(SetIamPolicyRequest, CallSettings)
public virtual Task<Policy> SetIamPolicyAsync(SetIamPolicyRequest request, CallSettings callSettings = null)Sets the access control policy on the specified resource. Replaces any existing policy.
Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
| Parameters | |
|---|---|
| Name | Description |
request |
Google.Cloud.Iam.V1.SetIamPolicyRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.Policy> |
A Task containing the RPC response. |
SetIamPolicyAsync(SetIamPolicyRequest, CancellationToken)
public virtual Task<Policy> SetIamPolicyAsync(SetIamPolicyRequest request, CancellationToken cancellationToken)Sets the access control policy on the specified resource. Replaces any existing policy.
Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
| Parameters | |
|---|---|
| Name | Description |
request |
Google.Cloud.Iam.V1.SetIamPolicyRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.Policy> |
A Task containing the RPC response. |
SetIamPolicyAsync(String, Policy, CallSettings)
public virtual Task<Policy> SetIamPolicyAsync(string resource, Policy policy, CallSettings callSettings = null)Sets the access control policy on the specified resource. Replaces any existing policy.
Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
| Parameters | |
|---|---|
| Name | Description |
resource |
System.StringREQUIRED: The resource for which the policy is being specified. See the operation documentation for the appropriate value for this field. |
policy |
Google.Cloud.Iam.V1.PolicyREQUIRED: The complete policy to be applied to the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.Policy> |
A Task containing the RPC response. |
SetIamPolicyAsync(String, Policy, CancellationToken)
public virtual Task<Policy> SetIamPolicyAsync(string resource, Policy policy, CancellationToken cancellationToken)Sets the access control policy on the specified resource. Replaces any existing policy.
Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
| Parameters | |
|---|---|
| Name | Description |
resource |
System.StringREQUIRED: The resource for which the policy is being specified. See the operation documentation for the appropriate value for this field. |
policy |
Google.Cloud.Iam.V1.PolicyREQUIRED: The complete policy to be applied to the |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.Policy> |
A Task containing the RPC response. |
ShutdownDefaultChannelsAsync()
public static Task ShutdownDefaultChannelsAsync()Shuts down any channels automatically created by Create() and CreateAsync(CancellationToken). Channels which weren't automatically created are not affected.
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task |
A task representing the asynchronous shutdown operation. |
After calling this method, further calls to Create() and CreateAsync(CancellationToken) will create new channels, which could in turn be shut down by another call to this method.
StreamingPull(CallSettings, BidirectionalStreamingSettings)
public virtual SubscriberServiceApiClient.StreamingPullStream StreamingPull(CallSettings callSettings = null, BidirectionalStreamingSettings streamingSettings = null)Establishes a stream with the server, which sends messages down to the
client. The client streams acknowledgements and ack deadline modifications
back to the server. The server will close the stream and return the status
on any error. The server may close the stream with status UNAVAILABLE to
reassign server-side resources, in which case, the client should
re-establish the stream. Flow control can be achieved by configuring the
underlying RPC channel.
| Parameters | |
|---|---|
| Name | Description |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
streamingSettings |
Google.Api.Gax.Grpc.BidirectionalStreamingSettingsIf not null, applies streaming overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
SubscriberServiceApiClient.StreamingPullStream |
The client-server stream. |
TestIamPermissions(IResourceName, IEnumerable<String>, CallSettings)
public virtual TestIamPermissionsResponse TestIamPermissions(IResourceName resource, IEnumerable<string> permissions, CallSettings callSettings = null)Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.
Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning.
| Parameters | |
|---|---|
| Name | Description |
resource |
Google.Api.Gax.IResourceNameREQUIRED: The resource for which the policy detail is being requested. See the operation documentation for the appropriate value for this field. |
permissions |
System.Collections.Generic.IEnumerable<System.String>The set of permissions to check for the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Cloud.Iam.V1.TestIamPermissionsResponse |
The RPC response. |
TestIamPermissions(TestIamPermissionsRequest, CallSettings)
public virtual TestIamPermissionsResponse TestIamPermissions(TestIamPermissionsRequest request, CallSettings callSettings = null)Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.
Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning.
| Parameters | |
|---|---|
| Name | Description |
request |
Google.Cloud.Iam.V1.TestIamPermissionsRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Cloud.Iam.V1.TestIamPermissionsResponse |
The RPC response. |
TestIamPermissions(String, IEnumerable<String>, CallSettings)
public virtual TestIamPermissionsResponse TestIamPermissions(string resource, IEnumerable<string> permissions, CallSettings callSettings = null)Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.
Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning.
| Parameters | |
|---|---|
| Name | Description |
resource |
System.StringREQUIRED: The resource for which the policy detail is being requested. See the operation documentation for the appropriate value for this field. |
permissions |
System.Collections.Generic.IEnumerable<System.String>The set of permissions to check for the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Google.Cloud.Iam.V1.TestIamPermissionsResponse |
The RPC response. |
TestIamPermissionsAsync(IResourceName, IEnumerable<String>, CallSettings)
public virtual Task<TestIamPermissionsResponse> TestIamPermissionsAsync(IResourceName resource, IEnumerable<string> permissions, CallSettings callSettings = null)Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.
Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning.
| Parameters | |
|---|---|
| Name | Description |
resource |
Google.Api.Gax.IResourceNameREQUIRED: The resource for which the policy detail is being requested. See the operation documentation for the appropriate value for this field. |
permissions |
System.Collections.Generic.IEnumerable<System.String>The set of permissions to check for the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.TestIamPermissionsResponse> |
A Task containing the RPC response. |
TestIamPermissionsAsync(IResourceName, IEnumerable<String>, CancellationToken)
public virtual Task<TestIamPermissionsResponse> TestIamPermissionsAsync(IResourceName resource, IEnumerable<string> permissions, CancellationToken cancellationToken)Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.
Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning.
| Parameters | |
|---|---|
| Name | Description |
resource |
Google.Api.Gax.IResourceNameREQUIRED: The resource for which the policy detail is being requested. See the operation documentation for the appropriate value for this field. |
permissions |
System.Collections.Generic.IEnumerable<System.String>The set of permissions to check for the |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.TestIamPermissionsResponse> |
A Task containing the RPC response. |
TestIamPermissionsAsync(TestIamPermissionsRequest, CallSettings)
public virtual Task<TestIamPermissionsResponse> TestIamPermissionsAsync(TestIamPermissionsRequest request, CallSettings callSettings = null)Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.
Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning.
| Parameters | |
|---|---|
| Name | Description |
request |
Google.Cloud.Iam.V1.TestIamPermissionsRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.TestIamPermissionsResponse> |
A Task containing the RPC response. |
TestIamPermissionsAsync(TestIamPermissionsRequest, CancellationToken)
public virtual Task<TestIamPermissionsResponse> TestIamPermissionsAsync(TestIamPermissionsRequest request, CancellationToken cancellationToken)Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.
Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning.
| Parameters | |
|---|---|
| Name | Description |
request |
Google.Cloud.Iam.V1.TestIamPermissionsRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.TestIamPermissionsResponse> |
A Task containing the RPC response. |
TestIamPermissionsAsync(String, IEnumerable<String>, CallSettings)
public virtual Task<TestIamPermissionsResponse> TestIamPermissionsAsync(string resource, IEnumerable<string> permissions, CallSettings callSettings = null)Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.
Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning.
| Parameters | |
|---|---|
| Name | Description |
resource |
System.StringREQUIRED: The resource for which the policy detail is being requested. See the operation documentation for the appropriate value for this field. |
permissions |
System.Collections.Generic.IEnumerable<System.String>The set of permissions to check for the |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.TestIamPermissionsResponse> |
A Task containing the RPC response. |
TestIamPermissionsAsync(String, IEnumerable<String>, CancellationToken)
public virtual Task<TestIamPermissionsResponse> TestIamPermissionsAsync(string resource, IEnumerable<string> permissions, CancellationToken cancellationToken)Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.
Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning.
| Parameters | |
|---|---|
| Name | Description |
resource |
System.StringREQUIRED: The resource for which the policy detail is being requested. See the operation documentation for the appropriate value for this field. |
permissions |
System.Collections.Generic.IEnumerable<System.String>The set of permissions to check for the |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Google.Cloud.Iam.V1.TestIamPermissionsResponse> |
A Task containing the RPC response. |
UpdateSnapshot(UpdateSnapshotRequest, CallSettings)
public virtual Snapshot UpdateSnapshot(UpdateSnapshotRequest request, CallSettings callSettings = null)Updates an existing snapshot. Snapshots are used in <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
request |
UpdateSnapshotRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Snapshot |
The RPC response. |
UpdateSnapshotAsync(UpdateSnapshotRequest, CallSettings)
public virtual Task<Snapshot> UpdateSnapshotAsync(UpdateSnapshotRequest request, CallSettings callSettings = null)Updates an existing snapshot. Snapshots are used in <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
request |
UpdateSnapshotRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
UpdateSnapshotAsync(UpdateSnapshotRequest, CancellationToken)
public virtual Task<Snapshot> UpdateSnapshotAsync(UpdateSnapshotRequest request, CancellationToken cancellationToken)Updates an existing snapshot. Snapshots are used in <a href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment state of messages in an existing subscription to the state captured by a snapshot.
| Parameters | |
|---|---|
| Name | Description |
request |
UpdateSnapshotRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Snapshot> |
A Task containing the RPC response. |
UpdateSubscription(UpdateSubscriptionRequest, CallSettings)
public virtual Subscription UpdateSubscription(UpdateSubscriptionRequest request, CallSettings callSettings = null)Updates an existing subscription. Note that certain properties of a subscription, such as its topic, are not modifiable.
| Parameters | |
|---|---|
| Name | Description |
request |
UpdateSubscriptionRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
Subscription |
The RPC response. |
UpdateSubscriptionAsync(UpdateSubscriptionRequest, CallSettings)
public virtual Task<Subscription> UpdateSubscriptionAsync(UpdateSubscriptionRequest request, CallSettings callSettings = null)Updates an existing subscription. Note that certain properties of a subscription, such as its topic, are not modifiable.
| Parameters | |
|---|---|
| Name | Description |
request |
UpdateSubscriptionRequestThe request object containing all of the parameters for the API call. |
callSettings |
Google.Api.Gax.Grpc.CallSettingsIf not null, applies overrides to this RPC call. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |
UpdateSubscriptionAsync(UpdateSubscriptionRequest, CancellationToken)
public virtual Task<Subscription> UpdateSubscriptionAsync(UpdateSubscriptionRequest request, CancellationToken cancellationToken)Updates an existing subscription. Note that certain properties of a subscription, such as its topic, are not modifiable.
| Parameters | |
|---|---|
| Name | Description |
request |
UpdateSubscriptionRequestThe request object containing all of the parameters for the API call. |
cancellationToken |
System.Threading.CancellationTokenA System.Threading.CancellationToken to use for this RPC. |
| Returns | |
|---|---|
| Type | Description |
System.Threading.Tasks.Task<Subscription> |
A Task containing the RPC response. |