pubsub

Documentation

Index

• func NewGCloudSubscription(ctx context.Context, project string, topic string, subscription string) (*pubsub.Subscription, func(), error)
• func NewGCloudTopic(ctx context.Context, project string, topic string) (*pubsub.Topic, error)
• func NewInMemoryTopic(ctx context.Context, topic string) (*pubsub.Topic, error)
• func NewRabbitTopic(ctx context.Context, topic string) (*pubsub.Topic, error)
• func OpenSubscription(ctx context.Context, subscription string, topic string) (*pubsub.Subscription, func(), error)
• func OpenTopic(ctx context.Context, topic string) (*pubsub.Topic, error)

Functions

func NewGCloudSubscription

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

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)