| /dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 345 verifiers.AddSubscribeStream(subscription.Path, subscription.Partition, stream)
974 verifiers.AddSubscribeStream(subscription, 1, subStream1)
986 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1022 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1034 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1147 verifiers.AddSubscribeStream(subscription, 3, subStream3)
1161 verifiers.AddSubscribeStream(subscription, 6, subStream6)
1172 verifiers.AddSubscribeStream(subscription, 8, subStream8)
1237 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1248 verifiers.AddSubscribeStream(subscription, 2, subStream2)
[all …]
|
| /dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 345 verifiers.AddSubscribeStream(subscription.Path, subscription.Partition, stream)
974 verifiers.AddSubscribeStream(subscription, 1, subStream1)
986 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1022 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1034 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1147 verifiers.AddSubscribeStream(subscription, 3, subStream3)
1161 verifiers.AddSubscribeStream(subscription, 6, subStream6)
1172 verifiers.AddSubscribeStream(subscription, 8, subStream8)
1237 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1248 verifiers.AddSubscribeStream(subscription, 2, subStream2)
[all …]
|
| /dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 345 verifiers.AddSubscribeStream(subscription.Path, subscription.Partition, stream)
974 verifiers.AddSubscribeStream(subscription, 1, subStream1)
986 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1022 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1034 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1147 verifiers.AddSubscribeStream(subscription, 3, subStream3)
1161 verifiers.AddSubscribeStream(subscription, 6, subStream6)
1172 verifiers.AddSubscribeStream(subscription, 8, subStream8)
1233 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1244 verifiers.AddSubscribeStream(subscription, 2, subStream2)
[all …]
|
| /dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 345 verifiers.AddSubscribeStream(subscription.Path, subscription.Partition, stream)
974 verifiers.AddSubscribeStream(subscription, 1, subStream1)
986 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1022 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1034 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1147 verifiers.AddSubscribeStream(subscription, 3, subStream3)
1161 verifiers.AddSubscribeStream(subscription, 6, subStream6)
1172 verifiers.AddSubscribeStream(subscription, 8, subStream8)
1237 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1248 verifiers.AddSubscribeStream(subscription, 2, subStream2)
[all …]
|
| /dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 345 verifiers.AddSubscribeStream(subscription.Path, subscription.Partition, stream)
974 verifiers.AddSubscribeStream(subscription, 1, subStream1)
986 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1022 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1034 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1147 verifiers.AddSubscribeStream(subscription, 3, subStream3)
1161 verifiers.AddSubscribeStream(subscription, 6, subStream6)
1172 verifiers.AddSubscribeStream(subscription, 8, subStream8)
1233 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1244 verifiers.AddSubscribeStream(subscription, 2, subStream2)
[all …]
|
| /dports/sysutils/restic/google-cloud-go-storage-v1.16.0/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 345 verifiers.AddSubscribeStream(subscription.Path, subscription.Partition, stream)
974 verifiers.AddSubscribeStream(subscription, 1, subStream1)
986 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1022 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1034 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1147 verifiers.AddSubscribeStream(subscription, 3, subStream3)
1161 verifiers.AddSubscribeStream(subscription, 6, subStream6)
1172 verifiers.AddSubscribeStream(subscription, 8, subStream8)
1233 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1244 verifiers.AddSubscribeStream(subscription, 2, subStream2)
[all …]
|
| /dports/www/tusd/tusd-1.8.0/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 345 verifiers.AddSubscribeStream(subscription.Path, subscription.Partition, stream)
974 verifiers.AddSubscribeStream(subscription, 1, subStream1)
986 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1022 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1034 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1147 verifiers.AddSubscribeStream(subscription, 3, subStream3)
1161 verifiers.AddSubscribeStream(subscription, 6, subStream6)
1172 verifiers.AddSubscribeStream(subscription, 8, subStream8)
1237 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1248 verifiers.AddSubscribeStream(subscription, 2, subStream2)
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 345 verifiers.AddSubscribeStream(subscription.Path, subscription.Partition, stream)
974 verifiers.AddSubscribeStream(subscription, 1, subStream1)
986 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1022 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1034 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1147 verifiers.AddSubscribeStream(subscription, 3, subStream3)
1161 verifiers.AddSubscribeStream(subscription, 6, subStream6)
1172 verifiers.AddSubscribeStream(subscription, 8, subStream8)
1233 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1244 verifiers.AddSubscribeStream(subscription, 2, subStream2)
[all …]
|
| /dports/sysutils/restic/restic-0.12.1/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 331 verifiers.AddSubscribeStream(subscription.Path, subscription.Partition, stream)
793 verifiers.AddSubscribeStream(subscription, 1, subStream1)
805 verifiers.AddSubscribeStream(subscription, 2, subStream2)
841 verifiers.AddSubscribeStream(subscription, 1, subStream1)
853 verifiers.AddSubscribeStream(subscription, 2, subStream2)
955 verifiers.AddSubscribeStream(subscription, 3, subStream3)
969 verifiers.AddSubscribeStream(subscription, 6, subStream6)
980 verifiers.AddSubscribeStream(subscription, 8, subStream8)
1041 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1052 verifiers.AddSubscribeStream(subscription, 2, subStream2)
[all …]
|
| /dports/www/tusd/google-cloud-go-storage-v1.18.2/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 989 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1001 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1040 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1052 verifiers.AddSubscribeStream(subscription, 2, subStream2)
1157 verifiers.AddSubscribeStream(subscription, 3, subStream3)
1171 verifiers.AddSubscribeStream(subscription, 6, subStream6)
1182 verifiers.AddSubscribeStream(subscription, 8, subStream8)
1245 verifiers.AddSubscribeStream(subscription, 1, subStream1)
1299 verifiers.AddSubscribeStream(subscription, 1, subStream)
1356 verifiers.AddSubscribeStream(subscription, 1, subStream)
[all …]
|
| /dports/www/grafana8/google-cloud-go-storage-v1.14.0/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 692 verifiers.AddSubscribeStream(subscription, 1, subStream1)
704 verifiers.AddSubscribeStream(subscription, 2, subStream2)
740 verifiers.AddSubscribeStream(subscription, 1, subStream1)
752 verifiers.AddSubscribeStream(subscription, 2, subStream2)
854 verifiers.AddSubscribeStream(subscription, 3, subStream3)
868 verifiers.AddSubscribeStream(subscription, 6, subStream6)
879 verifiers.AddSubscribeStream(subscription, 8, subStream8)
940 verifiers.AddSubscribeStream(subscription, 1, subStream1)
951 verifiers.AddSubscribeStream(subscription, 2, subStream2)
994 verifiers.AddSubscribeStream(subscription, 1, subStream1)
[all …]
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 692 verifiers.AddSubscribeStream(subscription, 1, subStream1)
704 verifiers.AddSubscribeStream(subscription, 2, subStream2)
740 verifiers.AddSubscribeStream(subscription, 1, subStream1)
752 verifiers.AddSubscribeStream(subscription, 2, subStream2)
854 verifiers.AddSubscribeStream(subscription, 3, subStream3)
868 verifiers.AddSubscribeStream(subscription, 6, subStream6)
879 verifiers.AddSubscribeStream(subscription, 8, subStream8)
940 verifiers.AddSubscribeStream(subscription, 1, subStream1)
951 verifiers.AddSubscribeStream(subscription, 2, subStream2)
994 verifiers.AddSubscribeStream(subscription, 1, subStream1)
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 279 verifiers.AddSubscribeStream(subscription.Path, subscription.Partition, stream)
692 verifiers.AddSubscribeStream(subscription, 1, subStream1)
704 verifiers.AddSubscribeStream(subscription, 2, subStream2)
740 verifiers.AddSubscribeStream(subscription, 1, subStream1)
752 verifiers.AddSubscribeStream(subscription, 2, subStream2)
854 verifiers.AddSubscribeStream(subscription, 3, subStream3)
868 verifiers.AddSubscribeStream(subscription, 6, subStream6)
879 verifiers.AddSubscribeStream(subscription, 8, subStream8)
940 verifiers.AddSubscribeStream(subscription, 1, subStream1)
951 verifiers.AddSubscribeStream(subscription, 2, subStream2)
[all …]
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 279 verifiers.AddSubscribeStream(subscription.Path, subscription.Partition, stream)
692 verifiers.AddSubscribeStream(subscription, 1, subStream1)
704 verifiers.AddSubscribeStream(subscription, 2, subStream2)
740 verifiers.AddSubscribeStream(subscription, 1, subStream1)
752 verifiers.AddSubscribeStream(subscription, 2, subStream2)
854 verifiers.AddSubscribeStream(subscription, 3, subStream3)
868 verifiers.AddSubscribeStream(subscription, 6, subStream6)
879 verifiers.AddSubscribeStream(subscription, 8, subStream8)
940 verifiers.AddSubscribeStream(subscription, 1, subStream1)
951 verifiers.AddSubscribeStream(subscription, 2, subStream2)
[all …]
|
| /dports/databases/litestream/litestream-0.3.6/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 279 verifiers.AddSubscribeStream(subscription.Path, subscription.Partition, stream)
692 verifiers.AddSubscribeStream(subscription, 1, subStream1)
704 verifiers.AddSubscribeStream(subscription, 2, subStream2)
740 verifiers.AddSubscribeStream(subscription, 1, subStream1)
752 verifiers.AddSubscribeStream(subscription, 2, subStream2)
854 verifiers.AddSubscribeStream(subscription, 3, subStream3)
868 verifiers.AddSubscribeStream(subscription, 6, subStream6)
879 verifiers.AddSubscribeStream(subscription, 8, subStream8)
940 verifiers.AddSubscribeStream(subscription, 1, subStream1)
951 verifiers.AddSubscribeStream(subscription, 2, subStream2)
[all …]
|
| /dports/databases/litestream/google-cloud-go-storage-v1.15.0/pubsublite/internal/wire/ |
| H A D | subscriber_test.go | 279 verifiers.AddSubscribeStream(subscription.Path, subscription.Partition, stream)
692 verifiers.AddSubscribeStream(subscription, 1, subStream1)
704 verifiers.AddSubscribeStream(subscription, 2, subStream2)
740 verifiers.AddSubscribeStream(subscription, 1, subStream1)
752 verifiers.AddSubscribeStream(subscription, 2, subStream2)
854 verifiers.AddSubscribeStream(subscription, 3, subStream3)
868 verifiers.AddSubscribeStream(subscription, 6, subStream6)
879 verifiers.AddSubscribeStream(subscription, 8, subStream8)
940 verifiers.AddSubscribeStream(subscription, 1, subStream1)
951 verifiers.AddSubscribeStream(subscription, 2, subStream2)
[all …]
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/cloud.google.com/go/google-cloud-go-0.72.0/pubsublite/internal/test/ |
| H A D | mock.go | 51 AddSubscribeStream(subscription string, partition int, streamVerifier *RPCVerifier)
236 func (s *mockLiteServer) AddSubscribeStream(subscription string, partition int, streamVerifier *RPC…
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/cloud.google.com/go/pubsublite/internal/test/ |
| H A D | mock.go | 51 AddSubscribeStream(subscription string, partition int, streamVerifier *RPCVerifier) methodSpec
236 func (s *mockLiteServer) AddSubscribeStream(subscription string, partition int, streamVerifier *RPC… func
|
| /dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/pubsublite/internal/test/ |
| H A D | verifier.go | 353 func (tv *Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier *RPCVeri… func
|
| /dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/pubsublite/internal/test/ |
| H A D | verifier.go | 353 func (tv *Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier *RPCVeri… func
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsublite/internal/test/ |
| H A D | verifier.go | 343 func (tv *Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier *RPCVeri… func
|
| /dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/pubsublite/internal/test/ |
| H A D | verifier.go | 353 func (tv *Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier *RPCVeri… func
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/pubsublite/internal/test/ |
| H A D | verifier.go | 353 func (tv *Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier *RPCVeri… func
|
| /dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/pubsublite/internal/test/ |
| H A D | verifier.go | 353 func (tv *Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier *RPCVeri… func
|
| /dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/pubsublite/internal/test/ |
| H A D | verifier.go | 353 func (tv *Verifiers) AddSubscribeStream(subscription string, partition int, streamVerifier *RPCVeri… func
|