Code Review
/
nonrtric
/
plt
/
ranpm.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Release notes & Roll version after i-release 1.1.0 -> 1.2.0
[nonrtric/plt/ranpm.git]
/
pm-file-converter
/
common
/
utils
/
utils.go
diff --git
a/pm-file-converter/common/utils/utils.go
b/pm-file-converter/common/utils/utils.go
index
5466d2c
..
7be5819
100644
(file)
--- a/
pm-file-converter/common/utils/utils.go
+++ b/
pm-file-converter/common/utils/utils.go
@@
-21,15
+21,16
@@
package utils
import (
"bytes"
import (
"bytes"
- log "github.com/sirupsen/logrus"
"main/components/kafkacollector"
"net/http"
"main/components/kafkacollector"
"net/http"
+
+ log "github.com/sirupsen/logrus"
)
var httpclient = &http.Client{}
// Send a http request with json (json may be nil)
)
var httpclient = &http.Client{}
// Send a http request with json (json may be nil)
-func Send
_http_r
equest(json []byte, method string, url string, retry bool, useAuth bool) bool {
+func Send
HttpR
equest(json []byte, method string, url string, retry bool, useAuth bool) bool {
// set the HTTP method, url, and request body
var req *http.Request
// set the HTTP method, url, and request body
var req *http.Request
@@
-46,7
+47,7
@@
func Send_http_request(json []byte, method string, url string, retry bool, useAu
}
if useAuth {
}
if useAuth {
- token, err := kafkacollector.Fetch
_t
oken()
+ token, err := kafkacollector.Fetch
T
oken()
if err != nil {
log.Error("Cannot fetch token for http request: ", err)
return false
if err != nil {
log.Error("Cannot fetch token for http request: ", err)
return false