pubsubx

Documentation

Overview

Package pubsubx contains utilities for working with Google PubSub.

Index

• func CleanupTopic(ctx context.Context, project, topic string)
• func EnsureSubscription(ctx context.Context, client *pubsub.Client, topic, id string) (*pubsub.Subscription, error)
• func EnsureTopic(ctx context.Context, client *pubsub.Client, topic string) (*pubsub.Topic, error)
• func MakeQualifiedSubscriptionName(project, subscription string) string
• func MakeQualifiedTopicName(project, topic string) string
• func Publish(ctx context.Context, project, topic string, messages ...string) (*pubsub.Subscription, error)

Functions

func CleanupTopic

func CleanupTopic(ctx context.Context, project, topic string)

CleanupTopic deletes a topic with all subscriptions and logs any error. Useful for defer.

func EnsureSubscription

func EnsureSubscription(ctx context.Context, client *pubsub.Client, topic, id string) (*pubsub.Subscription, error)

EnsureSubscription creates a new subscription with the given name, if it doesn't exist.

func EnsureTopic

func EnsureTopic(ctx context.Context, client *pubsub.Client, topic string) (*pubsub.Topic, error)

EnsureTopic creates a new topic, if it doesn't exist.

func MakeQualifiedSubscriptionName

func MakeQualifiedSubscriptionName(project, subscription string) string

MakeQualifiedSubscriptionName returns a fully-qualified subscription name for the given project and subscription id.

func MakeQualifiedTopicName

func MakeQualifiedTopicName(project, topic string) string

MakeQualifiedTopicName returns a fully-qualified topic name for the given project and topic.

func Publish

func Publish(ctx context.Context, project, topic string, messages ...string) (*pubsub.Subscription, error)

Publish is a simple utility for publishing a set of string messages serially to a pubsub topic. Small scale use only.