Versions in this module Expand all Collapse all v1 v1.10.8 Oct 6, 2021 v1.10.7 Oct 6, 2021 Changes in this version + func New(cnf *config.Config, projectID, subscriptionName string) (iface.Broker, error) + type Broker struct + MaxExtension time.Duration + func (b *Broker) Publish(ctx context.Context, signature *tasks.Signature) error + func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor) (bool, error) + func (b *Broker) StopConsuming()
Go to main page