Function TestOpenTopicFromURL

pubsub/gcppubsub/gcppubsub_test.go:375–407

(t *testing.T)

}

func TestOpenTopicFromURL(t *testing.T) {
	cleanup := setup.FakeGCPDefaultCredentials(t)
	defer cleanup()

	tests := []struct {
		URL     string
		WantErr bool
	}{
		// OK, short form.
		{"gcppubsub://myproject/mytopic", false},
		// OK, long form.
		{"gcppubsub://projects/myproject/topic/mytopic", false},
		// Invalid parameter.
		{"gcppubsub://myproject/mytopic?param=value", true},
		// Valid max_send_batch_size
		{"gcppubsub://projects/mytopic?max_send_batch_size=1", false},
		// Invalid max_send_batch_size
		{"gcppubsub://projects/mytopic?max_send_batch_size=0", true},
		// Invalid max_send_batch_size
		{"gcppubsub://projects/mytopic?max_send_batch_size=1001", true},
	}

	ctx := context.Background()
	for _, test := range tests {
		topic, err := pubsub.OpenTopic(ctx, test.URL)
		if (err != nil) != test.WantErr {
			t.Errorf("%s: got error %v, want error %v", test.URL, err, test.WantErr)
		}
		if topic != nil {
			topic.Shutdown(ctx)
		}
	}
}

func TestOpenSubscriptionFromURL(t *testing.T) {
	cleanup := setup.FakeGCPDefaultCredentials(t)