Versions in this module Expand all Collapse all v0 v0.0.0 Nov 23, 2022 Changes in this version + type MessageQueue interface + Close func() error + GetResult func(ctx context.Context, result *goPubSub.PublishResult) (string, error) + Init func(pubSubKey string, gProject string) error + Publish func(string, *PubSubData) *goPubSub.PublishResult + SubscribeMessages func(ctx context.Context, subscriptionId string, ...) error + func NewMessageQueue(enabled bool, serviceAccountKey string, project string) MessageQueue + type PubSubData struct + Data []byte + Id string + Timestamp int64 + type PubSubQueue struct + PubsubClient *goPubSub.Client + func (pubsubqueue *PubSubQueue) Close() error + func (pubsubqueue *PubSubQueue) GetResult(ctx context.Context, result *goPubSub.PublishResult) (string, error) + func (pubsubqueue *PubSubQueue) Init(pubSubKey string, gProject string) error + func (pubsubqueue *PubSubQueue) Publish(topicName string, pubSubData *PubSubData) *goPubSub.PublishResult + func (pubsubqueue *PubSubQueue) SubscribeMessages(ctx context.Context, subscriptionId string, ...) error + type SubscribeFunction func(ctx context.Context, msg *goPubSub.Message)
Go to main page