Lines Matching defs:Collector
15 type Collector struct { struct
16 m sync.Mutex
17 supervisor supervisor
18 interval time.Duration
19 publishers map[*container.Container]*pubsub.Publisher
20 bufReader *bufio.Reader
23 clockTicksPerSecond uint64
48 func (s *Collector) Collect(c *container.Container) chan interface{} {
61 func (s *Collector) StopCollection(c *container.Container) {
71 func (s *Collector) Unsubscribe(c *container.Container, ch chan interface{}) {
84 func (s *Collector) Run() {