offset_monitor

Documentation

Index

• type OffMonitor
  • func GetOffMonitor(conf OffMonitorConf) OffMonitor
  • func (monitor *OffMonitor) IngestSrcSkMetric(prefixName string, msg *sarama.ConsumerMessage)
  • func (monitor *OffMonitor) StartProducerConsumerMonitor(brokerList []string, topic string, cgName string, ...)
• type OffMonitorConf
• type OffMonitorHandler

Types

type OffMonitor

type OffMonitor struct {
	// contains filtered or unexported fields
}

func GetOffMonitor

func GetOffMonitor(conf OffMonitorConf) OffMonitor

func (*OffMonitor) IngestSrcSkMetric

func (monitor *OffMonitor) IngestSrcSkMetric(prefixName string, msg *sarama.ConsumerMessage)

func (*OffMonitor) StartProducerConsumerMonitor

func (monitor *OffMonitor) StartProducerConsumerMonitor(brokerList []string, topic string, cgName string,
	consumer *consumergroup.ConsumerGroup, ctx context.Context)

type OffMonitorConf

type OffMonitorConf struct {
	SourceSinkMonitorEnabled       bool          `json:"source_sink_monitor_enabled"`
	ProducerConsumerMonitorEnabled bool          `json:"producer_consumer_monitor_enabled"`
	OffPollingInterval             core.Duration `json:"offset_polling_interval"`
}

type OffMonitorHandler

type OffMonitorHandler interface {
	StartProducerConsumerMonitor(brokerList []string, topic string, cgName string, consumer *consumergroup.ConsumerGroup,
		ctx context.Context)
	IngestSrcSkMetric(prefixName string, msg *sarama.ConsumerMessage)
}