gocdk_pub_sub

package
v0.0.0-...-2206af0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 12, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

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

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL