Skip to content

Commit ec82623

Browse files
committed
fixes
1 parent a0fd5be commit ec82623

11 files changed

Lines changed: 585 additions & 2166 deletions

connect/transport.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ func DefaultConnectHandlerSettings() *ConnectHandlerSettings {
7979
ListenDnsPort: 53,
8080
EnableProxyProtocol: true,
8181
FramerSettings: connect.DefaultFramerSettings(),
82-
TransportTlsSettings: DefaultTransportTlsSettings(),
82+
TransportTlsSettings: server.DefaultTransportTlsSettings(),
8383

8484
ConnectionAnnounceTimeout: 5 * time.Second,
8585
ConnectionAnnounceSettings: *DefaultConnectionAnnounceSettings(),
@@ -100,7 +100,7 @@ type ConnectHandlerSettings struct {
100100
ListenDnsPort int
101101
EnableProxyProtocol bool
102102
FramerSettings *connect.FramerSettings
103-
TransportTlsSettings *TransportTlsSettings
103+
TransportTlsSettings *server.TransportTlsSettings
104104
ConnectionAnnounceTimeout time.Duration
105105
ConnectionAnnounceSettings
106106
ConnectionRateLimitSettings
@@ -113,7 +113,7 @@ type ConnectHandler struct {
113113
exchange *Exchange
114114
settings *ConnectHandlerSettings
115115

116-
transportTls *TransportTls
116+
transportTls *server.TransportTls
117117
serviceTransitionTime time.Time
118118
}
119119

@@ -124,10 +124,10 @@ func NewConnectHandlerWithDefaults(ctx context.Context, handlerId server.Id, exc
124124
func NewConnectHandler(ctx context.Context, handlerId server.Id, exchange *Exchange, settings *ConnectHandlerSettings) *ConnectHandler {
125125
cancelCtx, cancel := context.WithCancel(ctx)
126126

127-
transportTls, err := NewTransportTlsFromConfig(settings.TransportTlsSettings)
127+
transportTls, err := server.NewTransportTlsFromConfig(settings.TransportTlsSettings)
128128
if err != nil {
129129
glog.Errorf("[c]Could not initialize tls config. Disabling transport. = %s\n", err)
130-
transportTls = NewTransportTls(map[string]bool{}, DefaultTransportTlsSettings())
130+
transportTls = server.NewTransportTls(map[string]bool{}, server.DefaultTransportTlsSettings())
131131
}
132132

133133
h := &ConnectHandler{

connect/transport_proxy.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ func DefaultProxyConnectHandlerSettings() *ProxyConnectHandlerSettings {
5555
EnableProxyProtocol: true,
5656
// ProxyConnectTimeout: 15 * time.Second,
5757

58-
TransportTlsSettings: DefaultTransportTlsSettings(),
58+
TransportTlsSettings: server.DefaultTransportTlsSettings(),
5959
}
6060
}
6161

@@ -70,15 +70,15 @@ type ProxyConnectHandlerSettings struct {
7070
// ProxyConnectTimeout time.Duration
7171
// Mtu int
7272

73-
TransportTlsSettings *TransportTlsSettings
73+
TransportTlsSettings *server.TransportTlsSettings
7474
}
7575

7676
type ProxyConnectHandler struct {
7777
ctx context.Context
7878
cancel context.CancelFunc
7979
handlerId server.Id
8080
exchange *Exchange
81-
transportTls *TransportTls
81+
transportTls *server.TransportTls
8282
settings *ProxyConnectHandlerSettings
8383

8484
// stateLock sync.Mutex
@@ -105,10 +105,10 @@ func NewProxyConnectHandler(
105105
settings *ProxyConnectHandlerSettings) *ProxyConnectHandler {
106106
cancelCtx, cancel := context.WithCancel(ctx)
107107

108-
transportTls, err := NewTransportTlsFromConfig(settings.TransportTlsSettings)
108+
transportTls, err := server.NewTransportTlsFromConfig(settings.TransportTlsSettings)
109109
if err != nil {
110110
glog.Errorf("[c]Could not initialize tls config. Disabling transport. = %s\n", err)
111-
transportTls = NewTransportTls(map[string]bool{}, DefaultTransportTlsSettings())
111+
transportTls = server.NewTransportTls(map[string]bool{}, server.DefaultTransportTlsSettings())
112112
}
113113

114114
h := &ProxyConnectHandler{

proxy/README.md

Lines changed: 0 additions & 71 deletions
This file was deleted.

0 commit comments

Comments
 (0)