From 0ca18e5e7d4d0e94ea33dcb5cc851fa5309bd45f Mon Sep 17 00:00:00 2001 From: Patrick Date: Wed, 24 May 2023 10:32:31 +0800 Subject: [PATCH] use downstream direct remote address --- .../slime/modules/lazyload/controllers/producer.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/staging/src/slime.io/slime/modules/lazyload/controllers/producer.go b/staging/src/slime.io/slime/modules/lazyload/controllers/producer.go index f1a0d630..e94f431d 100644 --- a/staging/src/slime.io/slime/modules/lazyload/controllers/producer.go +++ b/staging/src/slime.io/slime/modules/lazyload/controllers/producer.go @@ -314,13 +314,13 @@ func accessLogHandler(logEntry []*data_accesslog.HTTPAccessLogEntry, ipToSvcCach func fetchSourceIp(entry *data_accesslog.HTTPAccessLogEntry) (string, error) { log := log.WithField("reporter", "accesslog convertor").WithField("function", "fetchSourceIp") - if entry.CommonProperties.DownstreamRemoteAddress == nil { - log.Debugf("DownstreamRemoteAddress is nil, skip") + if entry.CommonProperties.DownstreamDirectRemoteAddress == nil { + log.Debugf("DownstreamDirectRemoteAddress is nil, skip") return "", nil } - downstreamSock, ok := entry.CommonProperties.DownstreamRemoteAddress.Address.(*envoy_config_core.Address_SocketAddress) + downstreamSock, ok := entry.CommonProperties.DownstreamDirectRemoteAddress.Address.(*envoy_config_core.Address_SocketAddress) if !ok { - return "", stderrors.New("wrong type of DownstreamRemoteAddress") + return "", stderrors.New("wrong type of DownstreamDirectRemoteAddress") } if downstreamSock == nil || downstreamSock.SocketAddress == nil { return "", stderrors.New("downstream socket address is nil")