OLD | NEW |
1 // Copyright 2015 The LUCI Authors. All rights reserved. | 1 // Copyright 2015 The LUCI Authors. All rights reserved. |
2 // Use of this source code is governed under the Apache License, Version 2.0 | 2 // Use of this source code is governed under the Apache License, Version 2.0 |
3 // that can be found in the LICENSE file. | 3 // that can be found in the LICENSE file. |
4 | 4 |
5 package swarming | 5 package swarming |
6 | 6 |
7 import ( | 7 import ( |
8 "bytes" | 8 "bytes" |
9 "fmt" | 9 "fmt" |
10 "net/http" | 10 "net/http" |
11 "net/url" | 11 "net/url" |
12 "strings" | 12 "strings" |
13 "time" | 13 "time" |
14 | 14 |
15 "golang.org/x/net/context" | 15 "golang.org/x/net/context" |
16 | 16 |
17 swarming "github.com/luci/luci-go/common/api/swarming/swarming/v1" | 17 swarming "github.com/luci/luci-go/common/api/swarming/swarming/v1" |
18 "github.com/luci/luci-go/common/errors" | 18 "github.com/luci/luci-go/common/errors" |
19 "github.com/luci/luci-go/common/logging" | 19 "github.com/luci/luci-go/common/logging" |
20 "github.com/luci/luci-go/common/proto/google" | 20 "github.com/luci/luci-go/common/proto/google" |
21 miloProto "github.com/luci/luci-go/common/proto/milo" | 21 miloProto "github.com/luci/luci-go/common/proto/milo" |
22 "github.com/luci/luci-go/common/sync/parallel" | 22 "github.com/luci/luci-go/common/sync/parallel" |
23 "github.com/luci/luci-go/logdog/client/annotee" | 23 "github.com/luci/luci-go/logdog/client/annotee" |
24 "github.com/luci/luci-go/logdog/client/coordinator" | 24 "github.com/luci/luci-go/logdog/client/coordinator" |
25 "github.com/luci/luci-go/logdog/common/types" | 25 "github.com/luci/luci-go/logdog/common/types" |
26 "github.com/luci/luci-go/milo/api/resp" | 26 "github.com/luci/luci-go/milo/api/resp" |
27 » "github.com/luci/luci-go/milo/appengine/common" | 27 » "github.com/luci/luci-go/milo/common" |
28 » "github.com/luci/luci-go/milo/appengine/common/model" | 28 » "github.com/luci/luci-go/milo/common/model" |
29 » "github.com/luci/luci-go/milo/appengine/job_source/raw_presentation" | 29 » "github.com/luci/luci-go/milo/job_source/raw_presentation" |
30 "github.com/luci/luci-go/server/auth" | 30 "github.com/luci/luci-go/server/auth" |
31 ) | 31 ) |
32 | 32 |
33 // errNotMiloJob is returned if a Swarming task is fetched that does not self- | 33 // errNotMiloJob is returned if a Swarming task is fetched that does not self- |
34 // identify as a Milo job. | 34 // identify as a Milo job. |
35 var errNotMiloJob = errors.New("Not a Milo Job or access denied") | 35 var errNotMiloJob = errors.New("Not a Milo Job or access denied") |
36 | 36 |
37 // SwarmingTimeLayout is time layout used by swarming. | 37 // SwarmingTimeLayout is time layout used by swarming. |
38 const SwarmingTimeLayout = "2006-01-02T15:04:05.999999999" | 38 const SwarmingTimeLayout = "2006-01-02T15:04:05.999999999" |
39 | 39 |
(...skipping 728 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
768 for _, tag := range v { | 768 for _, tag := range v { |
769 var value string | 769 var value string |
770 parts := strings.SplitN(tag, ":", 2) | 770 parts := strings.SplitN(tag, ":", 2) |
771 if len(parts) == 2 { | 771 if len(parts) == 2 { |
772 value = parts[1] | 772 value = parts[1] |
773 } | 773 } |
774 res[parts[0]] = value | 774 res[parts[0]] = value |
775 } | 775 } |
776 return res | 776 return res |
777 } | 777 } |
OLD | NEW |