| /dports/net/grpcurl/grpcurl-1.8.5/vendor/cloud.google.com/go/pubsub/pstest/ |
| H A D | fake_test.go | 354 req.AckIds = append(req.AckIds, m.AckId)
386 AckIds: ackIDs,
425 AckIds: ackIDs,
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/gcppubsub/ |
| H A D | gcppubsub.go | 482 return s.client.Acknowledge(ctx, &pb.AcknowledgeRequest{Subscription: s.path, AckIds: ids2})
496 AckIds: ids2,
|
| /dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/cloud.google.com/go/google-cloud-go-0.72.0/pubsub/ |
| H A D | iterator.go | 402 AckIds: ids,
469 AckIds: ids,
|
| /dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 402 AckIds: ids,
469 AckIds: ids,
|
| /dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/sysutils/restic/google-cloud-go-storage-v1.16.0/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/sysutils/restic/restic-0.12.1/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/databases/litestream/litestream-0.3.6/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/databases/litestream/google-cloud-go-storage-v1.15.0/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/www/tusd/tusd-1.8.0/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/www/tusd/google-cloud-go-storage-v1.18.2/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/www/grafana8/google-cloud-go-storage-v1.14.0/pubsub/ |
| H A D | iterator.go | 405 AckIds: ids,
472 AckIds: ids,
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/cloud.google.com/go/pubsub/ |
| H A D | iterator.go | 407 AckIds: ids,
474 AckIds: ids,
|
| /dports/sysutils/docker-registry/distribution-2.7.1/vendor/cloud.google.com/go/pubsub/ |
| H A D | pullstream.go | 146 recordStat(s.ctx, AckCount, int64(len(req.AckIds)))
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/cloud.google.com/go/pubsub/ |
| H A D | pullstream.go | 153 recordStat(s.ctx, AckCount, int64(len(req.AckIds)))
|
| /dports/www/gohugo/google-cloud-go-storage-v1.10.0/pubsub/pstest/ |
| H A D | fake.go | 632 for _, id := range req.AckIds {
646 for _, id := range req.AckIds {
650 for _, id := range req.AckIds {
996 for _, ackID := range req.AckIds {
|
| H A D | fake_test.go | 391 req.AckIds = append(req.AckIds, m.AckId)
423 AckIds: ackIDs,
462 AckIds: ackIDs,
|
| /dports/devel/gitlab-runner/google-cloud-go-storage-v1.12.0/pubsub/pstest/ |
| H A D | fake.go | 653 for _, id := range req.AckIds {
667 for _, id := range req.AckIds {
671 for _, id := range req.AckIds {
1017 for _, ackID := range req.AckIds {
|