monitor

package

v0.0.0-...-238883e Latest Latest Go to latest Published: Oct 23, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var (
	// we may use a fixed interval
	METRIC_FETCH_INTERVAL_SECOND = 10
	META_UPDATE_INTERVAL_SECOND  = 60
)

This section is empty.

type BrokerTopicRequest struct {
	Result chan int
	Topic  string
}

type ConsumerFullOffset struct {
	Cluster   string
	Topic     string
	Group     string
	Timestamp int64
	// contains filtered or unexported fields
}

type ConsumerOffset struct {
	Cluster   string
	Topic     string
	Group     string
	Partition int32
	Offset    int64
	Timestamp int64
}

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

func NewFetcher(cfg *config.Config) (f *Fetcher, err error)

func (f *Fetcher) Start()

func (f *Fetcher) Stop()

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

func NewImporter(cfg *config.Config) (i *Importer, err error)

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

func NewKafkaClient(cfg *config.Config, cluster string) (*KafkaClient, error)

func (client *KafkaClient) MergeMaps(topicOffsetMap map[string]map[int32]int64)

MergeMaps merge the offset of the topic

func (client *KafkaClient) RefreshMetaData()

func (client *KafkaClient) Start()

func (client *KafkaClient) Stop()

Stop the client

type LogOffset struct {
	Logsize int64
	Offset  int64
}

type TopicPartitionOffset struct {
	Parition int32
	Offset   int64
}