1 2 3 4 5 6 7 8 9
package jobs // todo naming type Consumer interface { Push() Stat() Consume(*Pipeline) Register(*Pipeline) }