Documentation ¶
Index ¶
- func StartOtelLogsComponents(ctx context.Context, bridgeService *bridgeservice.SinkerOtelBridgeService, ...) (context.CancelFunc, error)
- func StartOtelMetricsComponents(ctx context.Context, bridgeService *bridgeservice.SinkerOtelBridgeService, ...) (context.CancelFunc, error)
- func StartOtelTracesComponents(ctx context.Context, bridgeService *bridgeservice.SinkerOtelBridgeService, ...) (context.CancelFunc, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StartOtelLogsComponents ¶
func StartOtelLogsComponents(ctx context.Context, bridgeService *bridgeservice.SinkerOtelBridgeService, logger *zap.Logger, kafkaUrl string, pubSub mfnats.PubSub) (context.CancelFunc, error)
func StartOtelMetricsComponents ¶
func StartOtelMetricsComponents(ctx context.Context, bridgeService *bridgeservice.SinkerOtelBridgeService, logger *zap.Logger, kafkaUrl string, pubSub mfnats.PubSub) (context.CancelFunc, error)
func StartOtelTracesComponents ¶
func StartOtelTracesComponents(ctx context.Context, bridgeService *bridgeservice.SinkerOtelBridgeService, logger *zap.Logger, kafkaUrl string, pubSub mfnats.PubSub) (context.CancelFunc, error)
Types ¶
This section is empty.
Directories ¶
Path | Synopsis |
---|---|
Package kafkaexporter exports trace data to Kafka.
|
Package kafkaexporter exports trace data to Kafka. |
internal/awsmsk
Package msk implements the required IAM auth used by AWS' managed Kafka platform to be used with the Surama kafka producer.
|
Package msk implements the required IAM auth used by AWS' managed Kafka platform to be used with the Surama kafka producer. |
Click to show internal directories.
Click to hide internal directories.