gocloud

Documentation

Overview

Package gocloud provides a pubsub broker for Go Cloud. Go Cloud offers cloud-agnostic interface for a variety of common cloud APIs. See https://github.com/google/go-cloud.

Index

• func GCPProjectID(projID gcp.ProjectID) broker.Option
• func GCPTokenSource(ts gcp.TokenSource) broker.Option
• func NewBroker(opts ...broker.Option) broker.Broker
• func RabbitURL(url string) broker.Option

Functions

func GCPProjectID

func GCPProjectID(projID gcp.ProjectID) broker.Option

GCPProjectID is a broker Option that provides a project ID for Go Cloud's Google Pub/Sub implementation.

func GCPTokenSource

func GCPTokenSource(ts gcp.TokenSource) broker.Option

GCPTokenSource is a broker Option that provides a TokenSource for Go Cloud's Google Pub/Sub implementation.

func NewBroker

func NewBroker(opts ...broker.Option) broker.Broker

NewBroker creates a new gocloud pubsubBroker. If the GCPProjectID option is set, Go Cloud uses its Google Cloud PubSub implementation. If the RabbitURL option is set, Go Cloud uses its RabbitMQ implementation. Otherwise, Go Cloud uses its in-memory implementation.

func RabbitURL

func RabbitURL(url string) broker.Option

RabbitURL is a broker Option that provides a URL for Go Cloud's RabbitMQ implementation.