Commit 0f227069 authored by Wojciech Tyczynski's avatar Wojciech Tyczynski

Reduce amount of annoying logs in cacher

parent 40e1aa6b
...@@ -368,7 +368,7 @@ func (c *Cacher) List(ctx context.Context, key string, resourceVersion string, p ...@@ -368,7 +368,7 @@ func (c *Cacher) List(ctx context.Context, key string, resourceVersion string, p
} }
trace := util.NewTrace(fmt.Sprintf("cacher %v: List", c.objectType.String())) trace := util.NewTrace(fmt.Sprintf("cacher %v: List", c.objectType.String()))
defer trace.LogIfLong(250 * time.Millisecond) defer trace.LogIfLong(500 * time.Millisecond)
c.ready.wait() c.ready.wait()
trace.Step("Ready") trace.Step("Ready")
...@@ -749,7 +749,7 @@ func (c *cacheWatcher) process(initEvents []watchCacheEvent, resourceVersion uin ...@@ -749,7 +749,7 @@ func (c *cacheWatcher) process(initEvents []watchCacheEvent, resourceVersion uin
// We should understand what is blocking us in those cases (e.g. // We should understand what is blocking us in those cases (e.g.
// is it lack of CPU, network, or sth else) and potentially // is it lack of CPU, network, or sth else) and potentially
// consider increase size of result buffer in those cases. // consider increase size of result buffer in those cases.
const initProcessThreshold = 100 * time.Millisecond const initProcessThreshold = 500 * time.Millisecond
startTime := time.Now() startTime := time.Now()
for _, event := range initEvents { for _, event := range initEvents {
c.sendWatchCacheEvent(event) c.sendWatchCacheEvent(event)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment