pubsub

Jan 6, 2020

Changes in this version

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

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

Nov 7, 2019

Changes in this version

+ 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 OpenTopic(ctx context.Context, topic string) (*pubsub.Topic, error)