MCPcopy Create free account
hub / github.com/TalkingData/owl / NewResultPool

Function NewResultPool

controller/pool.go:93–95  ·  view source on GitHub ↗
(size int)

Source from the content-addressed store, hash-verified

91}
92
93func NewResultPool(size int) *ResultPool {
94 return &ResultPool{make(chan *types.StrategyResult, size)}
95}
96
97func (this *ResultPool) PutResults(ar *types.AlarmResults) {
98 for _, result := range ar.Results {

Callers 1

InitControllerFunction · 0.70

Calls

no outgoing calls

Tested by

no test coverage detected