Function TestCloudPubSub

pkg/events/cloud/cloud_test.go:49–79

(t *testing.T)

var timeout = (1 << 10) * test.Delay

func TestCloudPubSub(t *testing.T) { //nolint:paralleltest
	events.IncludeCaller = true

	taskStarter := task.StartTaskFunc(task.DefaultStartTask)

	test.RunSubtest(t, test.SubtestConfig{
		Name:    "json",
		Timeout: 10 * timeout,
		Func: func(ctx context.Context, t *testing.T, a *assertions.Assertion) {
			t.Helper()
			pubsub, err := cloud.NewPubSub(ctx, taskStarter, "mem://json_events_test", "mem://json_events_test")
			a.So(err, should.BeNil)
			defer pubsub.Close(ctx)
			cloud.SetContentType(pubsub, "application/json")
			eventstest.TestBackend(ctx, t, a, pubsub)
		},
	})

	test.RunSubtest(t, test.SubtestConfig{
		Name:    "protobuf",
		Timeout: 10 * timeout,
		Func: func(ctx context.Context, t *testing.T, a *assertions.Assertion) {
			t.Helper()
			pubsub, err := cloud.NewPubSub(ctx, taskStarter, "mem://protobuf_events_test", "mem://protobuf_events_test")
			a.So(err, should.BeNil)
			defer pubsub.Close(ctx)
			cloud.SetContentType(pubsub, "application/protobuf")
			eventstest.TestBackend(ctx, t, a, pubsub)
		},
	})
}