Documentation
¶
Index ¶
- func BroadcastStatus(code int, topic, status string, duration time.Duration)
- func BroadcastStatusInc(code int, value, status string)
- func RegisterKafkaDurationHistogram(subSystem string, buckets []float64) error
- func RegisterMetrics() error
- type KafkaLogger
- type KafkaWriter
- type MessageDuplicator
- type SHA1HashCalculator
- type UDPReceiver
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) Log ¶
func (kl *KafkaLogger) Log(message string)
func (*KafkaLogger) SendMetricsToKafka ¶
func (kl *KafkaLogger) SendMetricsToKafka()
type KafkaWriter ¶
type KafkaWriter struct {
// contains filtered or unexported fields
}
func NewKafkaWriter ¶
func NewKafkaWriter(brokers []string, loggerTopic string) *KafkaWriter
func (*KafkaWriter) Close ¶
func (kl *KafkaWriter) Close()
func (*KafkaWriter) Log ¶
func (kl *KafkaWriter) Log(message string)
func (*KafkaWriter) SendMetricsToKafka ¶
func (kl *KafkaWriter) SendMetricsToKafka()
func (*KafkaWriter) WriteMessage ¶
func (kw *KafkaWriter) WriteMessage(message 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
type UDPReceiver ¶
type UDPReceiver struct {
// contains filtered or unexported fields
}
func NewUDPReceiver ¶
func NewUDPReceiver(Ip string, port int) (*UDPReceiver, error)
Source Files
Click to show internal directories.
Click to hide internal directories.