package mempubsub

import "gocloud.dev/pubsub/mempubsub"

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 NewSubscription(top *pubsub.Topic, ackDeadline time.Duration) *pubsub.Subscription
• func NewTopic() *pubsub.Topic

Functions ¶

func NewSubscription ¶

func NewSubscription(top *pubsub.Topic, ackDeadline time.Duration) *pubsub.Subscription

NewSubscription creates a new subscription for the given topic. It panics if the giventopic did not come from mempubsub.

func NewTopic ¶

func NewTopic() *pubsub.Topic

NewTopic creates a new in-memory topic.

Source Files ¶

mem.go