tweak mock source, add excluding build tag

This commit is contained in:
Bradley Cicenas 2017-03-07 02:14:16 +00:00
parent 98d8dc62f9
commit c955a8310b
2 changed files with 12 additions and 5 deletions

View File

@ -1,3 +1,5 @@
// +build !release
package metrics package metrics
import ( import (
@ -45,14 +47,13 @@ func (c *Mock) run() {
defer close(c.stream) defer close(c.stream)
for { for {
c.CPUUtil += rand.Intn(10) c.CPUUtil += rand.Intn(2)
if c.CPUUtil > 100 { if c.CPUUtil > 100 {
c.CPUUtil = 0 c.CPUUtil = 0
} }
c.CPUUtil += rand.Intn(2)
c.NetTx += rand.Int63n(600) c.NetTx += rand.Int63n(600)
c.NetRx += rand.Int63n(600) c.NetRx += rand.Int63n(600)
c.MemUsage += rand.Int63n(c.MemLimit / 16) c.MemUsage += rand.Int63n(c.MemLimit / 32)
if c.MemUsage > c.MemLimit { if c.MemUsage > c.MemLimit {
c.MemUsage = 0 c.MemUsage = 0
} }

View File

@ -1,3 +1,5 @@
// +build !release
package main package main
import ( import (
@ -24,11 +26,11 @@ func NewMockContainerSource() *MockContainerSource {
// Create Mock containers // Create Mock containers
func (cs *MockContainerSource) Init() { func (cs *MockContainerSource) Init() {
total := 40 total := 20
rand.Seed(int64(time.Now().Nanosecond())) rand.Seed(int64(time.Now().Nanosecond()))
for i := 0; i < total; i++ { for i := 0; i < total; i++ {
time.Sleep(1 * time.Second) //time.Sleep(1 * time.Second)
collector := metrics.NewMock() collector := metrics.NewMock()
c := NewContainer(makeID(), collector) c := NewContainer(makeID(), collector)
c.SetMeta("name", makeName()) c.SetMeta("name", makeName())
@ -95,6 +97,10 @@ func makeID() string {
func makeName() string { func makeName() string {
n, err := codename.Get(codename.Sanitized) n, err := codename.Get(codename.Sanitized)
nsp := strings.Split(n, "-")
if len(nsp) > 2 {
n = strings.Join(nsp[:2], "-")
}
if err != nil { if err != nil {
panic(err) panic(err)
} }