gcppubsub

Documentation

Overview

Package gcppubsub provides an implementation of pubsub that uses GCP PubSub.

It exposes the following types for As: Topic: *raw.PublisherClient Subscription: *raw.SubscriberClient

Index

• Constants
• func OpenSubscription(ctx context.Context, client *raw.SubscriberClient, proj gcp.ProjectID, ...) *pubsub.Subscription
• func OpenTopic(ctx context.Context, client *raw.PublisherClient, proj gcp.ProjectID, ...) *pubsub.Topic
• type SubscriptionOptions
• type TopicOptions

Constants

const EndPoint = "pubsub.googleapis.com:443"

Functions

func OpenSubscription

func OpenSubscription(ctx context.Context, client *raw.SubscriberClient, proj gcp.ProjectID, subscriptionName string, opts *SubscriptionOptions) *pubsub.Subscription

OpenSubscription opens the subscription on GCP PubSub for the given projectID and subscriptionName.

func OpenTopic

func OpenTopic(ctx context.Context, client *raw.PublisherClient, proj gcp.ProjectID, topicName string, opts *TopicOptions) *pubsub.Topic

OpenTopic opens the topic on GCP PubSub for the given projectID and topicName.

Types

type SubscriptionOptions

type SubscriptionOptions struct{}

SubscriptionOptions will contain configuration for subscriptions.

type TopicOptions

type TopicOptions struct{}

TopicOptions will contain configuration for topics.