diff --git a/analyzer/tcp/openvpn.go b/analyzer/tcp/openvpn.go
index ad9d70f..ff28ef3 100644
--- a/analyzer/tcp/openvpn.go
+++ b/analyzer/tcp/openvpn.go
@@ -20,7 +20,7 @@ func (a *OpenVpnAnalyzer) Limit() int {
 }
 
 func (a *OpenVpnAnalyzer) NewTCP(info analyzer.TCPInfo, logger analyzer.Logger) analyzer.TCPStream {
-	return newOpenVpnTCPStream(logger)
+	return newOpenVpnTcpStream(logger)
 }
 
 type openVpnStream struct {
@@ -52,7 +52,7 @@ type openVpnTcpPkt struct {
 	// payload []byte
 }
 
-func newOpenVpnTCPStream(logger analyzer.Logger) *openVpnStream {
+func newOpenVpnTcpStream(logger analyzer.Logger) *openVpnStream {
 	s := &openVpnStream{
 		logger:   logger,
 		reqBuf:   &utils.ByteBuffer{},
diff --git a/analyzer/udp/openvpn.go b/analyzer/udp/openvpn.go
index 0c77a0a..ae0cb90 100644
--- a/analyzer/udp/openvpn.go
+++ b/analyzer/udp/openvpn.go
@@ -20,7 +20,7 @@ func (a *OpenVpnAnalyzer) Limit() int {
 }
 
 func (a *OpenVpnAnalyzer) NewUDP(info analyzer.UDPInfo, logger analyzer.Logger) analyzer.UDPStream {
-	return newOpenVPNTCPStream(logger)
+	return newOpenVPNUdpStream(logger)
 }
 
 type openVpnStream struct {
@@ -53,7 +53,7 @@ type openVpnUdpPkt struct {
 	// payload []byte
 }
 
-func newOpenVPNTCPStream(logger analyzer.Logger) *openVpnStream {
+func newOpenVPNUdpStream(logger analyzer.Logger) *openVpnStream {
 	s := &openVpnStream{
 		logger:   logger,
 		pktLimit: internal.OpenVpnUdpPktDefaultLimit,