Skip to content

Commit db1be10

Browse files
committed
Fix existing TCP and UDP tests.
1 parent 8f200a5 commit db1be10

File tree

2 files changed

+7
-4
lines changed

2 files changed

+7
-4
lines changed

service/tcp_test.go

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -224,7 +224,7 @@ type probeTestMetrics struct {
224224

225225
var _ TCPMetrics = (*probeTestMetrics)(nil)
226226

227-
func (m *probeTestMetrics) AddClosedTCPConnection(clientInfo ipinfo.IPInfo, accessKey, status string, data metrics.ProxyMetrics, duration time.Duration) {
227+
func (m *probeTestMetrics) AddClosedTCPConnection(addr net.Addr, accessKey string, status string, data metrics.ProxyMetrics, duration time.Duration) {
228228
m.mu.Lock()
229229
m.closeStatus = append(m.closeStatus, status)
230230
m.mu.Unlock()
@@ -233,8 +233,11 @@ func (m *probeTestMetrics) AddClosedTCPConnection(clientInfo ipinfo.IPInfo, acce
233233
func (m *probeTestMetrics) GetIPInfo(net.IP) (ipinfo.IPInfo, error) {
234234
return ipinfo.IPInfo{}, nil
235235
}
236-
func (m *probeTestMetrics) AddOpenTCPConnection(clientInfo ipinfo.IPInfo) {
236+
func (m *probeTestMetrics) AddOpenTCPConnection(addr net.Addr) {
237237
}
238+
239+
func (m *probeTestMetrics) AddAuthenticatedTCPConnection(ip net.Addr, accessKey string) {}
240+
238241
func (m *probeTestMetrics) AddTCPProbe(status, drainResult string, port int, clientProxyBytes int64) {
239242
m.mu.Lock()
240243
m.probeData = append(m.probeData, clientProxyBytes)

service/udp_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -113,10 +113,10 @@ func (m *natTestMetrics) AddUDPPacketFromClient(clientInfo ipinfo.IPInfo, access
113113
}
114114
func (m *natTestMetrics) AddUDPPacketFromTarget(clientInfo ipinfo.IPInfo, accessKey, status string, targetProxyBytes, proxyClientBytes int) {
115115
}
116-
func (m *natTestMetrics) AddUDPNatEntry() {
116+
func (m *natTestMetrics) AddUDPNatEntry(ip net.Addr, accessKey string) {
117117
m.natEntriesAdded++
118118
}
119-
func (m *natTestMetrics) RemoveUDPNatEntry() {}
119+
func (m *natTestMetrics) RemoveUDPNatEntry(ip net.Addr, accessKey string) {}
120120
func (m *natTestMetrics) AddUDPCipherSearch(accessKeyFound bool, timeToCipher time.Duration) {}
121121

122122
// Takes a validation policy, and returns the metrics it

0 commit comments

Comments
 (0)