package gcppubsub

import "gocloud.dev/pubsub/gcppubsub"

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 ¶

• func Dial(ctx context.Context, ts gcp.TokenSource) (*grpc.ClientConn, func(), error)
• func OpenSubscription(ctx context.Context, client *raw.SubscriberClient, proj gcp.ProjectID, subscriptionName string, opts *SubscriptionOptions) *pubsub.Subscription
• func OpenTopic(ctx context.Context, client *raw.PublisherClient, proj gcp.ProjectID, topicName string, opts *TopicOptions) *pubsub.Topic
• func PublisherClient(ctx context.Context, conn *grpc.ClientConn) (*raw.PublisherClient, error)
• func SubscriberClient(ctx context.Context, conn *grpc.ClientConn) (*raw.SubscriberClient, error)
• type SubscriptionOptions
• type TopicOptions

Functions ¶

func Dial ¶

func Dial(ctx context.Context, ts gcp.TokenSource) (*grpc.ClientConn, func(), error)

Dial opens a gRPC connection to the GCP Pub Sub API.

The second return value is a function that can be called to clean up the connection opened by Dial.

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.

func PublisherClient ¶

func PublisherClient(ctx context.Context, conn *grpc.ClientConn) (*raw.PublisherClient, error)

PublisherClient returns a *raw.PublisherClient that can be used in OpenTopic.

func SubscriberClient ¶

func SubscriberClient(ctx context.Context, conn *grpc.ClientConn) (*raw.SubscriberClient, error)

SubscriberClient returns a *raw.SubscriberClient that can be used in OpenSubscription.

Types ¶

type SubscriptionOptions ¶

type SubscriptionOptions struct{}

SubscriptionOptions will contain configuration for subscriptions.

type TopicOptions ¶

type TopicOptions struct{}

TopicOptions will contain configuration for topics.

Source Files ¶

gcppubsub.go