gocdk_pub_sub

Documentation

Overview

Package gocdk_pub_sub supports the Go CDK (Cloud Development Kit) PubSub API, which in turn supports many providers, including Amazon SNS/SQS, Azure Service Bus, Google Cloud PubSub, and RabbitMQ.

In the config, select a provider and topic using a URL. See https://godoc.org/gocloud.dev/pubsub and its sub-packages for details.

The Go CDK PubSub API does not support administrative operations like topic creation. Create the topic using a UI, CLI or provider-specific API before running weed.

The Go CDK obtains credentials via environment variables and other provider-specific default mechanisms. See the provider's documentation for details.

Index

• type GoCDKPubSub
  • func (k *GoCDKPubSub) GetName() string
  • func (k *GoCDKPubSub) Initialize(configuration util.Configuration, prefix string) error
  • func (k *GoCDKPubSub) SendMessage(key string, message proto.Message) error

Types

type GoCDKPubSub

type GoCDKPubSub struct {
	// contains filtered or unexported fields
}

func (*GoCDKPubSub) GetName

func (k *GoCDKPubSub) GetName() string

func (*GoCDKPubSub) Initialize

func (k *GoCDKPubSub) Initialize(configuration util.Configuration, prefix string) error

func (*GoCDKPubSub) SendMessage

func (k *GoCDKPubSub) SendMessage(key string, message proto.Message) error