| 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/build_source/raw_presentation" |
| 27 "github.com/luci/luci-go/milo/common" | 28 "github.com/luci/luci-go/milo/common" |
| 28 "github.com/luci/luci-go/milo/common/model" | 29 "github.com/luci/luci-go/milo/common/model" |
| 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 |