pubsub

func NewGCloudSubscription ¶ added in v0.3.0

func NewGCloudSubscription(ctx context.Context, project string, topic string, subscription string) (*pubsub.Subscription, func(), error)

func NewGCloudTopic ¶

func NewGCloudTopic(ctx context.Context, project string, topic string) (*pubsub.Topic, error)

func NewInMemoryTopic ¶

func NewInMemoryTopic(ctx context.Context, topic string) (*pubsub.Topic, error)

func NewRabbitTopic ¶

func NewRabbitTopic(ctx context.Context, topic string) (*pubsub.Topic, error)

Create a new topic on RabbitMQ. This requires the environment variable `RABBIT_SERVER_URL` to be set.

func OpenSubscription ¶ added in v0.3.0

func OpenSubscription(ctx context.Context, subscription string, topic string) (*pubsub.Subscription, func(), error)

func OpenTopic ¶

func OpenTopic(ctx context.Context, topic string) (*pubsub.Topic, error)