Function newSendBatcher

pubsub/pubsub.go:328–342

newSendBatcher creates a batcher for topics, for use with NewTopic.

(ctx context.Context, t *Topic, dt driver.Topic, opts *batcher.Options)

// newSendBatcher creates a batcher for topics, for use with NewTopic.
func newSendBatcher(ctx context.Context, t *Topic, dt driver.Topic, opts *batcher.Options) *batcher.Batcher {
	handler := func(items any) error {
		dms := items.([]*driver.Message)
		err := retry.Call(ctx, gax.Backoff{}, dt.IsRetryable, func() (err error) {
			spanCtx, span := t.tracer.Start(ctx, "driver.Topic.SendBatch")
			defer func() { t.tracer.End(spanCtx, span, err) }()
			return dt.SendBatch(spanCtx, dms)
		})
		if err != nil {
			return wrapError(dt, err)
		}
		return nil
	}
	return batcher.New(reflect.TypeFor[*driver.Message](), opts, handler)
}

// newTopic makes a pubsub.Topic from a driver.Topic.
//