Categorygithub.com/scribd/go-sdkpkginstrumentationkafka
package
1.38.0
Repository: https://github.com/scribd/go-sdk.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
8
Dependents
2
Files
290 SLOC

# Functions

NewClient calls kgo.NewClient and wraps the resulting Client.
NewMessageCarrier creates a new MessageCarrier.
WithAnalytics enables Trace Analytics for all started spans.
WithAnalyticsRate sets the sampling rate for Trace Analytics events correlated to started spans.
WithServiceName sets the config service name to serviceName.
WrapClient wraps kgo.Client so that produced and consumed messages are traced.

# Structs

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Interfaces

No description provided by the author

# Type aliases

An Option customizes the config.