Lines Matching defs:Pipeliner

11 type Pipeliner struct {  struct
12 	sync.RWMutex
13 	window int
14 	numOut int
15 	ch     chan struct{}
16 	err    error
27 func (p *Pipeliner) getError() error {
33 func (p *Pipeliner) hasRoom() bool {
39 func (p *Pipeliner) launchOne() {
50 func (p *Pipeliner) WaitForRoom(ctx context.Context) error {
69 func (p *Pipeliner) CompleteOne(e error) {
75 func (p *Pipeliner) landOne() {
81 func (p *Pipeliner) hasOutstanding() bool {
87 func (p *Pipeliner) setError(e error) {
95 func (p *Pipeliner) checkContextDone(ctx context.Context) {
103 func (p *Pipeliner) wait(ctx context.Context) {
114 func (p *Pipeliner) Flush(ctx context.Context) error {