Home
last modified time | relevance | path

Searched refs:pubClient (Results 1 – 25 of 72) sorted by relevance

123

/dports/www/grafana8/google-cloud-go-storage-v1.14.0/pubsublite/pscompat/
H A Dpublisher_test.go135 pubClient := newTestPublisherClient(verifier, settings)
136 result := pubClient.Publish(ctx, input)
165 pubClient := newTestPublisherClient(verifier, settings)
166 result := pubClient.Publish(ctx, input)
172 if !test.ErrorEqual(pubClient.Error(), wantErr) {
173 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
175 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
222 pubClient := newTestPublisherClient(verifier, DefaultPublishSettings)
223 result := pubClient.Publish(ctx, input)
229 if !test.ErrorEqual(pubClient.Error(), tc.wireErr) {
[all …]
/dports/sysutils/terraform/terraform-1.0.11/vendor/cloud.google.com/go/pubsublite/pscompat/
H A Dpublisher_test.go135 pubClient := newTestPublisherClient(verifier, settings)
136 result := pubClient.Publish(ctx, input)
165 pubClient := newTestPublisherClient(verifier, settings)
166 result := pubClient.Publish(ctx, input)
172 if !test.ErrorEqual(pubClient.Error(), wantErr) {
173 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
175 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
222 pubClient := newTestPublisherClient(verifier, DefaultPublishSettings)
223 result := pubClient.Publish(ctx, input)
229 if !test.ErrorEqual(pubClient.Error(), tc.wireErr) {
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/sysutils/restic/google-cloud-go-storage-v1.16.0/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/sysutils/restic/restic-0.12.1/vendor/cloud.google.com/go/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/databases/litestream/litestream-0.3.6/vendor/cloud.google.com/go/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/www/tusd/tusd-1.8.0/vendor/cloud.google.com/go/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/www/tusd/google-cloud-go-storage-v1.18.2/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/databases/litestream/google-cloud-go-storage-v1.15.0/pubsublite/pscompat/
H A Dpublisher_test.go133 pubClient := newTestPublisherClient(verifier, settings)
134 result := pubClient.Publish(ctx, input)
163 pubClient := newTestPublisherClient(verifier, settings)
164 result := pubClient.Publish(ctx, input)
170 if !test.ErrorEqual(pubClient.Error(), wantErr) {
171 t.Errorf("PublisherClient.Error() got: (%v), want: (%v)", pubClient.Error(), wantErr)
173 if got, want := pubClient.wirePub.(*mockWirePublisher).Stopped, true; got != want {
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/gcppubsub/
H A Dgcppubsub_test.go42 pubClient *raw.PublisherClient member
50 pubClient, err := PublisherClient(ctx, conn)
58 …return &harness{closer: done, pubClient: pubClient, subClient: subClient, numTopics: 0, numSubs: 0…
69 dt, cleanup, err := createTopic(ctx, h.pubClient, topicName, topicPath)
72 h.pubClient.DeleteTopic(ctx, &pubsubpb.DeleteTopicRequest{Topic: topicPath})
79 func createTopic(ctx context.Context, pubClient *raw.PublisherClient, topicName, topicPath string) …
80 _, err = pubClient.CreateTopic(ctx, &pubsubpb.Topic{Name: topicPath})
84 dt = openTopic(pubClient, path.Join("projects", projectID, "topics", topicName))
86 pubClient.DeleteTopic(ctx, &pubsubpb.DeleteTopicRequest{Topic: topicPath})
92 return openTopic(h.pubClient, path.Join("projects", projectID, "topics", "nonexistent-topic")), nil
[all …]
/dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/gcppubsub/
H A Dgcppubsub_test.go42 pubClient *raw.PublisherClient member
50 pubClient, err := PublisherClient(ctx, conn)
58 …return &harness{closer: done, pubClient: pubClient, subClient: subClient, numTopics: 0, numSubs: 0…
69 dt, cleanup, err := createTopic(ctx, h.pubClient, topicName, topicPath)
72 h.pubClient.DeleteTopic(ctx, &pubsubpb.DeleteTopicRequest{Topic: topicPath})
79 func createTopic(ctx context.Context, pubClient *raw.PublisherClient, topicName, topicPath string) …
80 _, err = pubClient.CreateTopic(ctx, &pubsubpb.Topic{Name: topicPath})
84 dt = openTopic(pubClient, path.Join("projects", projectID, "topics", topicName))
86 pubClient.DeleteTopic(ctx, &pubsubpb.DeleteTopicRequest{Topic: topicPath})
92 return openTopic(h.pubClient, path.Join("projects", projectID, "topics", "nonexistent-topic")), nil
[all …]
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/gcppubsub/
H A Dgcppubsub_test.go42 pubClient *raw.PublisherClient member
50 pubClient, err := PublisherClient(ctx, conn)
58 …return &harness{closer: done, pubClient: pubClient, subClient: subClient, numTopics: 0, numSubs: 0…
69 dt, cleanup, err := createTopic(ctx, h.pubClient, topicName, topicPath)
72 h.pubClient.DeleteTopic(ctx, &pubsubpb.DeleteTopicRequest{Topic: topicPath})
79 func createTopic(ctx context.Context, pubClient *raw.PublisherClient, topicName, topicPath string) …
80 _, err = pubClient.CreateTopic(ctx, &pubsubpb.Topic{Name: topicPath})
84 dt = openTopic(pubClient, path.Join("projects", projectID, "topics", topicName))
86 pubClient.DeleteTopic(ctx, &pubsubpb.DeleteTopicRequest{Topic: topicPath})
92 return openTopic(h.pubClient, path.Join("projects", projectID, "topics", "nonexistent-topic")), nil
[all …]
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/gcppubsub/
H A Dgcppubsub_test.go42 pubClient *raw.PublisherClient member
50 pubClient, err := PublisherClient(ctx, conn)
58 …return &harness{closer: done, pubClient: pubClient, subClient: subClient, numTopics: 0, numSubs: 0…
69 dt, cleanup, err := createTopic(ctx, h.pubClient, topicName, topicPath)
72 h.pubClient.DeleteTopic(ctx, &pubsubpb.DeleteTopicRequest{Topic: topicPath})
79 func createTopic(ctx context.Context, pubClient *raw.PublisherClient, topicName, topicPath string) …
80 _, err = pubClient.CreateTopic(ctx, &pubsubpb.Topic{Name: topicPath})
84 dt = openTopic(pubClient, path.Join("projects", projectID, "topics", topicName))
86 pubClient.DeleteTopic(ctx, &pubsubpb.DeleteTopicRequest{Topic: topicPath})
92 return openTopic(h.pubClient, path.Join("projects", projectID, "topics", "nonexistent-topic")), nil
[all …]
/dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/pubsublite/internal/wire/
H A Dpublisher.go54 pubClient *vkit.PublisherClient member
71 pubClient *vkit.PublisherClient member
78 pubClient: f.pubClient,
146 return pp.pubClient.Publish(pp.metadata.AddToContext(ctx))
383 pubClient, err := newPublisherClient(ctx, region, opts...)
387 allClients = append(allClients, pubClient)
399 pubClient: pubClient,
/dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/pubsublite/internal/wire/
H A Dpublisher.go54 pubClient *vkit.PublisherClient member
71 pubClient *vkit.PublisherClient member
78 pubClient: f.pubClient,
146 return pp.pubClient.Publish(pp.metadata.AddToContext(ctx))
383 pubClient, err := newPublisherClient(ctx, region, opts...)
387 allClients = append(allClients, pubClient)
399 pubClient: pubClient,
/dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/pubsublite/internal/wire/
H A Dpublisher.go54 pubClient *vkit.PublisherClient member
71 pubClient *vkit.PublisherClient member
78 pubClient: f.pubClient,
146 return pp.pubClient.Publish(pp.metadata.AddToContext(ctx))
383 pubClient, err := newPublisherClient(ctx, region, opts...)
387 allClients = append(allClients, pubClient)
399 pubClient: pubClient,
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/pubsublite/internal/wire/
H A Dpublisher.go54 pubClient *vkit.PublisherClient member
71 pubClient *vkit.PublisherClient member
78 pubClient: f.pubClient,
146 return pp.pubClient.Publish(pp.metadata.AddToContext(ctx))
383 pubClient, err := newPublisherClient(ctx, region, opts...)
387 allClients = append(allClients, pubClient)
399 pubClient: pubClient,
/dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/pubsublite/internal/wire/
H A Dpublisher.go54 pubClient *vkit.PublisherClient member
71 pubClient *vkit.PublisherClient member
78 pubClient: f.pubClient,
146 return pp.pubClient.Publish(pp.metadata.AddToContext(ctx))
383 pubClient, err := newPublisherClient(ctx, region, opts...)
387 allClients = append(allClients, pubClient)
399 pubClient: pubClient,

123