tracing

Documentation

Index

• func NewAsync(tracer trace.Tracer, consumerAsync consumers.AsyncConsumer, host server.Config) consumers.AsyncConsumer
• func NewBlocking(tracer trace.Tracer, consumerBlock consumers.BlockingConsumer, ...) consumers.BlockingConsumer

Functions

func NewAsync

func NewAsync(tracer trace.Tracer, consumerAsync consumers.AsyncConsumer, host server.Config) consumers.AsyncConsumer

NewAsync creates a new traced consumers.AsyncConsumer service.

func NewBlocking

func NewBlocking(tracer trace.Tracer, consumerBlock consumers.BlockingConsumer, host server.Config) consumers.BlockingConsumer

NewBlocking creates a new traced consumers.BlockingConsumer service.