Documentation
¶
Index ¶
- func BroadcastStatus(code int, topic, status string, duration time.Duration)
- func BroadcastStatusInc(code int, topic, status string)
- func RegisterKafkaDurationHistogram(subSystem string, buckets []float64) error
- func RegisterMetrics() error
- type KafkaLogger
- type KafkaReader
- type MessageDuplicator
- type SHA1HashCalculator
- type UDPSender
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BroadcastStatusInc ¶
func RegisterMetrics ¶
func RegisterMetrics() error
Types ¶
type KafkaLogger ¶
type KafkaLogger struct {
// contains filtered or unexported fields
}
func NewKafkaLogger ¶
func NewKafkaLogger(brokers []string, topic string) *KafkaLogger
func (*KafkaLogger) Close ¶
func (kl *KafkaLogger) Close()
func (*KafkaLogger) Log ¶
func (kl *KafkaLogger) Log(message string)
func (*KafkaLogger) SendMetricsToKafka ¶
func (kl *KafkaLogger) SendMetricsToKafka()
type KafkaReader ¶
type KafkaReader struct {
// contains filtered or unexported fields
}
func NewKafkaReader ¶
func NewKafkaReader(brokers []string, topics []string, groupID string) *KafkaReader
func (*KafkaReader) Close ¶
func (kl *KafkaReader) Close()
func (*KafkaReader) ReadMessage ¶
func (kr *KafkaReader) ReadMessage() (domain.Message, error)
type MessageDuplicator ¶
type MessageDuplicator struct{}
func NewMessageDuplicator ¶
func NewMessageDuplicator() *MessageDuplicator
type SHA1HashCalculator ¶
type SHA1HashCalculator struct{}
func NewSHA1HashCalculator ¶
func NewSHA1HashCalculator() *SHA1HashCalculator
func (*SHA1HashCalculator) Calculate ¶
func (h *SHA1HashCalculator) Calculate(data string) string
Source Files
Click to show internal directories.
Click to hide internal directories.