Documentation
¶
Index ¶
- type PubsubContainer
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 (*PubsubContainer) CreateTopicAndSubscription ¶
func (*PubsubContainer) StopContainer ¶
func (c *PubsubContainer) StopContainer(ctx context.Context) error
Source Files
Click to show internal directories.
Click to hide internal directories.