Documentation
¶
Overview ¶
Package pubsub provides functions to trace the cloud.google.com/pubsub/go package.
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WrapReceiveHandler ¶
func WrapReceiveHandler(s *pubsub.Subscription, f func(context.Context, *pubsub.Message), opts ...Option) func(context.Context, *pubsub.Message)
WrapReceiveHandler returns a receive handler that wraps the supplied handler, extracts any tracing metadata attached to the received message, and starts a receive span.
Types ¶
type Option ¶
type Option interface {
// contains filtered or unexported methods
}
Option describes options for the Pub/Sub integration.
type OptionFn ¶
type OptionFn func(*config)
OptionFn represents options applicable to WrapReceiveHandler or Publish.
func WithMeasured ¶
func WithMeasured() OptionFn
WithMeasured sets the measured tag for traces started by WrapReceiveHandler or Publish.
func WithService ¶
WithService sets the service name tag for traces started by WrapReceiveHandler or Publish.
type PublishResult ¶
type PublishResult struct {
*pubsub.PublishResult
// contains filtered or unexported fields
}
PublishResult wraps *pubsub.PublishResult
func Publish ¶
func Publish(ctx context.Context, t *pubsub.Topic, msg *pubsub.Message, opts ...Option) *PublishResult
Publish publishes a message on the specified topic and returns a PublishResult. This function is functionally equivalent to t.Publish(ctx, msg), but it also starts a publish span and it ensures that the tracing metadata is propagated as attributes attached to the published message. It is required to call (*PublishResult).Get(ctx) on the value returned by Publish to complete the span.
Example ¶
package main
import (
"context"
"log"
"cloud.google.com/go/pubsub"
pubsubtrace "github.com/DataDog/dd-trace-go/v2/contrib/cloud.google.com/go/pubsub.v1"
)
func main() {
client, err := pubsub.NewClient(context.Background(), "project-id")
if err != nil {
log.Fatal(err)
}
topic := client.Topic("topic")
_, err = pubsubtrace.Publish(context.Background(), topic, &pubsub.Message{Data: []byte("hello world!")}).Get(context.Background())
if err != nil {
log.Fatal(err)
}
}
Output:
Source Files