pubsub

Documentation

Index

• func CreateSubscriptionIfNotExists(ctx context.Context, client *pubsub.Client, subscription string, ...) (*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, ...) error

Functions

func CreateSubscriptionIfNotExists

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

func CreateTopicIfNotExists

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

func NewClient

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

func Publish

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

func SubscribeToTopic

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