1 Star 0 Fork 0

zhangjungang/beats

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
.github
auditbeat
deploy/kubernetes
dev-tools
docs/devguide
filebeat
generator
heartbeat
libbeat
_meta
api
autodiscover
beat
cfgfile
cloudid
cmd
common
atomic
bus
cfgwarn
cli
docker
dtfmt
file
fmtstr
jsontransform
kubernetes
match
op
schema
streambuf
terminal
testdata
backoff.go
bytes.go
bytes_test.go
cache.go
cache_test.go
config.go
config_test.go
csv.go
csv_test.go
datetime.go
datetime_test.go
endpoint.go
event.go
event_test.go
field.go
field_test.go
flags.go
flags_test.go
mapstr.go
mapstr_pointer.go
mapstr_pointer_test.go
mapstr_test.go
math.go
math_test.go
net.go
net_test.go
statuses.go
string.go
stringset.go
tuples.go
tuples_test.go
url.go
url_test.go
version.go
version_test.go
dashboards
docs
keystore
kibana
logp
metric/system
ml-importer
mock
monitoring
outputs
paths
plugin
processors
publisher
scripts
service
setup/kibana
template
testing
tests
version
.gitignore
Dockerfile
Makefile
README.md
docker-compose.yml
libbeat.go
libbeat_test.go
metricbeat
packetbeat
script
testing/environments
vendor
winlogbeat
.appveyor.yml
.editorconfig
.gitattributes
.gitignore
.go-version
.pylintrc
.travis.yml
CHANGELOG.asciidoc
CONTRIBUTING.md
LICENSE.txt
Makefile
NOTICE.txt
README.md
Vagrantfile
codecov.yml
reviewdog.yml
setup.yml
克隆/下载
url.go 1.32 KB
一键复制 编辑 原始数据 按行查看 历史
package common
import (
"fmt"
"net"
"net/url"
"regexp"
"strconv"
"strings"
)
var hasScheme = regexp.MustCompile(`^([a-z][a-z0-9+\-.]*)://`)
// MakeURL creates the url based on the url configuration.
// Adds missing parts with defaults (scheme, host, port)
func MakeURL(defaultScheme string, defaultPath string, rawURL string, defaultPort int) (string, error) {
if defaultScheme == "" {
defaultScheme = "http"
}
if !hasScheme.MatchString(rawURL) {
rawURL = fmt.Sprintf("%v://%v", defaultScheme, rawURL)
}
addr, err := url.Parse(rawURL)
if err != nil {
return "", err
}
scheme := addr.Scheme
host := addr.Host
port := strconv.Itoa(defaultPort)
if host == "" {
host = "localhost"
} else {
// split host and optional port
if splitHost, splitPort, err := net.SplitHostPort(host); err == nil {
host = splitHost
port = splitPort
}
// Check if ipv6
if strings.Count(host, ":") > 1 && strings.Count(host, "]") == 0 {
host = "[" + host + "]"
}
}
// Assign default path if not set
if addr.Path == "" {
addr.Path = defaultPath
}
// reconstruct url
addr.Scheme = scheme
addr.Host = host + ":" + port
return addr.String(), nil
}
func EncodeURLParams(url string, params url.Values) string {
if len(params) == 0 {
return url
}
return strings.Join([]string{url, "?", params.Encode()}, "")
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/zhangjungang/beats.git
git@gitee.com:zhangjungang/beats.git
zhangjungang
beats
beats
v6.2.0

搜索帮助