pubsub

Documentation

Overview

Package pubsub contains helpers for Google Cloud Pub/Sub.

Index

• func CreateSubscription(pubsubCli *pubsub.Client, topic *pubsub.Topic, f *framework.Framework) *pubsub.Subscription
• func CreateTopic(pubsubCli *pubsub.Client, f *framework.Framework) *pubsub.Topic
• func DeleteSubscription(pubsubCli *pubsub.Client, subsID string)
• func DeleteTopic(pubsubCli *pubsub.Client, topicID string)
• func SendMessage(pubsubCli *pubsub.Client, topicID string) string

Functions

func CreateSubscription

func CreateSubscription(pubsubCli *pubsub.Client, topic *pubsub.Topic, f *framework.Framework) *pubsub.Subscription

CreateSubscription creates a subscription for the given Pub/Sub topic.

func CreateTopic

func CreateTopic(pubsubCli *pubsub.Client, f *framework.Framework) *pubsub.Topic

CreateTopic creates a Pub/Sub topic named after the given framework.Framework.

func DeleteSubscription

func DeleteSubscription(pubsubCli *pubsub.Client, subsID string)

DeleteSubscription deletes the Pub/Sub subscription with the given name.

func DeleteTopic

func DeleteTopic(pubsubCli *pubsub.Client, topicID string)

DeleteTopic deletes the Pub/Sub topic with the given name.

func SendMessage

func SendMessage(pubsubCli *pubsub.Client, topicID string) string

SendMessage sends a message to the given Pub/Sub topic and returns the corresponding message ID.