(reader metrix.Reader)
| 120 | } |
| 121 | |
| 122 | func (e *Engine) PreparePlan(reader metrix.Reader) (PlanAttempt, error) { |
| 123 | plan, materialized, epoch, commitSeq, attemptID, reserved, err := e.preparePlan(reader) |
| 124 | if err != nil { |
| 125 | return PlanAttempt{}, err |
| 126 | } |
| 127 | if !reserved { |
| 128 | return newNoopAttempt(plan), nil |
| 129 | } |
| 130 | return newPreparedAttempt(e, plan, materialized, epoch, commitSeq, attemptID), nil |
| 131 | } |
| 132 | |
| 133 | func (e *Engine) nextAttemptIDLocked() uint64 { |
| 134 | e.state.nextAttempt++ |