pubsub

func MustPublishPubsubMsg ¶

func MustPublishPubsubMsg(t *testing.T, ctx context.Context, s *pubsub.Topic, msg proto.Message)

MustPublishPubsubMsg is a helper function used to send custom PubSub message.

func MustSetupSubscription ¶

func MustSetupSubscription(ctx context.Context, projectID, topicID, subID string, cb func(context.Context, *pubsub.Message))

MustSetupSubscription is used to create PubSub receiver. User must ensure that topic is created.

func MustSetupTopic ¶

func MustSetupTopic(ctx context.Context, project, topicID string, subIDs ...string) *pubsub.Topic

func SetupTopic ¶

func SetupTopic(ctx context.Context, project, topicID string, subIDs ...string) (*pubsub.Topic, error)