Versions in this module Expand all Collapse all v0 v0.26.0 Dec 20, 2021 Changes in this version + func RunBenchmarks(b *testing.B, topic *pubsub.Topic, sub *pubsub.Subscription) + func RunConformanceTests(t *testing.T, newHarness HarnessMaker, asTests []AsTest) + type AsTest interface + AfterSend func(as func(interface{}) bool) error + BeforeSend func(as func(interface{}) bool) error + MessageCheck func(m *pubsub.Message) error + Name func() string + SubscriptionCheck func(s *pubsub.Subscription) error + SubscriptionErrorCheck func(s *pubsub.Subscription, err error) error + TopicCheck func(t *pubsub.Topic) error + TopicErrorCheck func(t *pubsub.Topic, err error) error + type Harness interface + Close func() + CreateSubscription func(ctx context.Context, t driver.Topic, testName string) (ds driver.Subscription, cleanup func(), err error) + CreateTopic func(ctx context.Context, testName string) (dt driver.Topic, cleanup func(), err error) + MakeNonexistentSubscription func(ctx context.Context) (ds driver.Subscription, cleanup func(), err error) + MakeNonexistentTopic func(ctx context.Context) (driver.Topic, error) + MaxBatchSizes func() (int, int) + SupportsMultipleSubscriptions func() bool + type HarnessMaker func(ctx context.Context, t *testing.T) (Harness, error)
Go to main page