pubsub

func CreateSubscriptionIfNotExists(
	ctx context.Context,
	client *pubsub.Client,
	subscription string,
	topic *pubsub.Topic,
	config *pubsub.SubscriptionConfig,
) (*pubsub.Subscription, error)

func CreateTopicIfNotExists(ctx context.Context, client *pubsub.Client, topic string) (*pubsub.Topic, error)

func NewClient(ctx context.Context, projectID string, options ...option.ClientOption) (*pubsub.Client, error)

func Publish(ctx context.Context, client *pubsub.Client, topic string, message interface{}) (string, error)

func SubscribeToTopic(
	ctx context.Context,
	client *pubsub.Client,
	topic string,
	subscription string,
	deadline time.Duration,
	sync bool,
	maxOutstandingMessages int,
	fx func(ctx context.Context, msg *pubsub.Message),
) error