pubsub

Documentation

Index

• type PubsubContainer
  • func StartPubSubContainer(ctx context.Context, projectId string) (*PubsubContainer, error)
  • func (c *PubsubContainer) CloseClient(ctx context.Context, t *testing.T)
  • func (c *PubsubContainer) CreateConnectionOptions(t *testing.T) []option.ClientOption
  • func (c *PubsubContainer) CreateSubscription(ctx context.Context, t *testing.T, topicName string, subscriptionName string) *pubsub.Subscription
  • func (c *PubsubContainer) CreateTopic(ctx context.Context, t *testing.T, topicName string) *pubsub.Topic
  • func (c *PubsubContainer) CreateTopicAndSubscription(ctx context.Context, t *testing.T, topicName string) *pubsub.Topic
  • func (c *PubsubContainer) StopContainer(ctx context.Context) error

Types

type PubsubContainer

type PubsubContainer struct {
	Container testcontainers.Container
	URI       string
	// contains filtered or unexported fields
}

PubsubContainer represents the cloud_pubsub container type used in the module.

func StartPubSubContainer

func StartPubSubContainer(ctx context.Context, projectId string) (*PubsubContainer, error)

StartPubSubContainer - startContainer creates an instance of the cloud_pubsub container type.

func (*PubsubContainer) CloseClient

func (c *PubsubContainer) CloseClient(ctx context.Context, t *testing.T)

func (*PubsubContainer) CreateConnectionOptions

func (c *PubsubContainer) CreateConnectionOptions(t *testing.T) []option.ClientOption

func (*PubsubContainer) CreateSubscription

func (c *PubsubContainer) CreateSubscription(ctx context.Context, t *testing.T, topicName string, subscriptionName string) *pubsub.Subscription

func (*PubsubContainer) CreateTopic

func (c *PubsubContainer) CreateTopic(ctx context.Context, t *testing.T, topicName string) *pubsub.Topic

func (*PubsubContainer) CreateTopicAndSubscription

func (c *PubsubContainer) CreateTopicAndSubscription(ctx context.Context, t *testing.T, topicName string) *pubsub.Topic

func (*PubsubContainer) StopContainer

func (c *PubsubContainer) StopContainer(ctx context.Context) error