You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@trafficcontrol.apache.org by da...@apache.org on 2016/11/17 01:34:07 UTC
[01/12] incubator-trafficcontrol git commit: Fix TM2 to Stop
time.Ticker
Repository: incubator-trafficcontrol
Updated Branches:
refs/heads/psql-rebase 7978fc78d -> 25f04116d
Fix TM2 to Stop time.Ticker
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/cda0f775
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/cda0f775
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/cda0f775
Branch: refs/heads/psql-rebase
Commit: cda0f775c9360f34b8fe2298559014f54f9aa465
Parents: 96ab116
Author: Robert Butts <ro...@gmail.com>
Authored: Wed Nov 9 15:21:11 2016 -0700
Committer: Dave Neuman <ne...@apache.org>
Committed: Mon Nov 14 10:08:17 2016 -0700
----------------------------------------------------------------------
traffic_monitor/experimental/common/poller/poller.go | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/cda0f775/traffic_monitor/experimental/common/poller/poller.go
----------------------------------------------------------------------
diff --git a/traffic_monitor/experimental/common/poller/poller.go b/traffic_monitor/experimental/common/poller/poller.go
index c1a98fb..e8e401a 100644
--- a/traffic_monitor/experimental/common/poller/poller.go
+++ b/traffic_monitor/experimental/common/poller/poller.go
@@ -8,9 +8,9 @@ package poller
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@@ -19,7 +19,6 @@ package poller
* under the License.
*/
-
import (
"io/ioutil"
"math/rand"
@@ -263,6 +262,7 @@ func pollHttp(interval time.Duration, id string, url string, fetcher fetcher.Fet
for {
select {
case now := <-tick.C:
+ tick.Stop() // old ticker MUST call Stop() to release resources. Else, memory leak.
tick = time.NewTicker(interval) // recreate timer, to avoid Go's "smoothing" nonsense
realInterval := now.Sub(lastTime)
if realInterval > interval+(time.Millisecond*100) {
[02/12] incubator-trafficcontrol git commit: Rename TM2 commonError
to wrapErr
Posted by da...@apache.org.
Rename TM2 commonError to wrapErr
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/f22f002f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/f22f002f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/f22f002f
Branch: refs/heads/psql-rebase
Commit: f22f002fe7a2dc33ac61e9cd1120b434d70ab40e
Parents: c7ec081
Author: Robert Butts <ro...@gmail.com>
Authored: Fri Nov 4 10:15:50 2016 -0600
Committer: Dave Neuman <ne...@apache.org>
Committed: Mon Nov 14 10:08:17 2016 -0700
----------------------------------------------------------------------
.../traffic_monitor/manager/datarequest.go | 30 ++++++++++----------
1 file changed, 15 insertions(+), 15 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/f22f002f/traffic_monitor/experimental/traffic_monitor/manager/datarequest.go
----------------------------------------------------------------------
diff --git a/traffic_monitor/experimental/traffic_monitor/manager/datarequest.go b/traffic_monitor/experimental/traffic_monitor/manager/datarequest.go
index 7de4c0e..0004b9d 100644
--- a/traffic_monitor/experimental/traffic_monitor/manager/datarequest.go
+++ b/traffic_monitor/experimental/traffic_monitor/manager/datarequest.go
@@ -465,8 +465,8 @@ func DataRequest(
log.Errorf("Request Error: %v\n", fmt.Errorf(req.Type.String()+": %v", err))
}
- // commonReturn takes the body, err, and the data request Type which has been processed. It logs and deals with any error, and returns the appropriate bytes and response code for the `srvhttp`.
- commonReturn := func(body []byte, err error) ([]byte, int) {
+ // wrapErr takes the body, err, and the data request Type which has been processed. It logs and deals with any error, and returns the appropriate bytes and response code for the `srvhttp`. It notably returns InternalServerError status on any error, for security reasons.
+ wrapErr := func(body []byte, err error) ([]byte, int) {
if err == nil {
return body, http.StatusOK
}
@@ -483,23 +483,23 @@ func DataRequest(
case srvhttp.TRConfig:
cdnName := opsConfig.Get().CdnName
if toSession == nil {
- return commonReturn(nil, fmt.Errorf("Unable to connect to Traffic Ops"))
+ return wrapErr(nil, fmt.Errorf("Unable to connect to Traffic Ops"))
}
if cdnName == "" {
- return commonReturn(nil, fmt.Errorf("No CDN Configured"))
+ return wrapErr(nil, fmt.Errorf("No CDN Configured"))
}
- return commonReturn(toSession.CRConfigRaw(cdnName))
+ return wrapErr(toSession.CRConfigRaw(cdnName))
case srvhttp.TRStateDerived:
- return commonReturn(peer.CrstatesMarshall(combinedStates.Get()))
+ return wrapErr(peer.CrstatesMarshall(combinedStates.Get()))
case srvhttp.TRStateSelf:
- return commonReturn(peer.CrstatesMarshall(localStates.Get()))
+ return wrapErr(peer.CrstatesMarshall(localStates.Get()))
case srvhttp.CacheStats:
filter, err := NewCacheStatFilter(req.Parameters, toData.Get().ServerTypes)
if err != nil {
handleErr(err)
return []byte(err.Error()), http.StatusBadRequest
}
- return commonReturn(cache.StatsMarshall(statHistory.Get(), filter, req.Parameters))
+ return wrapErr(cache.StatsMarshall(statHistory.Get(), filter, req.Parameters))
case srvhttp.DSStats:
filter, err := NewDSStatFilter(req.Parameters, toData.Get().DeliveryServiceTypes)
if err != nil {
@@ -507,27 +507,27 @@ func DataRequest(
return []byte(err.Error()), http.StatusBadRequest
}
// TODO marshall beforehand, for performance? (test to see how often requests are made)
- return commonReturn(json.Marshal(dsStats.Get().JSON(filter, req.Parameters)))
+ return wrapErr(json.Marshal(dsStats.Get().JSON(filter, req.Parameters)))
case srvhttp.EventLog:
- return commonReturn(json.Marshal(JSONEvents{Events: events.Get()}))
+ return wrapErr(json.Marshal(JSONEvents{Events: events.Get()}))
case srvhttp.PeerStates:
filter, err := NewPeerStateFilter(req.Parameters, toData.Get().ServerTypes)
if err != nil {
handleErr(err)
return []byte(err.Error()), http.StatusBadRequest
}
- return commonReturn(json.Marshal(createAPIPeerStates(peerStates.Get(), filter, req.Parameters)))
+ return wrapErr(json.Marshal(createAPIPeerStates(peerStates.Get(), filter, req.Parameters)))
case srvhttp.StatSummary:
return nil, http.StatusNotImplemented
case srvhttp.Stats:
- return commonReturn(getStats(staticAppData, healthPollInterval, lastHealthDurations.Get(), fetchCount.Get(), healthIteration.Get(), errorCount.Get()))
+ return wrapErr(getStats(staticAppData, healthPollInterval, lastHealthDurations.Get(), fetchCount.Get(), healthIteration.Get(), errorCount.Get()))
case srvhttp.ConfigDoc:
opsConfigCopy := opsConfig.Get()
// if the password is blank, leave it blank, so callers can see it's missing.
if opsConfigCopy.Password != "" {
opsConfigCopy.Password = "*****"
}
- return commonReturn(json.Marshal(opsConfigCopy))
+ return wrapErr(json.Marshal(opsConfigCopy))
case srvhttp.APICacheCount: // TODO determine if this should use peerStates
return []byte(strconv.Itoa(len(localStates.Get().Caches))), http.StatusOK
case srvhttp.APICacheAvailableCount:
@@ -545,7 +545,7 @@ func DataRequest(
case srvhttp.APITrafficOpsURI:
return []byte(opsConfig.Get().Url), http.StatusOK
case srvhttp.APICacheStates:
- return commonReturn(json.Marshal(createCacheStatuses(toData.Get().ServerTypes, statHistory.Get(),
+ return wrapErr(json.Marshal(createCacheStatuses(toData.Get().ServerTypes, statHistory.Get(),
lastHealthDurations.Get(), localStates.Get().Caches, lastStats.Get(), localCacheStatus)))
case srvhttp.APIBandwidthKbps:
serverTypes := toData.Get().ServerTypes
@@ -569,7 +569,7 @@ func DataRequest(
}
return []byte(fmt.Sprintf("%d", cap)), http.StatusOK
default:
- return commonReturn(nil, fmt.Errorf("Unknown Request Type"))
+ return wrapErr(nil, fmt.Errorf("Unknown Request Type"))
}
}
[11/12] incubator-trafficcontrol git commit: This closes #81
Posted by da...@apache.org.
This closes #81
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/f39c1fd1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/f39c1fd1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/f39c1fd1
Branch: refs/heads/psql-rebase
Commit: f39c1fd14ebe0f1c8c945a1ba9ba42957db94b54
Parents: 5c7bc65
Author: Eric Friedrich <ef...@cisco.com>
Authored: Tue Nov 15 20:03:55 2016 -0500
Committer: Eric Friedrich <ef...@cisco.com>
Committed: Tue Nov 15 20:03:55 2016 -0500
----------------------------------------------------------------------
----------------------------------------------------------------------
[04/12] incubator-trafficcontrol git commit: add TM2 log.Write
Posted by da...@apache.org.
add TM2 log.Write
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/93d1372e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/93d1372e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/93d1372e
Branch: refs/heads/psql-rebase
Commit: 93d1372e485eda0b5d5c80149c47e9f2c242a0db
Parents: f22f002
Author: Robert Butts <ro...@gmail.com>
Authored: Mon Nov 7 14:50:39 2016 -0700
Committer: Dave Neuman <ne...@apache.org>
Committed: Mon Nov 14 10:08:17 2016 -0700
----------------------------------------------------------------------
traffic_monitor/experimental/common/log/log.go | 17 +++++++++++++++++
1 file changed, 17 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/93d1372e/traffic_monitor/experimental/common/log/log.go
----------------------------------------------------------------------
diff --git a/traffic_monitor/experimental/common/log/log.go b/traffic_monitor/experimental/common/log/log.go
index 884d4c3..0fd33c9 100644
--- a/traffic_monitor/experimental/common/log/log.go
+++ b/traffic_monitor/experimental/common/log/log.go
@@ -85,3 +85,20 @@ func Closef(c io.Closer, contextFormat string, v ...interface{}) {
Errorf(": %v", err)
}
}
+
+// Write calls `Write()` on the given Writer, and logs any error. On error, the context is logged, followed by a colon, the error message, and a newline.
+func Write(w io.Writer, b []byte, context string) {
+ _, err := w.Write(b)
+ if err != nil {
+ Errorf("%v: %v", context, err)
+ }
+}
+
+// Writef acts like Write, with a given format string and values, followed by a colon, the error message, and a newline. The given values are not coerced, concatenated, or printed unless an error occurs, so this is more efficient than `Write()`.
+func Writef(w io.Writer, b []byte, contextFormat string, v ...interface{}) {
+ _, err := w.Write(b)
+ if err != nil {
+ Errorf(contextFormat, v...)
+ Errorf(": %v", err)
+ }
+}
[09/12] incubator-trafficcontrol git commit: This closes #78
Posted by da...@apache.org.
This closes #78
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/8586608b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/8586608b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/8586608b
Branch: refs/heads/psql-rebase
Commit: 8586608b082eafd1116f26faa951b625334f8330
Parents: 7837e8c
Author: Jeremy Mitchell <mi...@gmail.com>
Authored: Mon Nov 14 13:34:22 2016 -0700
Committer: Jeremy Mitchell <mi...@gmail.com>
Committed: Mon Nov 14 13:34:22 2016 -0700
----------------------------------------------------------------------
----------------------------------------------------------------------
[03/12] incubator-trafficcontrol git commit: Change TM2 HTTP dispatch
to use a map
Posted by da...@apache.org.
Change TM2 HTTP dispatch to use a map
Changes Traffic Monitor 2.0 HTTP dispatching to give a map directly
to the srvhttp.Server, to register endpoints. This not only makes
serving faster, but makes the code less error prone, by directly
dispatching instead of using a giant switch statement.
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/96ab1169
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/96ab1169
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/96ab1169
Branch: refs/heads/psql-rebase
Commit: 96ab11692f7ddfb6b8ae8fb38cd2a17d4c6134b6
Parents: 93d1372
Author: Robert Butts <ro...@gmail.com>
Authored: Mon Nov 7 14:54:48 2016 -0700
Committer: Dave Neuman <ne...@apache.org>
Committed: Mon Nov 14 10:08:17 2016 -0700
----------------------------------------------------------------------
.../traffic_monitor/manager/datarequest.go | 396 +++++++++++++------
.../traffic_monitor/manager/opsconfig.go | 46 ++-
.../traffic_monitor/srvhttp/srvhttp.go | 216 +---------
3 files changed, 310 insertions(+), 348 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/96ab1169/traffic_monitor/experimental/traffic_monitor/manager/datarequest.go
----------------------------------------------------------------------
diff --git a/traffic_monitor/experimental/traffic_monitor/manager/datarequest.go b/traffic_monitor/experimental/traffic_monitor/manager/datarequest.go
index 0004b9d..750264a 100644
--- a/traffic_monitor/experimental/traffic_monitor/manager/datarequest.go
+++ b/traffic_monitor/experimental/traffic_monitor/manager/datarequest.go
@@ -432,9 +432,223 @@ func NewPeerStateFilter(params url.Values, cacheTypes map[enum.CacheName]enum.Ca
}, nil
}
-// DataRequest takes an `srvhttp.DataRequest`, and the monitored data objects, and returns the appropriate response, and the status code.
-func DataRequest(
- req srvhttp.DataRequest,
+// HandleErr takes an error, and the request type it came from, and logs. It is ok to call with a nil error, in which case this is a no-op.
+func HandleErr(errorCount UintThreadsafe, reqPath string, err error) {
+ if err == nil {
+ return
+ }
+ errorCount.Inc()
+ log.Errorf("Request Error: %v\n", fmt.Errorf(reqPath+": %v", err))
+}
+
+// WrapErrCode takes the body, err, and log context (errorCount, reqPath). It logs and deals with any error, and returns the appropriate bytes and response code for the `srvhttp`. It notably returns InternalServerError status on any error, for security reasons.
+func WrapErrCode(errorCount UintThreadsafe, reqPath string, body []byte, err error) ([]byte, int) {
+ if err == nil {
+ return body, http.StatusOK
+ }
+ HandleErr(errorCount, reqPath, err)
+ return nil, http.StatusInternalServerError
+}
+
+// WrapBytes takes a function which cannot error and returns only bytes, and wraps it as a http.HandlerFunc. The errContext is logged if the write fails, and should be enough information to trace the problem (function name, endpoint, request parameters, etc).
+func WrapBytes(f func() []byte) http.HandlerFunc {
+ return func(w http.ResponseWriter, r *http.Request) {
+ log.Write(w, f(), r.URL.EscapedPath())
+ }
+}
+
+// WrapErr takes a function which returns bytes and an error, and wraps it as a http.HandlerFunc. If the error is nil, the bytes are written with Status OK. Else, the error is logged, and InternalServerError is returned as the response code. If you need to return a different response code (for example, StatusBadRequest), call wrapRespCode.
+func WrapErr(errorCount UintThreadsafe, f func() ([]byte, error)) http.HandlerFunc {
+ return func(w http.ResponseWriter, r *http.Request) {
+ bytes, err := f()
+ _, code := WrapErrCode(errorCount, r.URL.EscapedPath(), bytes, err)
+ w.WriteHeader(code)
+ log.Write(w, bytes, r.URL.EscapedPath())
+ }
+}
+
+// SrvFunc is a function which takes URL parameters, and returns the requested data, and a response code. Note it does not take the full http.Request, and does not have the path. SrvFunc functions should be called via dispatch, and any additional data needed should be closed via a lambda.
+// TODO split params and path into 2 separate wrappers?
+// TODO change to simply take the http.Request?
+type SrvFunc func(params url.Values, path string) ([]byte, int)
+
+// WrapParams takes a SrvFunc and wraps it as an http.HandlerFunc. Note if the SrvFunc returns 0 bytes, an InternalServerError is returned, and the response code is ignored, for security reasons. If an error response code is necessary, return bytes to that effect, for example, "Bad Request". DO NOT return informational messages regarding internal server errors; these should be logged, and only a 500 code returned to the client, for security reasons.
+func WrapParams(f SrvFunc) http.HandlerFunc {
+ return func(w http.ResponseWriter, r *http.Request) {
+ bytes, code := f(r.URL.Query(), r.URL.EscapedPath())
+ if len(bytes) > 0 {
+ w.WriteHeader(code)
+ if _, err := w.Write(bytes); err != nil {
+ log.Warnf("received error writing data request %v: %v\n", r.URL.EscapedPath(), err)
+ }
+ } else {
+ w.WriteHeader(http.StatusInternalServerError)
+ if _, err := w.Write([]byte("Internal Server Error")); err != nil {
+ log.Warnf("received error writing data request %v: %v\n", r.URL.EscapedPath(), err)
+ }
+ }
+ }
+}
+
+func srvTRConfig(opsConfig OpsConfigThreadsafe, toSession towrap.ITrafficOpsSession) ([]byte, error) {
+ cdnName := opsConfig.Get().CdnName
+ if toSession == nil {
+ return nil, fmt.Errorf("Unable to connect to Traffic Ops")
+ }
+ if cdnName == "" {
+ return nil, fmt.Errorf("No CDN Configured")
+ }
+ return toSession.CRConfigRaw(cdnName)
+}
+
+func makeWrapAll(errorCount UintThreadsafe, unpolledCaches UnpolledCachesThreadsafe) func(http.HandlerFunc) http.HandlerFunc {
+ return func(f http.HandlerFunc) http.HandlerFunc {
+ return wrapUnpolledCheck(unpolledCaches, errorCount, f)
+ }
+}
+
+func makeCrConfigHandler(wrapper func(http.HandlerFunc) http.HandlerFunc, errorCount UintThreadsafe, opsConfig OpsConfigThreadsafe, toSession towrap.ITrafficOpsSession) http.HandlerFunc {
+ return wrapper(WrapErr(errorCount, func() ([]byte, error) {
+ return srvTRConfig(opsConfig, toSession)
+ }))
+}
+
+func srvTRState(params url.Values, localStates peer.CRStatesThreadsafe, combinedStates peer.CRStatesThreadsafe) ([]byte, error) {
+ if _, raw := params["raw"]; raw {
+ return srvTRStateSelf(localStates)
+ }
+ return srvTRStateDerived(combinedStates)
+}
+
+func srvTRStateDerived(combinedStates peer.CRStatesThreadsafe) ([]byte, error) {
+ return peer.CrstatesMarshall(combinedStates.Get())
+}
+
+func srvTRStateSelf(localStates peer.CRStatesThreadsafe) ([]byte, error) {
+ return peer.CrstatesMarshall(localStates.Get())
+}
+
+// TODO remove error params, handle by returning an error? How, since we need to return a non-standard code?
+func srvCacheStats(params url.Values, errorCount UintThreadsafe, errContext string, toData todata.TODataThreadsafe, statHistory StatHistoryThreadsafe) ([]byte, int) {
+ filter, err := NewCacheStatFilter(params, toData.Get().ServerTypes)
+ if err != nil {
+ HandleErr(errorCount, errContext, err)
+ return []byte(err.Error()), http.StatusBadRequest
+ }
+ bytes, err := cache.StatsMarshall(statHistory.Get(), filter, params)
+ return WrapErrCode(errorCount, errContext, bytes, err)
+}
+
+func srvDSStats(params url.Values, errorCount UintThreadsafe, errContext string, toData todata.TODataThreadsafe, dsStats DSStatsReader) ([]byte, int) {
+ filter, err := NewDSStatFilter(params, toData.Get().DeliveryServiceTypes)
+ if err != nil {
+ HandleErr(errorCount, errContext, err)
+ return []byte(err.Error()), http.StatusBadRequest
+ }
+ bytes, err := json.Marshal(dsStats.Get().JSON(filter, params))
+ return WrapErrCode(errorCount, errContext, bytes, err)
+}
+
+func srvEventLog(events EventsThreadsafe) ([]byte, error) {
+ return json.Marshal(JSONEvents{Events: events.Get()})
+}
+
+func srvPeerStates(params url.Values, errorCount UintThreadsafe, errContext string, toData todata.TODataThreadsafe, peerStates peer.CRStatesPeersThreadsafe) ([]byte, int) {
+ filter, err := NewPeerStateFilter(params, toData.Get().ServerTypes)
+ if err != nil {
+ HandleErr(errorCount, errContext, err)
+ return []byte(err.Error()), http.StatusBadRequest
+ }
+ bytes, err := json.Marshal(createAPIPeerStates(peerStates.Get(), filter, params))
+ return WrapErrCode(errorCount, errContext, bytes, err)
+}
+
+func srvStatSummary() ([]byte, int) {
+ return nil, http.StatusNotImplemented
+}
+
+func srvStats(staticAppData StaticAppData, healthPollInterval time.Duration, lastHealthDurations DurationMapThreadsafe, fetchCount UintThreadsafe, healthIteration UintThreadsafe, errorCount UintThreadsafe) ([]byte, error) {
+ return getStats(staticAppData, healthPollInterval, lastHealthDurations.Get(), fetchCount.Get(), healthIteration.Get(), errorCount.Get())
+}
+
+func srvConfigDoc(opsConfig OpsConfigThreadsafe) ([]byte, error) {
+ opsConfigCopy := opsConfig.Get()
+ // if the password is blank, leave it blank, so callers can see it's missing.
+ if opsConfigCopy.Password != "" {
+ opsConfigCopy.Password = "*****"
+ }
+ return json.Marshal(opsConfigCopy)
+}
+
+// TODO determine if this should use peerStates
+func srvAPICacheCount(localStates peer.CRStatesThreadsafe) []byte {
+ return []byte(strconv.Itoa(len(localStates.Get().Caches)))
+}
+
+func srvAPICacheAvailableCount(localStates peer.CRStatesThreadsafe) []byte {
+ return []byte(strconv.Itoa(cacheAvailableCount(localStates.Get().Caches)))
+}
+
+func srvAPICacheDownCount(localStates peer.CRStatesThreadsafe, monitorConfig TrafficMonitorConfigMapThreadsafe) []byte {
+ return []byte(strconv.Itoa(cacheDownCount(localStates.Get().Caches, monitorConfig.Get().TrafficServer)))
+}
+
+func srvAPIVersion(staticAppData StaticAppData) []byte {
+ s := "traffic_monitor-" + staticAppData.Version + "."
+ if len(staticAppData.GitRevision) > 6 {
+ s += staticAppData.GitRevision[:6]
+ } else {
+ s += staticAppData.GitRevision
+ }
+ return []byte(s)
+}
+
+func srvAPITrafficOpsURI(opsConfig OpsConfigThreadsafe) []byte {
+ return []byte(opsConfig.Get().Url)
+}
+func srvAPICacheStates(toData todata.TODataThreadsafe, statHistory StatHistoryThreadsafe, lastHealthDurations DurationMapThreadsafe, localStates peer.CRStatesThreadsafe, lastStats LastStatsThreadsafe, localCacheStatus CacheAvailableStatusThreadsafe) ([]byte, error) {
+ return json.Marshal(createCacheStatuses(toData.Get().ServerTypes, statHistory.Get(), lastHealthDurations.Get(), localStates.Get().Caches, lastStats.Get(), localCacheStatus))
+}
+
+func srvAPIBandwidthKbps(toData todata.TODataThreadsafe, lastStats LastStatsThreadsafe) []byte {
+ serverTypes := toData.Get().ServerTypes
+ kbpsStats := lastStats.Get()
+ sum := float64(0.0)
+ for cache, data := range kbpsStats.Caches {
+ if serverTypes[cache] != enum.CacheTypeEdge {
+ continue
+ }
+ sum += data.Bytes.PerSec / ds.BytesPerKilobit
+ }
+ return []byte(fmt.Sprintf("%f", sum))
+}
+func srvAPIBandwidthCapacityKbps(statHistoryThs StatHistoryThreadsafe) []byte {
+ statHistory := statHistoryThs.Get()
+ cap := int64(0)
+ for _, results := range statHistory {
+ if len(results) == 0 {
+ continue
+ }
+ cap += results[0].MaxKbps
+ }
+ return []byte(fmt.Sprintf("%d", cap))
+}
+
+// WrapUnpolledCheck wraps an http.HandlerFunc, returning ServiceUnavailable if any caches are unpolled; else, calling the wrapped func.
+func wrapUnpolledCheck(unpolledCaches UnpolledCachesThreadsafe, errorCount UintThreadsafe, f http.HandlerFunc) http.HandlerFunc {
+ return func(w http.ResponseWriter, r *http.Request) {
+ if unpolledCaches.Any() {
+ HandleErr(errorCount, r.URL.EscapedPath(), fmt.Errorf("service still starting, some caches unpolled"))
+ w.WriteHeader(http.StatusServiceUnavailable)
+ log.Write(w, []byte("Service Unavailable"), r.URL.EscapedPath())
+ return
+ }
+ f(w, r)
+ }
+}
+
+// MakeDispatchMap returns the map of paths to http.HandlerFuncs for dispatching.
+func MakeDispatchMap(
opsConfig OpsConfigThreadsafe,
toSession towrap.ITrafficOpsSession,
localStates peer.CRStatesThreadsafe,
@@ -454,122 +668,66 @@ func DataRequest(
lastStats LastStatsThreadsafe,
unpolledCaches UnpolledCachesThreadsafe,
monitorConfig TrafficMonitorConfigMapThreadsafe,
-) ([]byte, int) {
-
- // handleErr takes an error, and the request type it came from, and logs. It is ok to call with a nil error, in which case this is a no-op.
- handleErr := func(err error) {
- if err == nil {
- return
- }
- errorCount.Inc()
- log.Errorf("Request Error: %v\n", fmt.Errorf(req.Type.String()+": %v", err))
- }
-
- // wrapErr takes the body, err, and the data request Type which has been processed. It logs and deals with any error, and returns the appropriate bytes and response code for the `srvhttp`. It notably returns InternalServerError status on any error, for security reasons.
- wrapErr := func(body []byte, err error) ([]byte, int) {
- if err == nil {
- return body, http.StatusOK
- }
- handleErr(err)
- return nil, http.StatusInternalServerError
- }
-
- if unpolledCaches.Any() {
- handleErr(fmt.Errorf("service still starting, some caches unpolled"))
- return []byte("Service Unavailable"), http.StatusServiceUnavailable
- }
-
- switch req.Type {
- case srvhttp.TRConfig:
- cdnName := opsConfig.Get().CdnName
- if toSession == nil {
- return wrapErr(nil, fmt.Errorf("Unable to connect to Traffic Ops"))
- }
- if cdnName == "" {
- return wrapErr(nil, fmt.Errorf("No CDN Configured"))
- }
- return wrapErr(toSession.CRConfigRaw(cdnName))
- case srvhttp.TRStateDerived:
- return wrapErr(peer.CrstatesMarshall(combinedStates.Get()))
- case srvhttp.TRStateSelf:
- return wrapErr(peer.CrstatesMarshall(localStates.Get()))
- case srvhttp.CacheStats:
- filter, err := NewCacheStatFilter(req.Parameters, toData.Get().ServerTypes)
- if err != nil {
- handleErr(err)
- return []byte(err.Error()), http.StatusBadRequest
- }
- return wrapErr(cache.StatsMarshall(statHistory.Get(), filter, req.Parameters))
- case srvhttp.DSStats:
- filter, err := NewDSStatFilter(req.Parameters, toData.Get().DeliveryServiceTypes)
- if err != nil {
- handleErr(err)
- return []byte(err.Error()), http.StatusBadRequest
- }
- // TODO marshall beforehand, for performance? (test to see how often requests are made)
- return wrapErr(json.Marshal(dsStats.Get().JSON(filter, req.Parameters)))
- case srvhttp.EventLog:
- return wrapErr(json.Marshal(JSONEvents{Events: events.Get()}))
- case srvhttp.PeerStates:
- filter, err := NewPeerStateFilter(req.Parameters, toData.Get().ServerTypes)
- if err != nil {
- handleErr(err)
- return []byte(err.Error()), http.StatusBadRequest
- }
- return wrapErr(json.Marshal(createAPIPeerStates(peerStates.Get(), filter, req.Parameters)))
- case srvhttp.StatSummary:
- return nil, http.StatusNotImplemented
- case srvhttp.Stats:
- return wrapErr(getStats(staticAppData, healthPollInterval, lastHealthDurations.Get(), fetchCount.Get(), healthIteration.Get(), errorCount.Get()))
- case srvhttp.ConfigDoc:
- opsConfigCopy := opsConfig.Get()
- // if the password is blank, leave it blank, so callers can see it's missing.
- if opsConfigCopy.Password != "" {
- opsConfigCopy.Password = "*****"
- }
- return wrapErr(json.Marshal(opsConfigCopy))
- case srvhttp.APICacheCount: // TODO determine if this should use peerStates
- return []byte(strconv.Itoa(len(localStates.Get().Caches))), http.StatusOK
- case srvhttp.APICacheAvailableCount:
- return []byte(strconv.Itoa(cacheAvailableCount(localStates.Get().Caches))), http.StatusOK
- case srvhttp.APICacheDownCount:
- return []byte(strconv.Itoa(cacheDownCount(localStates.Get().Caches, monitorConfig.Get().TrafficServer))), http.StatusOK
- case srvhttp.APIVersion:
- s := "traffic_monitor-" + staticAppData.Version + "."
- if len(staticAppData.GitRevision) > 6 {
- s += staticAppData.GitRevision[:6]
- } else {
- s += staticAppData.GitRevision
- }
- return []byte(s), http.StatusOK
- case srvhttp.APITrafficOpsURI:
- return []byte(opsConfig.Get().Url), http.StatusOK
- case srvhttp.APICacheStates:
- return wrapErr(json.Marshal(createCacheStatuses(toData.Get().ServerTypes, statHistory.Get(),
- lastHealthDurations.Get(), localStates.Get().Caches, lastStats.Get(), localCacheStatus)))
- case srvhttp.APIBandwidthKbps:
- serverTypes := toData.Get().ServerTypes
- kbpsStats := lastStats.Get()
- sum := float64(0.0)
- for cache, data := range kbpsStats.Caches {
- if serverTypes[cache] != enum.CacheTypeEdge {
- continue
- }
- sum += data.Bytes.PerSec / ds.BytesPerKilobit
- }
- return []byte(fmt.Sprintf("%f", sum)), http.StatusOK
- case srvhttp.APIBandwidthCapacityKbps:
- statHistory := statHistory.Get()
- cap := int64(0)
- for _, results := range statHistory {
- if len(results) == 0 {
- continue
- }
- cap += results[0].MaxKbps
- }
- return []byte(fmt.Sprintf("%d", cap)), http.StatusOK
- default:
- return wrapErr(nil, fmt.Errorf("Unknown Request Type"))
+) map[string]http.HandlerFunc {
+
+ // wrap composes all universal wrapper functions. Right now, it's only the UnpolledCheck, but there may be others later. For example, security headers.
+ wrap := func(f http.HandlerFunc) http.HandlerFunc {
+ return wrapUnpolledCheck(unpolledCaches, errorCount, f)
+ }
+
+ return map[string]http.HandlerFunc{
+ "/publish/CrConfig": wrap(WrapErr(errorCount, func() ([]byte, error) {
+ return srvTRConfig(opsConfig, toSession)
+ })),
+ "/publish/CrStates": wrap(WrapParams(func(params url.Values, path string) ([]byte, int) {
+ bytes, err := srvTRState(params, localStates, combinedStates)
+ return WrapErrCode(errorCount, path, bytes, err)
+ })),
+ "/publish/CacheStats": wrap(WrapParams(func(params url.Values, path string) ([]byte, int) {
+ return srvCacheStats(params, errorCount, path, toData, statHistory)
+ })),
+ "/publish/DsStats": wrap(WrapParams(func(params url.Values, path string) ([]byte, int) {
+ return srvDSStats(params, errorCount, path, toData, dsStats)
+ })),
+ "/publish/EventLog": wrap(WrapErr(errorCount, func() ([]byte, error) {
+ return srvEventLog(events)
+ })),
+ "/publish/PeerStates": wrap(WrapParams(func(params url.Values, path string) ([]byte, int) {
+ return srvPeerStates(params, errorCount, path, toData, peerStates)
+ })),
+ "/publish/StatSummary": wrap(WrapParams(func(params url.Values, path string) ([]byte, int) {
+ return srvStatSummary()
+ })),
+ "/publish/Stats": wrap(WrapErr(errorCount, func() ([]byte, error) {
+ return srvStats(staticAppData, healthPollInterval, lastHealthDurations, fetchCount, healthIteration, errorCount)
+ })),
+ "/publish/ConfigDoc": wrap(WrapErr(errorCount, func() ([]byte, error) {
+ return srvConfigDoc(opsConfig)
+ })),
+ "/api/cache-count": wrap(WrapBytes(func() []byte {
+ return srvAPICacheCount(localStates)
+ })),
+ "/api/cache-available-count": wrap(WrapBytes(func() []byte {
+ return srvAPICacheAvailableCount(localStates)
+ })),
+ "/api/cache-down-count": wrap(WrapBytes(func() []byte {
+ return srvAPICacheDownCount(localStates, monitorConfig)
+ })),
+ "/api/version": wrap(WrapBytes(func() []byte {
+ return srvAPIVersion(staticAppData)
+ })),
+ "/api/traffic-ops-uri": wrap(WrapBytes(func() []byte {
+ return srvAPITrafficOpsURI(opsConfig)
+ })),
+ "/api/cache-statuses": wrap(WrapErr(errorCount, func() ([]byte, error) {
+ return srvAPICacheStates(toData, statHistory, lastHealthDurations, localStates, lastStats, localCacheStatus)
+ })),
+ "/api/bandwidth-kbps": wrap(WrapBytes(func() []byte {
+ return srvAPIBandwidthKbps(toData, lastStats)
+ })),
+ "/api/bandwidth-capacity-kbps": wrap(WrapBytes(func() []byte {
+ return srvAPIBandwidthCapacityKbps(statHistory)
+ })),
}
}
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/96ab1169/traffic_monitor/experimental/traffic_monitor/manager/opsconfig.go
----------------------------------------------------------------------
diff --git a/traffic_monitor/experimental/traffic_monitor/manager/opsconfig.go b/traffic_monitor/experimental/traffic_monitor/manager/opsconfig.go
index 813399f..f525181 100644
--- a/traffic_monitor/experimental/traffic_monitor/manager/opsconfig.go
+++ b/traffic_monitor/experimental/traffic_monitor/manager/opsconfig.go
@@ -125,30 +125,28 @@ func StartOpsConfigManager(
log.Errorf("OpsConfigManager: %v\n", err)
}
- err = httpServer.Run(func(req srvhttp.DataRequest) ([]byte, int) {
- return DataRequest(
- req,
- opsConfig,
- toSession,
- localStates,
- peerStates,
- combinedStates,
- statHistory,
- dsStats,
- events,
- staticAppData,
- healthPollInterval,
- lastHealthDurations,
- fetchCount,
- healthIteration,
- errorCount,
- toData,
- localCacheStatus,
- lastStats,
- unpolledCaches,
- monitorConfig,
- )
- }, listenAddress, cfg.ServeReadTimeout, cfg.ServeWriteTimeout)
+ endpoints := MakeDispatchMap(
+ opsConfig,
+ toSession,
+ localStates,
+ peerStates,
+ combinedStates,
+ statHistory,
+ dsStats,
+ events,
+ staticAppData,
+ healthPollInterval,
+ lastHealthDurations,
+ fetchCount,
+ healthIteration,
+ errorCount,
+ toData,
+ localCacheStatus,
+ lastStats,
+ unpolledCaches,
+ monitorConfig,
+ )
+ err = httpServer.Run(endpoints, listenAddress, cfg.ServeReadTimeout, cfg.ServeWriteTimeout)
if err != nil {
handleErr(fmt.Errorf("MonitorConfigPoller: error creating HTTP server: %s\n", err))
continue
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/96ab1169/traffic_monitor/experimental/traffic_monitor/srvhttp/srvhttp.go
----------------------------------------------------------------------
diff --git a/traffic_monitor/experimental/traffic_monitor/srvhttp/srvhttp.go b/traffic_monitor/experimental/traffic_monitor/srvhttp/srvhttp.go
index 0b93493..84fdf78 100644
--- a/traffic_monitor/experimental/traffic_monitor/srvhttp/srvhttp.go
+++ b/traffic_monitor/experimental/traffic_monitor/srvhttp/srvhttp.go
@@ -50,79 +50,34 @@ type CommonAPIData struct {
// each time the previous running server will be stopped, and the server will be
// restarted with the new port address and data request channel.
type Server struct {
- getData GetDataFunc
stoppableListener *stoppableListener.StoppableListener
stoppableListenerWaitGroup sync.WaitGroup
}
-// endpoints returns a map of HTTP paths to functions.
-// This is a function because Go doesn't have constant map literals.
-func (s Server) endpoints() (map[string]http.HandlerFunc, error) {
+func (s Server) registerEndpoints(sm *http.ServeMux, endpoints map[string]http.HandlerFunc) error {
handleRoot, err := s.handleRootFunc()
- handleSortableJs, err := s.handleSortableFunc()
if err != nil {
- return nil, fmt.Errorf("Error getting root endpoint: %v", err)
+ return fmt.Errorf("Error getting root endpoint: %v", err)
}
-
- // note: with the trailing slash, any non-trailing slash requests will get a 301 redirect
- return map[string]http.HandlerFunc{
- "/publish/CacheStats/": s.dataRequestFunc(CacheStats),
- "/publish/CacheStats": s.dataRequestFunc(CacheStats),
- "/publish/CrConfig/": s.dataRequestFunc(TRConfig),
- "/publish/CrConfig": s.dataRequestFunc(TRConfig),
- "/publish/CrStates/": s.handleCrStatesFunc(),
- "/publish/CrStates": s.handleCrStatesFunc(),
- "/publish/DsStats/": s.dataRequestFunc(DSStats),
- "/publish/DsStats": s.dataRequestFunc(DSStats),
- "/publish/EventLog/": s.dataRequestFunc(EventLog),
- "/publish/EventLog": s.dataRequestFunc(EventLog),
- "/publish/PeerStates/": s.dataRequestFunc(PeerStates),
- "/publish/PeerStates": s.dataRequestFunc(PeerStates),
- "/publish/StatSummary/": s.dataRequestFunc(StatSummary),
- "/publish/StatSummary": s.dataRequestFunc(StatSummary),
- "/publish/Stats/": s.dataRequestFunc(Stats),
- "/publish/Stats": s.dataRequestFunc(Stats),
- "/publish/ConfigDoc/": s.dataRequestFunc(ConfigDoc),
- "/publish/ConfigDoc": s.dataRequestFunc(ConfigDoc),
- "/api/cache-count/": s.dataRequestFunc(APICacheCount),
- "/api/cache-count": s.dataRequestFunc(APICacheCount),
- "/api/cache-available-count/": s.dataRequestFunc(APICacheAvailableCount),
- "/api/cache-available-count": s.dataRequestFunc(APICacheAvailableCount),
- "/api/cache-down-count/": s.dataRequestFunc(APICacheDownCount),
- "/api/cache-down-count": s.dataRequestFunc(APICacheDownCount),
- "/api/version/": s.dataRequestFunc(APIVersion),
- "/api/version": s.dataRequestFunc(APIVersion),
- "/api/traffic-ops-uri/": s.dataRequestFunc(APITrafficOpsURI),
- "/api/traffic-ops-uri": s.dataRequestFunc(APITrafficOpsURI),
- "/api/cache-statuses/": s.dataRequestFunc(APICacheStates),
- "/api/cache-statuses": s.dataRequestFunc(APICacheStates),
- "/api/bandwidth-kbps/": s.dataRequestFunc(APIBandwidthKbps),
- "/api/bandwidth-kbps": s.dataRequestFunc(APIBandwidthKbps),
- "/api/bandwidth-capacity-kbps/": s.dataRequestFunc(APIBandwidthCapacityKbps),
- "/api/bandwidth-capacity-kbps": s.dataRequestFunc(APIBandwidthCapacityKbps),
- "/": handleRoot,
- "/sorttable.js": handleSortableJs,
- }, nil
-}
-
-func (s Server) registerEndpoints(sm *http.ServeMux) error {
- endpoints, err := s.endpoints()
+ handleSortableJs, err := s.handleSortableFunc()
if err != nil {
- return err
+ return fmt.Errorf("Error getting sortable endpoint: %v", err)
}
+
for path, f := range endpoints {
sm.HandleFunc(path, f)
}
+
+ sm.HandleFunc("/", handleRoot)
+ sm.HandleFunc("/sorttable.js", handleSortableJs)
+
return nil
}
// Run runs a new HTTP service at the given addr, making data requests to the given c.
// Run may be called repeatedly, and each time, will shut down any existing service first.
// Run is NOT threadsafe, and MUST NOT be called concurrently by multiple goroutines.
-func (s Server) Run(f GetDataFunc, addr string, readTimeout time.Duration, writeTimeout time.Duration) error {
- // TODO make an object, which itself is not threadsafe, but which encapsulates all data so multiple
- // objects can be created and Run.
-
+func (s Server) Run(endpoints map[string]http.HandlerFunc, addr string, readTimeout time.Duration, writeTimeout time.Duration) error {
if s.stoppableListener != nil {
log.Infof("Stopping Web Server\n")
s.stoppableListener.Stop()
@@ -139,10 +94,8 @@ func (s Server) Run(f GetDataFunc, addr string, readTimeout time.Duration, write
return err
}
- s.getData = f
-
sm := http.NewServeMux()
- err = s.registerEndpoints(sm)
+ err = s.registerEndpoints(sm, endpoints)
if err != nil {
return err
}
@@ -168,113 +121,6 @@ func (s Server) Run(f GetDataFunc, addr string, readTimeout time.Duration, write
return nil
}
-// Type is the API request type which was received.
-type Type int
-
-const (
- // TRConfig represents a data request for the Traffic Router config
- TRConfig Type = (1 << iota)
- // TRStateDerived represents a data request for the derived data, aggregated from all Traffic Monitor peers.
- TRStateDerived
- // TRStateSelf represents a data request for the cache health data only from this Traffic Monitor, not from its peers.
- TRStateSelf
- // CacheStats represents a data request for general cache stats
- CacheStats
- // DSStats represents a data request for delivery service stats
- DSStats
- // EventLog represents a data request for the event log
- EventLog
- // PeerStates represents a data request for the cache health data gathered from Traffic Monitor peers.
- PeerStates
- // StatSummary represents a data request for a summary of the gathered stats
- StatSummary
- // Stats represents a data request for stats
- Stats
- // ConfigDoc represents a data request for this app's configuration data.
- ConfigDoc
- // APICacheCount represents a data request for the total number of caches this Traffic Monitor polls, as received Traffic Ops.
- APICacheCount
- // APICacheAvailableCount represents a data request for the number of caches flagged as available by this Traffic Monitor
- APICacheAvailableCount
- // APICacheDownCount represents a data request for the number of caches flagged as unavailable by this Traffic Monitor
- APICacheDownCount
- // APIVersion represents a data request for this app's version
- APIVersion
- // APITrafficOpsURI represents a data request for the Traffic Ops URI this app is configured to query
- APITrafficOpsURI
- // APICacheStates represents a data request for a summary of the cache states
- APICacheStates
- // APIBandwidthKbps represents a data request for the total bandwidth of all caches polled
- APIBandwidthKbps
- // APIBandwidthCapacityKbps represents a data request for the total bandwidth capacity of all caches polled
- APIBandwidthCapacityKbps
-)
-
-// String returns a string representation of the API request type.
-func (t Type) String() string {
- switch t {
- case TRConfig:
- return "TRConfig"
- case TRStateDerived:
- return "TRStateDerived"
- case TRStateSelf:
- return "TRStateSelf"
- case CacheStats:
- return "CacheStats"
- case DSStats:
- return "DSStats"
- case EventLog:
- return "EventLog"
- case PeerStates:
- return "PeerStates"
- case StatSummary:
- return "StatSummary"
- case Stats:
- return "Stats"
- case ConfigDoc:
- return "ConfigDoc"
- case APICacheCount:
- return "APICacheCount"
- case APICacheAvailableCount:
- return "APICacheAvailableCount"
- case APICacheDownCount:
- return "APICacheDownCount"
- case APIVersion:
- return "APIVersion"
- case APITrafficOpsURI:
- return "APITrafficOpsURI"
- case APICacheStates:
- return "APICacheStates"
- case APIBandwidthKbps:
- return "APIBandwidthKbps"
- case APIBandwidthCapacityKbps:
- return "APIBandwidthCapacityKbps"
- default:
- return "Invalid"
- }
-}
-
-// Format is the format protocol the API response will be.
-type Format int
-
-const (
- // XML represents that data should be serialized to XML
- XML Format = (1 << iota)
- // JSON represents that data should be serialized to JSON
- JSON
-)
-
-// DataRequest contains all the data about an API request necessary to form a response.
-type DataRequest struct {
- Type
- Format
- Date string
- Parameters map[string][]string
-}
-
-// GetDataFunc is a function which takes a DataRequest from a request made by a client, and returns the proper response to send to the client.
-type GetDataFunc func(DataRequest) ([]byte, int)
-
// ParametersStr takes the URL query parameters, and returns a string as used by the Traffic Monitor 1.0 endpoints "pp" key.
func ParametersStr(params url.Values) string {
pp := ""
@@ -294,30 +140,6 @@ func DateStr(t time.Time) string {
return t.UTC().Format("Mon Jan 02 15:04:05 UTC 2006")
}
-func (s Server) dataRequest(w http.ResponseWriter, req *http.Request, t Type, f Format) {
- //pp: "0=[my-ats-edge-cache-0], hc=[1]",
- //dateLayout := "Thu Oct 09 20:28:36 UTC 2014"
- dateLayout := "Mon Jan 02 15:04:05 MST 2006"
- data, responseCode := s.getData(DataRequest{
- Type: t,
- Format: f,
- Date: time.Now().UTC().Format(dateLayout),
- Parameters: req.URL.Query(),
- })
- if len(data) > 0 {
- w.WriteHeader(responseCode)
- if _, err := w.Write(data); err != nil {
- log.Warnf("received error writing data request %v: %v\n", t, err)
- }
-
- } else {
- w.WriteHeader(http.StatusInternalServerError)
- if _, err := w.Write([]byte("Internal Server Error")); err != nil {
- log.Warnf("received error writing data request %v: %v\n", t, err)
- }
- }
-}
-
func (s Server) handleRootFunc() (http.HandlerFunc, error) {
return s.handleFile("index.html")
}
@@ -335,19 +157,3 @@ func (s Server) handleFile(name string) (http.HandlerFunc, error) {
fmt.Fprintf(w, "%s", index)
}, nil
}
-
-func (s Server) handleCrStatesFunc() http.HandlerFunc {
- return func(w http.ResponseWriter, req *http.Request) {
- t := TRStateDerived
- if req.URL.RawQuery == "raw" {
- t = TRStateSelf
- }
- s.dataRequest(w, req, t, JSON)
- }
-}
-
-func (s Server) dataRequestFunc(t Type) http.HandlerFunc {
- return func(w http.ResponseWriter, r *http.Request) {
- s.dataRequest(w, r, t, JSON)
- }
-}
[10/12] incubator-trafficcontrol git commit: Fix TC-43: TR prints 'No
certificate data for https' for a ds with cert
Posted by da...@apache.org.
Fix TC-43: TR prints 'No certificate data for https' for a ds with cert
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/5c7bc65f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/5c7bc65f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/5c7bc65f
Branch: refs/heads/psql-rebase
Commit: 5c7bc65f2bec66fe2dffadeac71f958e742cdba3
Parents: 8586608
Author: John Shen <we...@cisco.com>
Authored: Tue Nov 15 06:02:14 2016 -0500
Committer: Eric Friedrich <ef...@cisco.com>
Committed: Tue Nov 15 20:03:29 2016 -0500
----------------------------------------------------------------------
.../traffic_router/core/config/CertificateChecker.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/5c7bc65f/traffic_router/core/src/main/java/com/comcast/cdn/traffic_control/traffic_router/core/config/CertificateChecker.java
----------------------------------------------------------------------
diff --git a/traffic_router/core/src/main/java/com/comcast/cdn/traffic_control/traffic_router/core/config/CertificateChecker.java b/traffic_router/core/src/main/java/com/comcast/cdn/traffic_control/traffic_router/core/config/CertificateChecker.java
index f6601c9..928b926 100644
--- a/traffic_router/core/src/main/java/com/comcast/cdn/traffic_control/traffic_router/core/config/CertificateChecker.java
+++ b/traffic_router/core/src/main/java/com/comcast/cdn/traffic_control/traffic_router/core/config/CertificateChecker.java
@@ -77,8 +77,6 @@ public class CertificateChecker {
return true;
}
- boolean hasValidCertificates = false;
-
for (int i = 0; i < domains.length(); i++) {
final String domain = domains.optString(i, "").replaceAll("^\\*\\.", "");
if (domain == null || domain.isEmpty()) {
@@ -87,13 +85,14 @@ public class CertificateChecker {
for (final CertificateData certificateData : certificateDataList) {
if (certificateData.getDeliveryservice().equals(deliveryServiceId)) {
- hasValidCertificates = true;
+ LOGGER.debug("Delivery Service " + deliveryServiceId + " has certificate data for https");
+ return true;
}
}
LOGGER.error("No certificate data for https " + deliveryServiceId + " domain " + domain);
}
- return hasValidCertificates;
+ return false;
}
private boolean supportsHttps(final JSONObject deliveryServiceJson, final JSONObject protocolJson) {
[08/12] incubator-trafficcontrol git commit: lock the sslkeys screen
to prevent scrolling issue. This fixes: TC-42
Posted by da...@apache.org.
lock the sslkeys screen to prevent scrolling issue. This fixes: TC-42
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/7837e8c1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/7837e8c1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/7837e8c1
Branch: refs/heads/psql-rebase
Commit: 7837e8c131a75ff26120d6ecc449c8c304fe9329
Parents: 579555d
Author: Dave Neuman <ne...@apache.org>
Authored: Mon Nov 14 11:40:11 2016 -0700
Committer: Jeremy Mitchell <mi...@gmail.com>
Committed: Mon Nov 14 13:33:48 2016 -0700
----------------------------------------------------------------------
traffic_ops/app/templates/delivery_service/edit.html.ep | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/7837e8c1/traffic_ops/app/templates/delivery_service/edit.html.ep
----------------------------------------------------------------------
diff --git a/traffic_ops/app/templates/delivery_service/edit.html.ep b/traffic_ops/app/templates/delivery_service/edit.html.ep
index 2980ce4..807fc8a 100644
--- a/traffic_ops/app/templates/delivery_service/edit.html.ep
+++ b/traffic_ops/app/templates/delivery_service/edit.html.ep
@@ -146,7 +146,7 @@
}
function addSslKeys() {
- $.fancybox({ type: 'iframe', href: "/ds/<%= $ds->id %>/sslkeys/add", padding: 0, autosize: true, fitToView: true, width: 750, minHeight: 800, modal:true, helpers: {overlay:{locked:false}}});
+ $.fancybox({ type: 'iframe', href: "/ds/<%= $ds->id %>/sslkeys/add", padding: 0, autosize: true, fitToView: true, width: 750, minHeight: 800, modal:true, helpers: {overlay:{locked:true}}});
}
var re_row_num = Object;
[06/12] incubator-trafficcontrol git commit: changed repo path from
github.com/Comcast to github.com/apache/incubator-trafficcontrol
Posted by da...@apache.org.
changed repo path from github.com/Comcast to github.com/apache/incubator-trafficcontrol
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/e3860428
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/e3860428
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/e3860428
Branch: refs/heads/psql-rebase
Commit: e3860428d01ccb237c4d373fdad7e16ff8c25f25
Parents: 4b74947
Author: Brian Luke <br...@cable.comcast.com>
Authored: Thu Nov 10 13:20:18 2016 -0700
Committer: Dan Kirkwood <da...@gmail.com>
Committed: Mon Nov 14 10:19:34 2016 -0700
----------------------------------------------------------------------
traffic_ops/experimental/ats_config/ats_config_cli.go | 4 ++--
traffic_ops/experimental/server/README.md | 2 +-
traffic_ops/experimental/server/api/asns.go | 2 +-
traffic_ops/experimental/server/api/cachegroups.go | 2 +-
.../experimental/server/api/cachegroups_parameters.go | 2 +-
traffic_ops/experimental/server/api/cachegroups_types.go | 2 +-
traffic_ops/experimental/server/api/cdns.go | 2 +-
traffic_ops/experimental/server/api/crconfig_snapshots.go | 2 +-
traffic_ops/experimental/server/api/deliveryservices.go | 2 +-
.../experimental/server/api/deliveryservices_regexes.go | 2 +-
.../experimental/server/api/deliveryservices_servers.go | 2 +-
.../experimental/server/api/deliveryservices_types.go | 2 +-
.../experimental/server/api/deliveryservices_users.go | 2 +-
traffic_ops/experimental/server/api/divisions.go | 2 +-
traffic_ops/experimental/server/api/domains.go | 2 +-
traffic_ops/experimental/server/api/extensions.go | 2 +-
traffic_ops/experimental/server/api/extensions_types.go | 2 +-
traffic_ops/experimental/server/api/federation_resolvers.go | 2 +-
traffic_ops/experimental/server/api/federation_users.go | 2 +-
traffic_ops/experimental/server/api/federations.go | 2 +-
.../experimental/server/api/federations_deliveryservices.go | 2 +-
.../server/api/federations_federation_resolvers.go | 2 +-
traffic_ops/experimental/server/api/goose_db_version.go | 2 +-
traffic_ops/experimental/server/api/log.go | 2 +-
traffic_ops/experimental/server/api/parameters.go | 2 +-
traffic_ops/experimental/server/api/phys_locations.go | 2 +-
traffic_ops/experimental/server/api/profiles.go | 2 +-
traffic_ops/experimental/server/api/profiles_parameters.go | 2 +-
traffic_ops/experimental/server/api/regexes.go | 2 +-
traffic_ops/experimental/server/api/regexes_types.go | 2 +-
traffic_ops/experimental/server/api/regions.go | 2 +-
traffic_ops/experimental/server/api/roles.go | 2 +-
traffic_ops/experimental/server/api/servers.go | 2 +-
traffic_ops/experimental/server/api/servers_types.go | 2 +-
traffic_ops/experimental/server/api/snapshot_crconfig.go | 4 ++--
traffic_ops/experimental/server/api/staticdnsentries.go | 2 +-
.../experimental/server/api/staticdnsentries_types.go | 2 +-
traffic_ops/experimental/server/api/stats_summary.go | 2 +-
traffic_ops/experimental/server/api/statuses.go | 2 +-
traffic_ops/experimental/server/api/users.go | 2 +-
traffic_ops/experimental/server/auth/auth.go | 2 +-
traffic_ops/experimental/server/csconfig/csconfig.go | 2 +-
traffic_ops/experimental/server/main.go | 6 +++---
traffic_ops/experimental/server/routes/routes.go | 8 ++++----
traffic_ops/experimental/server/tools/gen_goto2.go | 2 +-
45 files changed, 52 insertions(+), 52 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/ats_config/ats_config_cli.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/ats_config/ats_config_cli.go b/traffic_ops/experimental/ats_config/ats_config_cli.go
index 410c8f6..c596a5b 100644
--- a/traffic_ops/experimental/ats_config/ats_config_cli.go
+++ b/traffic_ops/experimental/ats_config/ats_config_cli.go
@@ -17,8 +17,8 @@ import (
"errors"
"flag"
"fmt"
- configfiles "github.com/Comcast/traffic_control/traffic_ops/experimental/ats_config/config_files"
- "github.com/Comcast/traffic_control/traffic_ops/experimental/ats_config/traffic_ops"
+ configfiles "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/ats_config/config_files"
+ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/ats_config/traffic_ops"
)
// Args encapsulates the command line arguments
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/README.md
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/README.md b/traffic_ops/experimental/server/README.md
index c877ec7..38b9261 100644
--- a/traffic_ops/experimental/server/README.md
+++ b/traffic_ops/experimental/server/README.md
@@ -90,7 +90,7 @@ Note: for now, we are using the web.go method to get the swagger pages up, later
```
[jvd@laika swagger-api]$ pwd
/Users/jvd/work/gh/swagger-api
- [jvd@laika swagger-api]$ swagger -apiPackage github.com/Comcast/traffic_control/traffic_ops/experimental/server/api -mainApiFile github.com/Comcast/traffic_control/traffic_ops/experimental/server/api/api.go -format go
+ [jvd@laika swagger-api]$ swagger -apiPackage github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/api -mainApiFile github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/api/api.go -format go
2016/01/16 09:57:34 Start parsing
2016/01/16 09:57:36 Finish parsing
2016/01/16 09:57:36 Doc file generated
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/asns.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/asns.go b/traffic_ops/experimental/server/api/asns.go
index a576c18..955ba23 100644
--- a/traffic_ops/experimental/server/api/asns.go
+++ b/traffic_ops/experimental/server/api/asns.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/cachegroups.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/cachegroups.go b/traffic_ops/experimental/server/api/cachegroups.go
index 0e30008..04b5178 100644
--- a/traffic_ops/experimental/server/api/cachegroups.go
+++ b/traffic_ops/experimental/server/api/cachegroups.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/cachegroups_parameters.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/cachegroups_parameters.go b/traffic_ops/experimental/server/api/cachegroups_parameters.go
index 62c3694..f82c8a2 100644
--- a/traffic_ops/experimental/server/api/cachegroups_parameters.go
+++ b/traffic_ops/experimental/server/api/cachegroups_parameters.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/cachegroups_types.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/cachegroups_types.go b/traffic_ops/experimental/server/api/cachegroups_types.go
index 5f7c0f8..654bf30 100644
--- a/traffic_ops/experimental/server/api/cachegroups_types.go
+++ b/traffic_ops/experimental/server/api/cachegroups_types.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/cdns.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/cdns.go b/traffic_ops/experimental/server/api/cdns.go
index 408f200..b7417c1 100644
--- a/traffic_ops/experimental/server/api/cdns.go
+++ b/traffic_ops/experimental/server/api/cdns.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/crconfig_snapshots.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/crconfig_snapshots.go b/traffic_ops/experimental/server/api/crconfig_snapshots.go
index f0ad8c8..175087a 100644
--- a/traffic_ops/experimental/server/api/crconfig_snapshots.go
+++ b/traffic_ops/experimental/server/api/crconfig_snapshots.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/deliveryservices.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/deliveryservices.go b/traffic_ops/experimental/server/api/deliveryservices.go
index fdb19a6..05e21e6 100644
--- a/traffic_ops/experimental/server/api/deliveryservices.go
+++ b/traffic_ops/experimental/server/api/deliveryservices.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/deliveryservices_regexes.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/deliveryservices_regexes.go b/traffic_ops/experimental/server/api/deliveryservices_regexes.go
index 1e899cd..b9ef4d4 100644
--- a/traffic_ops/experimental/server/api/deliveryservices_regexes.go
+++ b/traffic_ops/experimental/server/api/deliveryservices_regexes.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/deliveryservices_servers.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/deliveryservices_servers.go b/traffic_ops/experimental/server/api/deliveryservices_servers.go
index 8aff5e1..609e7d3 100644
--- a/traffic_ops/experimental/server/api/deliveryservices_servers.go
+++ b/traffic_ops/experimental/server/api/deliveryservices_servers.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/deliveryservices_types.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/deliveryservices_types.go b/traffic_ops/experimental/server/api/deliveryservices_types.go
index 6c20202..9751c85 100644
--- a/traffic_ops/experimental/server/api/deliveryservices_types.go
+++ b/traffic_ops/experimental/server/api/deliveryservices_types.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/deliveryservices_users.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/deliveryservices_users.go b/traffic_ops/experimental/server/api/deliveryservices_users.go
index 41fe3d8..e4eb871 100644
--- a/traffic_ops/experimental/server/api/deliveryservices_users.go
+++ b/traffic_ops/experimental/server/api/deliveryservices_users.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/divisions.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/divisions.go b/traffic_ops/experimental/server/api/divisions.go
index 241485d..7d963df 100644
--- a/traffic_ops/experimental/server/api/divisions.go
+++ b/traffic_ops/experimental/server/api/divisions.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/domains.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/domains.go b/traffic_ops/experimental/server/api/domains.go
index 58c688d..a84075b 100644
--- a/traffic_ops/experimental/server/api/domains.go
+++ b/traffic_ops/experimental/server/api/domains.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/extensions.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/extensions.go b/traffic_ops/experimental/server/api/extensions.go
index 9785777..0cb83d0 100644
--- a/traffic_ops/experimental/server/api/extensions.go
+++ b/traffic_ops/experimental/server/api/extensions.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/extensions_types.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/extensions_types.go b/traffic_ops/experimental/server/api/extensions_types.go
index 384ea13..63411e2 100644
--- a/traffic_ops/experimental/server/api/extensions_types.go
+++ b/traffic_ops/experimental/server/api/extensions_types.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/federation_resolvers.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/federation_resolvers.go b/traffic_ops/experimental/server/api/federation_resolvers.go
index 983888c..26fda86 100644
--- a/traffic_ops/experimental/server/api/federation_resolvers.go
+++ b/traffic_ops/experimental/server/api/federation_resolvers.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/federation_users.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/federation_users.go b/traffic_ops/experimental/server/api/federation_users.go
index 8f1d32b..bcc4bb5 100644
--- a/traffic_ops/experimental/server/api/federation_users.go
+++ b/traffic_ops/experimental/server/api/federation_users.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/federations.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/federations.go b/traffic_ops/experimental/server/api/federations.go
index f8433a8..43167e7 100644
--- a/traffic_ops/experimental/server/api/federations.go
+++ b/traffic_ops/experimental/server/api/federations.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/federations_deliveryservices.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/federations_deliveryservices.go b/traffic_ops/experimental/server/api/federations_deliveryservices.go
index 4e2df94..79906c6 100644
--- a/traffic_ops/experimental/server/api/federations_deliveryservices.go
+++ b/traffic_ops/experimental/server/api/federations_deliveryservices.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/federations_federation_resolvers.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/federations_federation_resolvers.go b/traffic_ops/experimental/server/api/federations_federation_resolvers.go
index dd24ce4..04fac67 100644
--- a/traffic_ops/experimental/server/api/federations_federation_resolvers.go
+++ b/traffic_ops/experimental/server/api/federations_federation_resolvers.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/goose_db_version.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/goose_db_version.go b/traffic_ops/experimental/server/api/goose_db_version.go
index 1b76890..1425737 100644
--- a/traffic_ops/experimental/server/api/goose_db_version.go
+++ b/traffic_ops/experimental/server/api/goose_db_version.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/log.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/log.go b/traffic_ops/experimental/server/api/log.go
index 8975238..0cb0f87 100644
--- a/traffic_ops/experimental/server/api/log.go
+++ b/traffic_ops/experimental/server/api/log.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/parameters.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/parameters.go b/traffic_ops/experimental/server/api/parameters.go
index 57abe34..9ce35bd 100644
--- a/traffic_ops/experimental/server/api/parameters.go
+++ b/traffic_ops/experimental/server/api/parameters.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/phys_locations.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/phys_locations.go b/traffic_ops/experimental/server/api/phys_locations.go
index a5c6ef8..8c46310 100644
--- a/traffic_ops/experimental/server/api/phys_locations.go
+++ b/traffic_ops/experimental/server/api/phys_locations.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/profiles.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/profiles.go b/traffic_ops/experimental/server/api/profiles.go
index c380a05..5a1c029 100644
--- a/traffic_ops/experimental/server/api/profiles.go
+++ b/traffic_ops/experimental/server/api/profiles.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/profiles_parameters.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/profiles_parameters.go b/traffic_ops/experimental/server/api/profiles_parameters.go
index d90bd35..0b4a477 100644
--- a/traffic_ops/experimental/server/api/profiles_parameters.go
+++ b/traffic_ops/experimental/server/api/profiles_parameters.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/regexes.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/regexes.go b/traffic_ops/experimental/server/api/regexes.go
index e64baea..727a86c 100644
--- a/traffic_ops/experimental/server/api/regexes.go
+++ b/traffic_ops/experimental/server/api/regexes.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/regexes_types.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/regexes_types.go b/traffic_ops/experimental/server/api/regexes_types.go
index beddf27..021fbcb 100644
--- a/traffic_ops/experimental/server/api/regexes_types.go
+++ b/traffic_ops/experimental/server/api/regexes_types.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/regions.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/regions.go b/traffic_ops/experimental/server/api/regions.go
index 49ce66a..8fd0d5a 100644
--- a/traffic_ops/experimental/server/api/regions.go
+++ b/traffic_ops/experimental/server/api/regions.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/roles.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/roles.go b/traffic_ops/experimental/server/api/roles.go
index 396a718..b36816a 100644
--- a/traffic_ops/experimental/server/api/roles.go
+++ b/traffic_ops/experimental/server/api/roles.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/servers.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/servers.go b/traffic_ops/experimental/server/api/servers.go
index 5a7c409..04ddc7e 100644
--- a/traffic_ops/experimental/server/api/servers.go
+++ b/traffic_ops/experimental/server/api/servers.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/servers_types.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/servers_types.go b/traffic_ops/experimental/server/api/servers_types.go
index f3663f0..382a2b7 100644
--- a/traffic_ops/experimental/server/api/servers_types.go
+++ b/traffic_ops/experimental/server/api/servers_types.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/snapshot_crconfig.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/snapshot_crconfig.go b/traffic_ops/experimental/server/api/snapshot_crconfig.go
index a888506..49ebb89 100644
--- a/traffic_ops/experimental/server/api/snapshot_crconfig.go
+++ b/traffic_ops/experimental/server/api/snapshot_crconfig.go
@@ -18,8 +18,8 @@ package api
import (
"encoding/json"
- "github.com/Comcast/traffic_control/traffic_ops/experimental/server/crconfig"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/crconfig"
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
)
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/staticdnsentries.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/staticdnsentries.go b/traffic_ops/experimental/server/api/staticdnsentries.go
index 4acab90..6c7f778 100644
--- a/traffic_ops/experimental/server/api/staticdnsentries.go
+++ b/traffic_ops/experimental/server/api/staticdnsentries.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/staticdnsentries_types.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/staticdnsentries_types.go b/traffic_ops/experimental/server/api/staticdnsentries_types.go
index f8547a2..ff82353 100644
--- a/traffic_ops/experimental/server/api/staticdnsentries_types.go
+++ b/traffic_ops/experimental/server/api/staticdnsentries_types.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/stats_summary.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/stats_summary.go b/traffic_ops/experimental/server/api/stats_summary.go
index 20d7fcd..4cc2a94 100644
--- a/traffic_ops/experimental/server/api/stats_summary.go
+++ b/traffic_ops/experimental/server/api/stats_summary.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
"log"
"time"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/statuses.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/statuses.go b/traffic_ops/experimental/server/api/statuses.go
index 7a6d260..c1c7638 100644
--- a/traffic_ops/experimental/server/api/statuses.go
+++ b/traffic_ops/experimental/server/api/statuses.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/api/users.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/api/users.go b/traffic_ops/experimental/server/api/users.go
index 5adf3c5..a4a4d99 100644
--- a/traffic_ops/experimental/server/api/users.go
+++ b/traffic_ops/experimental/server/api/users.go
@@ -18,7 +18,7 @@ package api
import (
"encoding/json"
- _ "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format" // needed for swagger
+ _ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format" // needed for swagger
"github.com/jmoiron/sqlx"
null "gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/auth/auth.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/auth/auth.go b/traffic_ops/experimental/server/auth/auth.go
index 157c968..5f1536f 100644
--- a/traffic_ops/experimental/server/auth/auth.go
+++ b/traffic_ops/experimental/server/auth/auth.go
@@ -20,7 +20,7 @@ import (
"encoding/hex"
"encoding/json"
"fmt"
- api "github.com/Comcast/traffic_control/traffic_ops/experimental/server/api"
+ api "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/api"
jwt "github.com/dgrijalva/jwt-go"
"github.com/jmoiron/sqlx"
"io/ioutil"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/csconfig/csconfig.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/csconfig/csconfig.go b/traffic_ops/experimental/server/csconfig/csconfig.go
index cf24527..50057c3 100644
--- a/traffic_ops/experimental/server/csconfig/csconfig.go
+++ b/traffic_ops/experimental/server/csconfig/csconfig.go
@@ -15,7 +15,7 @@ package csconfig
import (
"fmt"
- "github.com/Comcast/traffic_control/traffic_ops/experimental/server/api"
+ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/api"
"github.com/jmoiron/sqlx"
"gopkg.in/guregu/null.v3"
"log"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/main.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/main.go b/traffic_ops/experimental/server/main.go
index 8b3f284..cc8d8b3 100644
--- a/traffic_ops/experimental/server/main.go
+++ b/traffic_ops/experimental/server/main.go
@@ -14,9 +14,9 @@
package main
import (
- "github.com/Comcast/traffic_control/traffic_ops/experimental/server/auth"
- "github.com/Comcast/traffic_control/traffic_ops/experimental/server/db"
- "github.com/Comcast/traffic_control/traffic_ops/experimental/server/routes"
+ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/auth"
+ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/db"
+ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/routes"
"encoding/gob"
"encoding/json"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/routes/routes.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/routes/routes.go b/traffic_ops/experimental/server/routes/routes.go
index cc7ae37..d46cb24 100644
--- a/traffic_ops/experimental/server/routes/routes.go
+++ b/traffic_ops/experimental/server/routes/routes.go
@@ -16,10 +16,10 @@
package routes
import (
- "github.com/Comcast/traffic_control/traffic_ops/experimental/server/api"
- "github.com/Comcast/traffic_control/traffic_ops/experimental/server/auth"
- "github.com/Comcast/traffic_control/traffic_ops/experimental/server/csconfig"
- output "github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format"
+ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/api"
+ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/auth"
+ "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/csconfig"
+ output "github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format"
"encoding/json"
"fmt"
http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/blob/e3860428/traffic_ops/experimental/server/tools/gen_goto2.go
----------------------------------------------------------------------
diff --git a/traffic_ops/experimental/server/tools/gen_goto2.go b/traffic_ops/experimental/server/tools/gen_goto2.go
index 47b2be0..45c9c6d 100644
--- a/traffic_ops/experimental/server/tools/gen_goto2.go
+++ b/traffic_ops/experimental/server/tools/gen_goto2.go
@@ -134,7 +134,7 @@ func writeFile(schemas []ColumnSchema, table string) (int, error) {
if strings.Contains(sString, "null.") {
header += "null \"gopkg.in/guregu/null.v3\"\n"
}
- header += "_ \"github.com/Comcast/traffic_control/traffic_ops/experimental/server/output_format\" // needed for swagger\n"
+ header += "_ \"github.com/apache/incubator-trafficcontrol/traffic_ops/experimental/server/output_format\" // needed for swagger\n"
if strings.Contains(sString, "time.") {
header += "\"time\"\n"
}
[07/12] incubator-trafficcontrol git commit: This closes #68.
Posted by da...@apache.org.
This closes #68.
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/579555d7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/579555d7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/579555d7
Branch: refs/heads/psql-rebase
Commit: 579555d7516110c1288109f98ad0ffd9c36e6d05
Parents: e386042
Author: Dan Kirkwood <da...@gmail.com>
Authored: Mon Nov 14 10:20:18 2016 -0700
Committer: Dan Kirkwood <da...@gmail.com>
Committed: Mon Nov 14 10:20:18 2016 -0700
----------------------------------------------------------------------
----------------------------------------------------------------------
[12/12] incubator-trafficcontrol git commit: Merge branch 'master' of
github.com:apache/incubator-trafficcontrol into psql-rebase
Posted by da...@apache.org.
Merge branch 'master' of github.com:apache/incubator-trafficcontrol into psql-rebase
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/25f04116
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/25f04116
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/25f04116
Branch: refs/heads/psql-rebase
Commit: 25f04116d4b4bb6a0d7f080d4d01a01330e76430
Parents: 7978fc7 f39c1fd
Author: Dan Kirkwood <da...@gmail.com>
Authored: Wed Nov 16 18:33:44 2016 -0700
Committer: Dan Kirkwood <da...@gmail.com>
Committed: Wed Nov 16 18:33:44 2016 -0700
----------------------------------------------------------------------
.../traffic_router/core/config/CertificateChecker.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
[05/12] incubator-trafficcontrol git commit: This closes #60
Posted by da...@apache.org.
This closes #60
Project: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/commit/4b749476
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/tree/4b749476
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafficcontrol/diff/4b749476
Branch: refs/heads/psql-rebase
Commit: 4b74947610718f3e776b352017337d7b1cf76c53
Parents: cda0f77
Author: Dave Neuman <ne...@apache.org>
Authored: Mon Nov 14 10:08:34 2016 -0700
Committer: Dave Neuman <ne...@apache.org>
Committed: Mon Nov 14 10:08:34 2016 -0700
----------------------------------------------------------------------
----------------------------------------------------------------------