| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/golang/gddo/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 132 subscriberClient pubsubpb.SubscriberClient member
154 subscriberClient: pubsubpb.NewSubscriberClient(conn),
258 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
349 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
367 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
383 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
410 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
430 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
451 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
526 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/www/miniflux/v2-2.0.35/vendor/github.com/golang/gddo/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 132 subscriberClient pubsubpb.SubscriberClient member
154 subscriberClient: pubsubpb.NewSubscriberClient(conn),
258 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
349 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
367 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
383 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
410 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
430 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
451 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
526 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/sysutils/docker-registry/distribution-2.7.1/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 143 subscriberClient pubsubpb.SubscriberClient member
166 subscriberClient: pubsubpb.NewSubscriberClient(conn),
225 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
314 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
332 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
347 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
369 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
389 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
414 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
498 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/sysutils/jest/jest-f76bc46/vendor/github.com/golang/gddo/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 132 subscriberClient pubsubpb.SubscriberClient member
154 subscriberClient: pubsubpb.NewSubscriberClient(conn),
258 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
349 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
367 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
383 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
410 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
430 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
451 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
526 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 135 subscriberClient pubsubpb.SubscriberClient member
158 subscriberClient: pubsubpb.NewSubscriberClient(conn),
225 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
314 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
332 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
348 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
370 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
390 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
415 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
499 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/misc/concourse/concourse-6.7.2/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 143 subscriberClient pubsubpb.SubscriberClient member
166 subscriberClient: pubsubpb.NewSubscriberClient(conn),
229 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
323 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
342 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
358 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
380 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
401 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
429 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
523 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/net/storj/storj-1.45.3/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 158 subscriberClient pubsubpb.SubscriberClient member
181 subscriberClient: pubsubpb.NewSubscriberClient(conn),
244 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
338 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
357 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
373 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
395 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
416 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
444 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
538 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 158 subscriberClient pubsubpb.SubscriberClient member
181 subscriberClient: pubsubpb.NewSubscriberClient(conn),
244 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
338 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
357 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
373 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
395 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
416 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
444 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
538 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/sysutils/istio/google-cloud-go-logging-v1.0.0/pubsub/apiv1/ |
| H A D | subscriber_client.go | 141 subscriberClient pubsubpb.SubscriberClient member
164 subscriberClient: pubsubpb.NewSubscriberClient(conn),
227 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
321 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
340 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
356 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
378 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
399 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
427 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
521 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 140 subscriberClient pubsubpb.SubscriberClient member
163 subscriberClient: pubsubpb.NewSubscriberClient(conn),
226 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
320 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
339 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
355 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
377 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
398 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
426 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
520 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/audio/gonic/gonic-0.8.4/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 140 subscriberClient pubsubpb.SubscriberClient member
163 subscriberClient: pubsubpb.NewSubscriberClient(conn),
226 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
320 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
339 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
355 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
377 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
398 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
426 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
520 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 158 subscriberClient pubsubpb.SubscriberClient member
181 subscriberClient: pubsubpb.NewSubscriberClient(conn),
244 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
338 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
357 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
373 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
395 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
416 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
444 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
538 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/security/vault/google-cloud-go-storage-v1.6.0/pubsub/apiv1/ |
| H A D | subscriber_client.go | 158 subscriberClient pubsubpb.SubscriberClient member
181 subscriberClient: pubsubpb.NewSubscriberClient(conn),
244 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
338 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
357 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
373 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
395 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
416 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
444 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
538 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/sysutils/go-wtf/wtf-0.21.0/vendor/cloud.google.com/go/google-cloud-go-0.40.0/pubsub/apiv1/ |
| H A D | subscriber_client.go | 140 subscriberClient pubsubpb.SubscriberClient member
163 subscriberClient: pubsubpb.NewSubscriberClient(conn),
226 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
320 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
339 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
355 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
377 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
398 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
426 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
520 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 140 subscriberClient pubsubpb.SubscriberClient member
163 subscriberClient: pubsubpb.NewSubscriberClient(conn),
226 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
319 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
338 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
354 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
376 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
397 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
428 resp, err = c.subscriberClient.ListSnapshots(ctx, req, settings.GRPC...)
532 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/sysutils/chaoskube/chaoskube-0.22.0/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 274 subscriberClient pubsubpb.SubscriberClient member
297 subscriberClient: pubsubpb.NewSubscriberClient(connPool),
363 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
459 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
478 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
494 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
516 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
537 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
555 resp, err = c.subscriberClient.GetSnapshot(ctx, req, settings.GRPC...)
686 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 274 subscriberClient pubsubpb.SubscriberClient member
297 subscriberClient: pubsubpb.NewSubscriberClient(connPool),
363 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
459 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
478 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
494 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
516 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
537 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
555 resp, err = c.subscriberClient.GetSnapshot(ctx, req, settings.GRPC...)
686 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/security/lego/lego-4.5.3/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 274 subscriberClient pubsubpb.SubscriberClient member
297 subscriberClient: pubsubpb.NewSubscriberClient(connPool),
363 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
459 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
478 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
494 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
516 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
537 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
555 resp, err = c.subscriberClient.GetSnapshot(ctx, req, settings.GRPC...)
686 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 274 subscriberClient pubsubpb.SubscriberClient member
297 subscriberClient: pubsubpb.NewSubscriberClient(connPool),
362 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
458 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
477 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
493 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
515 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
536 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
554 resp, err = c.subscriberClient.GetSnapshot(ctx, req, settings.GRPC...)
685 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/security/vault/google-cloud-go-spanner-v1.5.1/pubsub/apiv1/ |
| H A D | subscriber_client.go | 276 subscriberClient pubsubpb.SubscriberClient member
309 subscriberClient: pubsubpb.NewSubscriberClient(connPool),
374 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
470 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
489 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
505 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
527 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
548 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
566 resp, err = c.subscriberClient.GetSnapshot(ctx, req, settings.GRPC...)
697 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/www/gohugo/google-cloud-go-storage-v1.10.0/pubsub/apiv1/ |
| H A D | subscriber_client.go | 276 subscriberClient pubsubpb.SubscriberClient member
309 subscriberClient: pubsubpb.NewSubscriberClient(connPool),
374 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
470 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
489 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
505 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
527 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
548 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
566 resp, err = c.subscriberClient.GetSnapshot(ctx, req, settings.GRPC...)
697 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/sysutils/helm/helm-3.5.2/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 274 subscriberClient pubsubpb.SubscriberClient member
297 subscriberClient: pubsubpb.NewSubscriberClient(connPool),
363 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
459 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
478 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
494 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
516 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
537 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
555 resp, err = c.subscriberClient.GetSnapshot(ctx, req, settings.GRPC...)
686 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/www/pomerium/pomerium-0.8.3/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 274 subscriberClient pubsubpb.SubscriberClient member
297 subscriberClient: pubsubpb.NewSubscriberClient(connPool),
362 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
458 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
477 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
493 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
515 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
536 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
554 resp, err = c.subscriberClient.GetSnapshot(ctx, req, settings.GRPC...)
685 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/sysutils/helmfile/google-cloud-go-storage-v1.10.0/pubsub/apiv1/ |
| H A D | subscriber_client.go | 276 subscriberClient pubsubpb.SubscriberClient member
309 subscriberClient: pubsubpb.NewSubscriberClient(connPool),
374 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
470 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
489 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
505 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
527 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
548 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
566 resp, err = c.subscriberClient.GetSnapshot(ctx, req, settings.GRPC...)
697 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|
| /dports/net/grpcui/grpcui-1.1.0/vendor/cloud.google.com/go/pubsub/apiv1/ |
| H A D | subscriber_client.go | 274 subscriberClient pubsubpb.SubscriberClient member
297 subscriberClient: pubsubpb.NewSubscriberClient(connPool),
362 resp, err = c.subscriberClient.GetSubscription(ctx, req, settings.GRPC...)
458 _, err = c.subscriberClient.ModifyAckDeadline(ctx, req, settings.GRPC...)
477 _, err = c.subscriberClient.Acknowledge(ctx, req, settings.GRPC...)
493 resp, err = c.subscriberClient.Pull(ctx, req, settings.GRPC...)
515 resp, err = c.subscriberClient.StreamingPull(ctx, settings.GRPC...)
536 _, err = c.subscriberClient.ModifyPushConfig(ctx, req, settings.GRPC...)
554 resp, err = c.subscriberClient.GetSnapshot(ctx, req, settings.GRPC...)
685 _, err = c.subscriberClient.DeleteSnapshot(ctx, req, settings.GRPC...)
[all …]
|