kotop

package
v0.0.0-...-59d92b3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 27, 2017 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const BrokerListSpliter = ","

Variables

This section is empty.

Functions

This section is empty.

Types

type Canvas 

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

func NewCanvas 

func NewCanvas() *Canvas

func (*Canvas) LoadData 

func (c *Canvas) LoadData(data canvasData)

func (*Canvas) PageDown 

func (c *Canvas) PageDown()

func (*Canvas) PageUp 

func (c *Canvas) PageUp()

func (*Canvas) Render 

func (c *Canvas) Render()

func (*Canvas) SetSort 

func (c *Canvas) SetSort(field FieldName)

type FieldName 

type FieldName string
const (
	FieldNamePid          FieldName = "pid"
	FieldNameOffset       FieldName = "offset"
	FieldNameSize         FieldName = "size"
	FieldNameOffsetLag    FieldName = "oslag"
	FieldNameHighWaterLag FieldName = "hwlag"
	FieldNameProduceSpeed FieldName = "produce_speed"
	FieldNameConsumeSpeed FieldName = "consume_speed"
	FieldNameLeader       FieldName = "leader"
)

type KOTop 

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

func NewKOTop 

func NewKOTop(conf *KOTopConf, topic, cg string, version sarama.KafkaVersion) (k *KOTop, err error)

func (*KOTop) Check 

func (k *KOTop) Check(topic string) (data canvasData, err error)

type KOTopConf 

type KOTopConf struct {
	Brokers      string `json:"brokers"`
	ZKHosts      string `json:"zkhosts"`
	KafkaVersion string `json:"kafka_version"`
	Verbose      bool
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.