Method Wait

cmd/cql-proxy/task/task.go:123–141

Wait waits task for completion or wait timeout.

(ctx context.Context, id int64)

// Wait waits task for completion or wait timeout.
func (m *Manager) Wait(ctx context.Context, id int64) (err error) {
	i := &waitItem{
		id: id,
		ch: make(chan struct{}),
	}

	m.waitCh <- i

	select {
	case <-i.ch:
		return
	case <-ctx.Done():
		err = ctx.Err()
		return
	case <-m.ctx.Done():
		err = m.ctx.Err()
		return
	}
}

// New pushes new task to scheduling pool.
func (m *Manager) New(tt model.TaskType, developer int64, account int64, args gin.H) (id int64, err error) {