test

Documentation

Index

• func NewClient(ctx context.Context, projectID string, opts ...option.ClientOption) (pubsub.Client, error)
• type TestClient
  • func (c *TestClient) Close() error
  • func (c *TestClient) CreateSubscription(ctx context.Context, id string, cfg pubsub.SubscriptionConfig) (pubsub.Subscription, error)
  • func (c *TestClient) Subscription(id string) pubsub.Subscription
  • func (c *TestClient) Topic(id string) pubsub.Topic
• type TestSubscription
  • func (s *TestSubscription) Config(ctx context.Context) (pubsub.SubscriptionConfig, error)
  • func (s *TestSubscription) Delete(ctx context.Context) error
  • func (s *TestSubscription) Exists(ctx context.Context) (bool, error)
  • func (s *TestSubscription) Update(ctx context.Context, cfg pubsub.SubscriptionConfig) (pubsub.SubscriptionConfig, error)
• type TestTopic
  • func (t *TestTopic) Exists(ctx context.Context) (bool, error)

Functions

func NewClient

func NewClient(ctx context.Context, projectID string, opts ...option.ClientOption) (pubsub.Client, error)

NewClient creates a new test Pub/Sub client.

Types

type TestClient

type TestClient struct {
	Project string
}

TestClient is a test Pub/Sub client.

func (*TestClient) Close

func (c *TestClient) Close() error

Close implements client.Close

func (*TestClient) CreateSubscription

func (c *TestClient) CreateSubscription(ctx context.Context, id string, cfg pubsub.SubscriptionConfig) (pubsub.Subscription, error)

CreateSubscription implements Client.CreateSubscription.

func (*TestClient) Subscription

func (c *TestClient) Subscription(id string) pubsub.Subscription

Subscription implements Client.Subscription.

func (*TestClient) Topic

func (c *TestClient) Topic(id string) pubsub.Topic

Topic implements Client.Topic.

type TestSubscription

type TestSubscription struct {
	// contains filtered or unexported fields
}

TestSubscription is a test Pub/Sub subscription.

func (*TestSubscription) Config

func (s *TestSubscription) Config(ctx context.Context) (pubsub.SubscriptionConfig, error)

Config implements Subscription.Config.

func (*TestSubscription) Delete

func (s *TestSubscription) Delete(ctx context.Context) error

Delete implements Subscription.Delete.

func (*TestSubscription) Exists

func (s *TestSubscription) Exists(ctx context.Context) (bool, error)

Exists implements Subscription.Exists.

func (*TestSubscription) Update

func (s *TestSubscription) Update(ctx context.Context, cfg pubsub.SubscriptionConfig) (pubsub.SubscriptionConfig, error)

Update implements Subscription.Update.

type TestTopic

type TestTopic struct {
	// contains filtered or unexported fields
}

TestTopic is a test Pub/Sub topic.

func (*TestTopic) Exists

func (t *TestTopic) Exists(ctx context.Context) (bool, error)

Exists implements Topic.Exists.