diff --git a/connector/collector/docker.go b/connector/collector/docker.go index 10e4425..03c18de 100644 --- a/connector/collector/docker.go +++ b/connector/collector/docker.go @@ -1,17 +1,17 @@ package collector import ( - "github.com/bcicen/ctop/metrics" + "github.com/bcicen/ctop/models" api "github.com/fsouza/go-dockerclient" ) // Docker collector type Docker struct { - metrics.Metrics + models.Metrics id string client *api.Client running bool - stream chan metrics.Metrics + stream chan models.Metrics done chan bool lastCpu float64 lastSysCpu float64 @@ -19,7 +19,7 @@ type Docker struct { func NewDocker(client *api.Client, id string) *Docker { return &Docker{ - Metrics: metrics.Metrics{}, + Metrics: models.Metrics{}, id: id, client: client, } @@ -27,7 +27,7 @@ func NewDocker(client *api.Client, id string) *Docker { func (c *Docker) Start() { c.done = make(chan bool) - c.stream = make(chan metrics.Metrics) + c.stream = make(chan models.Metrics) stats := make(chan *api.Stats) go func() { @@ -61,7 +61,7 @@ func (c *Docker) Running() bool { return c.running } -func (c *Docker) Stream() chan metrics.Metrics { +func (c *Docker) Stream() chan models.Metrics { return c.stream } diff --git a/connector/collector/mock.go b/connector/collector/mock.go index 09ada8a..972e6f5 100644 --- a/connector/collector/mock.go +++ b/connector/collector/mock.go @@ -6,13 +6,13 @@ import ( "math/rand" "time" - "github.com/bcicen/ctop/metrics" + "github.com/bcicen/ctop/models" ) // Mock collector type Mock struct { - metrics.Metrics - stream chan metrics.Metrics + models.Metrics + stream chan models.Metrics done bool running bool aggression int64 @@ -20,7 +20,7 @@ type Mock struct { func NewMock(a int64) *Mock { c := &Mock{ - Metrics: metrics.Metrics{}, + Metrics: models.Metrics{}, aggression: a, } c.MemLimit = 2147483648 @@ -33,7 +33,7 @@ func (c *Mock) Running() bool { func (c *Mock) Start() { c.done = false - c.stream = make(chan metrics.Metrics) + c.stream = make(chan models.Metrics) go c.run() } @@ -41,7 +41,7 @@ func (c *Mock) Stop() { c.done = true } -func (c *Mock) Stream() chan metrics.Metrics { +func (c *Mock) Stream() chan models.Metrics { return c.stream } diff --git a/connector/collector/runc.go b/connector/collector/runc.go index c167495..905c018 100644 --- a/connector/collector/runc.go +++ b/connector/collector/runc.go @@ -5,17 +5,17 @@ package collector import ( "time" - "github.com/bcicen/ctop/metrics" + "github.com/bcicen/ctop/models" "github.com/opencontainers/runc/libcontainer" "github.com/opencontainers/runc/libcontainer/cgroups" ) // Runc collector type Runc struct { - metrics.Metrics + models.Metrics id string libc libcontainer.Container - stream chan metrics.Metrics + stream chan models.Metrics done bool running bool interval int // collection interval, in seconds @@ -25,7 +25,7 @@ type Runc struct { func NewRunc(libc libcontainer.Container) *Runc { c := &Runc{ - Metrics: metrics.Metrics{}, + Metrics: models.Metrics{}, id: libc.ID(), libc: libc, interval: 1, @@ -39,7 +39,7 @@ func (c *Runc) Running() bool { func (c *Runc) Start() { c.done = false - c.stream = make(chan metrics.Metrics) + c.stream = make(chan models.Metrics) go c.run() } @@ -47,7 +47,7 @@ func (c *Runc) Stop() { c.done = true } -func (c *Runc) Stream() chan metrics.Metrics { +func (c *Runc) Stream() chan models.Metrics { return c.stream } diff --git a/container/main.go b/container/main.go index 38d0a66..4f004b6 100644 --- a/container/main.go +++ b/container/main.go @@ -4,7 +4,7 @@ import ( "github.com/bcicen/ctop/cwidgets" "github.com/bcicen/ctop/cwidgets/compact" "github.com/bcicen/ctop/logging" - "github.com/bcicen/ctop/metrics" + "github.com/bcicen/ctop/models" ) var ( @@ -13,19 +13,19 @@ var ( // Metrics and metadata representing a container type Container struct { - metrics.Metrics + models.Metrics Id string Meta map[string]string Widgets *compact.Compact Display bool // display this container in compact view updater cwidgets.WidgetUpdater - collector metrics.Collector + collector models.Collector } -func New(id string, collector metrics.Collector) *Container { +func New(id string, collector models.Collector) *Container { widgets := compact.NewCompact(id) return &Container{ - Metrics: metrics.NewMetrics(), + Metrics: models.NewMetrics(), Id: id, Meta: make(map[string]string), Widgets: widgets, @@ -67,14 +67,14 @@ func (c *Container) SetState(s string) { } // Read metric stream, updating widgets -func (c *Container) Read(stream chan metrics.Metrics) { +func (c *Container) Read(stream chan models.Metrics) { go func() { for metrics := range stream { c.Metrics = metrics c.updater.SetMetrics(metrics) } log.Infof("reader stopped for container: %s", c.Id) - c.Metrics = metrics.NewMetrics() + c.Metrics = models.NewMetrics() c.Widgets.Reset() }() log.Infof("reader started for container: %s", c.Id) diff --git a/cwidgets/compact/main.go b/cwidgets/compact/main.go index b0d2d27..9fa2961 100644 --- a/cwidgets/compact/main.go +++ b/cwidgets/compact/main.go @@ -2,7 +2,7 @@ package compact import ( "github.com/bcicen/ctop/logging" - "github.com/bcicen/ctop/metrics" + "github.com/bcicen/ctop/models" ui "github.com/gizak/termui" ) @@ -59,7 +59,7 @@ func (row *Compact) SetMeta(k, v string) { } } -func (row *Compact) SetMetrics(m metrics.Metrics) { +func (row *Compact) SetMetrics(m models.Metrics) { row.SetCPU(m.CPUUtil) row.SetNet(m.NetRx, m.NetTx) row.SetMem(m.MemUsage, m.MemLimit, m.MemPercent) diff --git a/cwidgets/expanded/main.go b/cwidgets/expanded/main.go index 9c355fd..0c53ca6 100644 --- a/cwidgets/expanded/main.go +++ b/cwidgets/expanded/main.go @@ -2,7 +2,7 @@ package expanded import ( "github.com/bcicen/ctop/logging" - "github.com/bcicen/ctop/metrics" + "github.com/bcicen/ctop/models" ui "github.com/gizak/termui" ) @@ -55,7 +55,7 @@ func (e *Expanded) Down() { func (e *Expanded) SetWidth(w int) { e.Width = w } func (e *Expanded) SetMeta(k, v string) { e.Info.Set(k, v) } -func (e *Expanded) SetMetrics(m metrics.Metrics) { +func (e *Expanded) SetMetrics(m models.Metrics) { e.Cpu.Update(m.CPUUtil) e.Net.Update(m.NetRx, m.NetTx) e.Mem.Update(int(m.MemUsage), int(m.MemLimit)) diff --git a/cwidgets/main.go b/cwidgets/main.go index 8ccafc7..50e4d2e 100644 --- a/cwidgets/main.go +++ b/cwidgets/main.go @@ -2,12 +2,12 @@ package cwidgets import ( "github.com/bcicen/ctop/logging" - "github.com/bcicen/ctop/metrics" + "github.com/bcicen/ctop/models" ) var log = logging.Init() type WidgetUpdater interface { SetMeta(string, string) - SetMetrics(metrics.Metrics) + SetMetrics(models.Metrics) } diff --git a/metrics/main.go b/models/main.go similarity index 96% rename from metrics/main.go rename to models/main.go index 8048122..fb1ddc3 100644 --- a/metrics/main.go +++ b/models/main.go @@ -1,4 +1,4 @@ -package metrics +package models type Metrics struct { CPUUtil int