Documentation ¶
Index ¶
- type Agent
- type Alias
- type Audit
- type AuthFunc
- type Autocomplete
- type Balance
- type Brokers
- type Capacity
- type Chaos
- type Checkup
- type Clusters
- type Comma
- type Console
- type Consumers
- type Controllers
- type Cpu
- type Deploy
- type Disable
- type Discover
- type Ext4fs
- type Faq
- type Farm
- type GC
- type Haproxy
- type Histogram
- type Host
- type Influx
- type Jmx
- type Job
- type Kafka
- type Kateway
- type Kguard
- type Lags
- type Logstash
- type Lookup
- type LsZk
- type Members
- type Merkle
- type Migrate
- type Mirror
- type Mount
- type Move
- type Normalize
- type Offset
- type Partition
- type Peek
- type Perf
- type Ping
- type Produce
- type Rebalance
- type Redis
- type Sample
- type Scale
- type Segment
- type Sniff
- type Systool
- type Time
- type Top
- type TopBroker
- type TopicInfo
- type Topics
- type Topology
- type Trace
- type UnderReplicated
- type Upgrade
- type Verify
- type Watch
- type Webhook
- type Whois
- type WhoisAppInfo
- type WhoisGroupInfo
- type WhoisTopicInfo
- type ZkInstall
- type ZkLog
- type Zktop
- type Zones
- type Zookeeper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Autocomplete ¶
type Autocomplete struct { Ui cli.Ui Cmd string }
func (*Autocomplete) Help ¶
func (this *Autocomplete) Help() string
func (*Autocomplete) Run ¶
func (this *Autocomplete) Run(args []string) (exitCode int)
func (*Autocomplete) Synopsis ¶
func (this *Autocomplete) Synopsis() string
type Balance ¶
type Balance struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Brokers ¶
type Brokers struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Capacity ¶
type Capacity struct { Ui cli.Ui Cmd string }
chain of dependencies, performance metrics, prioritization
type Clusters ¶
type Clusters struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Console ¶
type Consumers ¶
type Consumers struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Controllers ¶
type Controllers struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
func (*Controllers) Help ¶
func (this *Controllers) Help() string
func (*Controllers) Run ¶
func (this *Controllers) Run(args []string) (exitCode int)
func (*Controllers) Synopsis ¶
func (*Controllers) Synopsis() string
type Deploy ¶
type Deploy struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Disable ¶
type Disable struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Discover ¶
type Discover struct { Ui cli.Ui Cmd string }
type Haproxy ¶
type Haproxy struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Histogram ¶
type Histogram struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
#!/bin/sh date >> /var/wd/topics_offsets/offsets; /usr/bin/gk topics -z prod -l | grep CUM >> /var/wd/topics_offsets/offsets
date >> /var/wd/topics_offsets/network; consul exec ifconfig bond0 | grep 'RX bytes' | awk '{print $1,$3,$7}' | sort >> /var/wd/topics_offsets/network
type Kateway ¶
type Kateway struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Members ¶
type Members struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
consul members will include: - zk cluster as server - agents
- brokers
- kateway
- kguard
type Migrate ¶
type Migrate struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Normalize ¶
type Normalize struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Ping ¶
type Ping struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Produce ¶
type Produce struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Rebalance ¶
type Rebalance struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Redis ¶
type Redis struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
TODO add cluster
type Segment ¶
type Segment struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
TODO calculate how much data produced each day "github.com/hashicorp/go-memdb"
type TopBroker ¶
type TopBroker struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type Topology ¶
type Topology struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type UnderReplicated ¶
type UnderReplicated struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
func (*UnderReplicated) Help ¶
func (this *UnderReplicated) Help() string
func (*UnderReplicated) Run ¶
func (this *UnderReplicated) Run(args []string) (exitCode int)
func (*UnderReplicated) Synopsis ¶
func (*UnderReplicated) Synopsis() string
type Upgrade ¶
type Upgrade struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
type WhoisAppInfo ¶
type WhoisAppInfo struct { AppId string `db:"AppId"` ApplicationName string `db:"ApplicationName"` ApplicationIntro string `db:"ApplicationIntro"` Cluster string `db:"Cluster"` CreateBy string `db:"CreateBy"` CreateTime string `db:"CreateTime"` Status string `db:"Status"` AppSecret string `db:"AppSecret"` Raw string `db:"Raw"` }
type WhoisGroupInfo ¶
type WhoisTopicInfo ¶
type ZkInstall ¶
type ZkInstall struct { Ui cli.Ui Cmd string // contains filtered or unexported fields }
Source Files ¶
- agent.go
- alias.go
- audit.go
- auth.go
- autocomplete.go
- balance.go
- brokers.go
- capacity.go
- chaos.go
- checkup.go
- clusters.go
- comma.go
- console.go
- consumers.go
- controllers.go
- cpu.go
- deploy.go
- disable.go
- discover.go
- ext4fs.go
- faq.go
- farm.go
- gc.go
- haproxy.go
- histogram.go
- host.go
- influx.go
- init.go
- jmx.go
- job.go
- kafka.go
- kateway.go
- kguard.go
- lags.go
- logstash.go
- lookup.go
- lszk.go
- members.go
- merkle.go
- migrate.go
- mirror.go
- mount.go
- move.go
- normalize.go
- offset.go
- partition.go
- peek.go
- perf.go
- ping.go
- produce.go
- rebalance.go
- redis.go
- sample.go
- scale.go
- segment.go
- sniff.go
- systool.go
- template.go
- time.go
- top.go
- topbroker.go
- topics.go
- topology.go
- trace.go
- underreplicated.go
- upgrade.go
- utils.go
- verify.go
- watch.go
- webhook.go
- whois.go
- zkinstall.go
- zklog.go
- zktop.go
- zones.go
- zookeeper.go
Click to show internal directories.
Click to hide internal directories.