pubsub

README

krakend-pubsub

a pubsub backend for the KrakenD framework

Backends

• AWS SNS (Simple Notification Service) and SQS (Simple Queueing Service)
• Azure Service Bus Topic and Subscription
• GCP PubSub
• NATS.io
• RabbitMQ

Configuration

Just add the extra config at your backend:

"github.com/devopsfaith/krakend-pubsub/subscriber": {
	"subscription_url": "gcppubsub://project/topic"
}

"github.com/devopsfaith/krakend-pubsub/publisher": {
	"topic_url": "gcppubsub://project/topic"
}

Documentation

Index

• Variables
• type BackendFactory
  • func NewBackendFactory(ctx context.Context, logger logging.Logger, bf proxy.BackendFactory) *BackendFactory
  • func (f *BackendFactory) New(remote *config.Backend) proxy.Proxy
• type NamespaceNotFoundErr
  • func (n *NamespaceNotFoundErr) Error() string

Variables

var OpenCensusViews = pubsub.OpenCensusViews

Types

type BackendFactory

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

func NewBackendFactory

func NewBackendFactory(ctx context.Context, logger logging.Logger, bf proxy.BackendFactory) *BackendFactory

func (*BackendFactory) New

func (f *BackendFactory) New(remote *config.Backend) proxy.Proxy

type NamespaceNotFoundErr

type NamespaceNotFoundErr struct {
	Namespace string
}

func (*NamespaceNotFoundErr) Error

func (n *NamespaceNotFoundErr) Error() string