Versions in this module Expand all Collapse all v0 v0.1.1 Feb 21, 2024 v0.1.0 Nov 13, 2023 Changes in this version + func NewSubscriber(opt SubscriberOptions) (*subscriberImpl, error) + type JobBody struct + Message string + Progress int + type JobStatus struct + Body JobBody + Code int + OrderingKey string + Status string + type Subscriber interface + Close func() + Listen func() error + NewJobStatus func(pMsg *pubsub.Message) (*JobStatus, error) + type SubscriberOptions struct + LoggerBase *log.Logger + OnReceive func(ctx context.Context, message *pubsub.Message) + ProjectID string + SubscriptionID string
Go to main page