mempubsub

Documentation

Overview

Package mempubsub provides an in-memory pubsub implementation. This should not be used for production: it is intended for local development and testing.

mempubsub does not support any types for As.

Index

• func OpenSubscription(b *Broker, topicName string, ackDeadline time.Duration) *pubsub.Subscription
• func OpenTopic(b *Broker, name string) *pubsub.Topic
• type Broker
  • func NewBroker(topicNames []string) *Broker

Functions

func OpenSubscription

func OpenSubscription(b *Broker, topicName string, ackDeadline time.Duration) *pubsub.Subscription

func OpenTopic

func OpenTopic(b *Broker, name string) *pubsub.Topic

OpenTopic establishes a new topic. Open subscribers for the topic before publishing.

Types

type Broker

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

func NewBroker

func NewBroker(topicNames []string) *Broker