Categorygithub.com/redhatinsights/insights-ingress-gointernalqueue
package
0.0.0-20241202171925-7848b515e5e2
Repository: https://github.com/redhatinsights/insights-ingress-go.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
8
Dependents
3
Files
116 SLOC

# Functions

Producer consumes in and produces to the topic in config Each message is sent to the writer via a goroutine so that the internal batch buffer has an opportunity to fill.

# Structs

ProducerConfig configures a producer.