Initial distributor implementation

appengine/cmd/dm/model/execution.go

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package model
 
 import (
         "crypto/subtle"
         "fmt"
 
         "github.com/luci/gae/service/datastore"
         "github.com/luci/luci-go/appengine/cmd/dm/enums/attempt"
+        "github.com/luci/luci-go/appengine/cmd/dm/enums/execution"
         "github.com/luci/luci-go/appengine/cmd/dm/types"
         "github.com/luci/luci-go/common/logging"
         "golang.org/x/net/context"
 )
 
 // Execution represents either an ongoing execution on the Quest's specified
 // distributor, or is a placeholder for an already-completed Execution.
 type Execution struct {
         ID      types.UInt32   `gae:"$id"`
         Attempt *datastore.Key `gae:"$parent"`
 
         // ExecutionKey is a randomized nonce that's used to identify API calls from
         // the current execution to dungeon master. Once DM decides that the execution
         // should no longer be able to make API calls (e.g. it uploaded a result or
         // added new dependencies), DM will revoke this key, making all further API
         // access invalid.
         ExecutionKey []byte `gae:",noindex"`
+
+        Status       execution.State
+        StatusReason string `gae:",noindex"`
 }
 
 // Done returns true iff the Execution is done (i.e. it has a blank
 // ExecutionKey).
 func (e *Execution) Done() bool {
         return len(e.ExecutionKey) == 0
 }
 
 // Revoke will null-out the ExecutionKey and Put this Execution to the
 // datastore.
@@ skipping 46 matching lines @@
 // revokes the execution key.
 //
 // As a bonus, it will return the loaded Attempt and Execution.
 func InvalidateExecution(c context.Context, aid *types.AttemptID, evkey []byte) (*Attempt, *Execution, error) {
         a, e, err := verifyExecutionInternal(c, aid, evkey)
         if err != nil {
                 return nil, nil, err
         }
         return a, e, e.Revoke(c)
 }