summaryrefslogtreecommitdiff
path: root/edge
diff options
context:
space:
mode:
authorkadisi <iamkadisi@163.com>2020-04-24 00:10:26 +0800
committerkadisi <iamkadisi@163.com>2020-04-30 18:41:47 +0800
commitaf32c17f33a4c75b218025a7e3597d2940ee4396 (patch)
tree4d315a7f6e0dc03002e7ef283e1da73daabff29e /edge
parentsupport kubectl logs (diff)
downloadkubeedge-af32c17f33a4c75b218025a7e3597d2940ee4396.tar.gz
add create sream cert doc instruction
Signed-off-by: kadisi <iamkadisi@163.com>
Diffstat (limited to 'edge')
-rw-r--r--edge/pkg/edgestream/edgestream.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/edge/pkg/edgestream/edgestream.go b/edge/pkg/edgestream/edgestream.go
index e7da1276b..37f3fbc07 100644
--- a/edge/pkg/edgestream/edgestream.go
+++ b/edge/pkg/edgestream/edgestream.go
@@ -40,13 +40,13 @@ const (
type edgestream struct {
enable bool
- tunnelSessionID string
+ hostnameOveride string
}
func newEdgeStream(enable bool, hostnameOverride string) *edgestream {
return &edgestream{
enable: enable,
- tunnelSessionID: hostnameOverride,
+ hostnameOveride: hostnameOverride,
}
}
@@ -107,7 +107,7 @@ func (e *edgestream) TLSClientConnect(url url.URL, tlsConfig *tls.Config) error
HandshakeTimeout: time.Duration(config.Config.HandshakeTimeout) * time.Second,
}
header := http.Header{}
- header.Add(stream.TunnelSessionID, e.tunnelSessionID)
+ header.Add(stream.TunnelSessionID, e.hostnameOveride)
con, _, err := dial.Dial(url.String(), header)
if err != nil {