Documentation
¶
Index ¶
- Variables
- func ConnectTracer(stop chan struct{}, serviceName string, grpcEndpoint string)
- func ExtractAMQPHeaders(ctx context.Context, headers map[string]interface{}) context.Context
- func InjectAMQPHeaders(ctx context.Context) map[string]interface{}
- func StartTracing(stop chan struct{}, cancelChan chan os.Signal, serviceName string, ...)
- type AmqpHeadersCarrier
Constants ¶
This section is empty.
Variables ¶
View Source
var (
GrpcEndpoint = "localhost:4317"
)
Functions ¶
func ConnectTracer ¶
func ExtractAMQPHeaders ¶
ExtractAMQPHeaders extracts the tracing from the header and puts it into the context
func InjectAMQPHeaders ¶
InjectAMQPHeaders injects the tracing from the context into the header map
Types ¶
type AmqpHeadersCarrier ¶
type AmqpHeadersCarrier map[string]interface{}
func (AmqpHeadersCarrier) Get ¶
func (a AmqpHeadersCarrier) Get(key string) string
func (AmqpHeadersCarrier) Keys ¶
func (a AmqpHeadersCarrier) Keys() []string
func (AmqpHeadersCarrier) Set ¶
func (a AmqpHeadersCarrier) Set(key string, value string)
Source Files
Click to show internal directories.
Click to hide internal directories.