monitor

package

v0.0.0-...-875b2bb Latest Latest Go to latest Published: Mar 27, 2020 License: Apache-2.0 Imports: 12 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

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
}