| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 106 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
187 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
204 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
226 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
271 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
279 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
290 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
297 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
450 res, err := t.c.pubc.Publish(ctx, &pb.PublishRequest{
|
| /dports/www/grafana8/google-cloud-go-storage-v1.14.0/pubsub/ |
| H A D | topic.go | 128 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
146 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
236 _, err := c.pubc.DetachSubscription(ctx, &pb.DetachSubscriptionRequest{
281 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
295 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
321 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
366 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
374 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
386 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
393 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 128 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
146 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
236 _, err := c.pubc.DetachSubscription(ctx, &pb.DetachSubscriptionRequest{
281 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
295 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
321 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
366 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
374 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
386 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
393 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
[all …]
|
| /dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 128 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
146 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
242 _, err := c.pubc.DetachSubscription(ctx, &pb.DetachSubscriptionRequest{
287 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
301 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
327 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
372 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
380 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
392 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
399 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 128 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
146 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
242 _, err := c.pubc.DetachSubscription(ctx, &pb.DetachSubscriptionRequest{
287 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
301 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
327 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
372 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
380 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
392 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
399 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
[all …]
|
| /dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 128 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
146 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
242 _, err := c.pubc.DetachSubscription(ctx, &pb.DetachSubscriptionRequest{
287 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
301 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
327 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
372 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
380 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
392 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
399 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
[all …]
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 128 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
146 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
236 _, err := c.pubc.DetachSubscription(ctx, &pb.DetachSubscriptionRequest{
281 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
295 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
321 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
366 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
374 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
386 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
393 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
[all …]
|
| /dports/sysutils/restic/restic-0.12.1/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 128 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
146 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
236 _, err := c.pubc.DetachSubscription(ctx, &pb.DetachSubscriptionRequest{
281 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
295 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
321 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
366 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
374 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
386 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
393 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
[all …]
|
| /dports/sysutils/restic/google-cloud-go-storage-v1.16.0/pubsub/ |
| H A D | topic.go | 128 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
146 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
236 _, err := c.pubc.DetachSubscription(ctx, &pb.DetachSubscriptionRequest{
281 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
295 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
321 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
366 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
374 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
386 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
393 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
[all …]
|
| /dports/databases/litestream/litestream-0.3.6/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 128 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
146 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
236 _, err := c.pubc.DetachSubscription(ctx, &pb.DetachSubscriptionRequest{
281 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
295 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
321 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
366 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
374 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
386 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
393 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
[all …]
|
| /dports/databases/litestream/google-cloud-go-storage-v1.15.0/pubsub/ |
| H A D | topic.go | 128 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
146 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
236 _, err := c.pubc.DetachSubscription(ctx, &pb.DetachSubscriptionRequest{
281 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
295 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
321 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
366 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
374 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
386 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
393 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
[all …]
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 128 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
146 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
236 _, err := c.pubc.DetachSubscription(ctx, &pb.DetachSubscriptionRequest{
281 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
295 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
321 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
366 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
374 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
386 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
393 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/golang/gddo/vendor/cloud.google.com/go/pubsub/ |
| H A D | service.go | 89 pubc *vkit.PublisherClient member
94 pubc, err := vkit.NewPublisherClient(ctx, opts...)
100 _ = pubc.Close() // ignore error
103 pubc.SetGoogleClientInfo("gccl", version.Repo)
105 return &apiService{pubc: pubc, subc: subc}, nil
110 err := s.pubc.Close()
198 _, err := s.pubc.CreateTopic(ctx, &pb.Topic{Name: name})
203 it := s.pubc.ListTopics(ctx, &pb.ListTopicsRequest{
220 _, err := s.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: name})
313 resp, err := s.pubc.Publish(ctx, &pb.PublishRequest{
[all …]
|
| /dports/www/miniflux/v2-2.0.35/vendor/github.com/golang/gddo/vendor/cloud.google.com/go/pubsub/ |
| H A D | service.go | 89 pubc *vkit.PublisherClient member
94 pubc, err := vkit.NewPublisherClient(ctx, opts...)
100 _ = pubc.Close() // ignore error
103 pubc.SetGoogleClientInfo("gccl", version.Repo)
105 return &apiService{pubc: pubc, subc: subc}, nil
110 err := s.pubc.Close()
198 _, err := s.pubc.CreateTopic(ctx, &pb.Topic{Name: name})
203 it := s.pubc.ListTopics(ctx, &pb.ListTopicsRequest{
220 _, err := s.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: name})
313 resp, err := s.pubc.Publish(ctx, &pb.PublishRequest{
[all …]
|
| /dports/sysutils/jest/jest-f76bc46/vendor/github.com/golang/gddo/vendor/cloud.google.com/go/pubsub/ |
| H A D | service.go | 89 pubc *vkit.PublisherClient member
94 pubc, err := vkit.NewPublisherClient(ctx, opts...)
100 _ = pubc.Close() // ignore error
103 pubc.SetGoogleClientInfo("gccl", version.Repo)
105 return &apiService{pubc: pubc, subc: subc}, nil
110 err := s.pubc.Close()
198 _, err := s.pubc.CreateTopic(ctx, &pb.Topic{Name: name})
203 it := s.pubc.ListTopics(ctx, &pb.ListTopicsRequest{
220 _, err := s.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: name})
313 resp, err := s.pubc.Publish(ctx, &pb.PublishRequest{
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 121 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
139 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
256 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
270 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
296 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
341 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
349 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
361 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
368 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
537 res, err := t.c.pubc.Publish(ctx, &pb.PublishRequest{
|
| /dports/net/storj/storj-1.45.3/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 121 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
139 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
256 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
270 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
296 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
341 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
349 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
361 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
368 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
537 res, err := t.c.pubc.Publish(ctx, &pb.PublishRequest{
|
| /dports/sysutils/istio/istio-1.6.7/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 121 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
139 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
256 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
270 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
296 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
341 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
349 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
361 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
368 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
537 res, err := t.c.pubc.Publish(ctx, &pb.PublishRequest{
|
| /dports/sysutils/chaoskube/chaoskube-0.22.0/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 121 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
139 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
256 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
270 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
296 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
341 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
349 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
361 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
368 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
537 res, err := t.c.pubc.Publish(ctx, &pb.PublishRequest{
|
| /dports/security/lego/lego-4.5.3/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 121 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
139 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
256 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
270 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
296 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
341 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
349 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
361 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
368 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
537 res, err := t.c.pubc.Publish(ctx, &pb.PublishRequest{
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 121 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
139 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
256 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
270 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
296 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
341 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
349 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
361 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
368 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
537 res, err := t.c.pubc.Publish(ctx, &pb.PublishRequest{
|
| /dports/security/vault/google-cloud-go-storage-v1.6.0/pubsub/ |
| H A D | topic.go | 121 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
139 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
256 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
270 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
296 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
341 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
349 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
361 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
368 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
537 res, err := t.c.pubc.Publish(ctx, &pb.PublishRequest{
|
| /dports/sysutils/helm/helm-3.5.2/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 121 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
139 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
256 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
270 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
296 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
341 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
349 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
361 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
368 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
537 res, err := t.c.pubc.Publish(ctx, &pb.PublishRequest{
|
| /dports/misc/concourse/concourse-6.7.2/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 121 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
139 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{
256 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
270 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
296 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
341 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
349 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
361 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
368 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
537 res, err := t.c.pubc.Publish(ctx, &pb.PublishRequest{
|
| /dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/pubsub/ |
| H A D | topic.go | 130 _, err := c.pubc.CreateTopic(ctx, &pb.Topic{Name: t.name})
150 _, err := c.pubc.CreateTopic(ctx, topic)
276 _, err := c.pubc.DetachSubscription(ctx, &pb.DetachSubscriptionRequest{
321 pbt, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
335 rpt, err := t.c.pubc.UpdateTopic(ctx, req)
370 it := c.pubc.ListTopics(ctx, &pb.ListTopicsRequest{Project: c.fullyQualifiedProjectName()})
415 return t.c.pubc.DeleteTopic(ctx, &pb.DeleteTopicRequest{Topic: t.name})
423 _, err := t.c.pubc.GetTopic(ctx, &pb.GetTopicRequest{Topic: t.name})
435 return iam.InternalNewHandle(t.c.pubc.Connection(), t.name)
442 it := t.c.pubc.ListTopicSubscriptions(ctx, &pb.ListTopicSubscriptionsRequest{
[all …]
|