diff --git a/core/metadata/ProcessorK8sMetadata.cpp b/core/metadata/ProcessorK8sMetadata.cpp index c062177fda..3f7923dc90 100644 --- a/core/metadata/ProcessorK8sMetadata.cpp +++ b/core/metadata/ProcessorK8sMetadata.cpp @@ -35,44 +35,44 @@ void ProcessorK8sMetadata::Process(PipelineEventGroup& logGroup) { return; } EventsContainer& events = logGroup.MutableEvents(); - std::vector container_vec; - std::vector remote_ip_vec; - std::vector cotainer_not_tag; + std::vector containerVec; + std::vector remoteIpVec; + std::vector cotainerNotTag; for (size_t rIdx = 0; rIdx < events.size(); ++rIdx) { - if (!ProcessEvent(events[rIdx], container_vec, remote_ip_vec)) { - cotainer_not_tag.push_back(rIdx); + if (!ProcessEvent(events[rIdx], containerVec, remoteIpVec)) { + cotainerNotTag.push_back(rIdx); } } auto& k8sMetadata = K8sMetadata::GetInstance(); - if (!container_vec.empty()) { - k8sMetadata.GetByContainerIdsFromServer(container_vec); + if (!containerVec.empty()) { + k8sMetadata.GetByContainerIdsFromServer(containerVec); } - if (!remote_ip_vec.empty()) { - k8sMetadata.GetByIpsFromServer(remote_ip_vec); + if (!remoteIpVec.empty()) { + k8sMetadata.GetByIpsFromServer(remoteIpVec); } - for (size_t i = 0; i < cotainer_not_tag.size(); ++i) { - ProcessEvent(events[i], container_vec, remote_ip_vec); + for (size_t i = 0; i < cotainerNotTag.size(); ++i) { + ProcessEvent(events[i], containerVec, remoteIpVec); } - cotainer_not_tag.clear(); - container_vec.clear(); - remote_ip_vec.clear(); + cotainerNotTag.clear(); + containerVec.clear(); + remoteIpVec.clear(); } -bool ProcessorK8sMetadata::ProcessEvent(PipelineEventPtr& e, std::vector& container_vec, std::vector& remote_ip_vec) { +bool ProcessorK8sMetadata::ProcessEvent(PipelineEventPtr& e, std::vector& containerVec, std::vector& remoteIpVec) { if (!IsSupportedEvent(e)) { return true; } if (e.Is()) { - return ProcessEventForMetric(e.Cast(), container_vec, remote_ip_vec); + return ProcessEventForMetric(e.Cast(), containerVec, remoteIpVec); } else if (e.Is()) { - return ProcessEventForSpan(e.Cast(), container_vec, remote_ip_vec); + return ProcessEventForSpan(e.Cast(), containerVec, remoteIpVec); } return true; } -bool ProcessorK8sMetadata::ProcessEventForSpan(SpanEvent& e, std::vector& container_vec, std::vector& remote_ip_vec) { +bool ProcessorK8sMetadata::ProcessEventForSpan(SpanEvent& e, std::vector& containerVec, std::vector& remoteIpVec) { bool res = true; auto& k8sMetadata = K8sMetadata::GetInstance(); @@ -82,7 +82,7 @@ bool ProcessorK8sMetadata::ProcessEventForSpan(SpanEvent& e, std::vector container_info = k8sMetadata.GetInfoByContainerIdFromCache(containerId); if (container_info == nullptr) { - container_vec.push_back(containerId); + containerVec.push_back(containerId); res = false; } else { e.SetTag("workloadName", container_info->workloadName); @@ -99,7 +99,7 @@ bool ProcessorK8sMetadata::ProcessEventForSpan(SpanEvent& e, std::vector ip_info = k8sMetadata.GetInfoByIpFromCache(remote_ip); if (ip_info == nullptr) { - remote_ip_vec.push_back(remote_ip); + remoteIpVec.push_back(remote_ip); res = false; } else { e.SetTag("peerWorkloadName", ip_info->workloadName); @@ -111,7 +111,7 @@ bool ProcessorK8sMetadata::ProcessEventForSpan(SpanEvent& e, std::vector& container_vec, std::vector& remote_ip_vec) { +bool ProcessorK8sMetadata::ProcessEventForMetric(MetricEvent& e, std::vector& containerVec, std::vector& remoteIpVec) { bool res = true; auto& k8sMetadata = K8sMetadata::GetInstance(); @@ -121,7 +121,7 @@ bool ProcessorK8sMetadata::ProcessEventForMetric(MetricEvent& e, std::vector container_info = k8sMetadata.GetInfoByContainerIdFromCache(containerId); if (container_info == nullptr) { - container_vec.push_back(containerId); + containerVec.push_back(containerId); res = false; } else { e.SetTag("workloadName", container_info->workloadName); @@ -138,7 +138,7 @@ bool ProcessorK8sMetadata::ProcessEventForMetric(MetricEvent& e, std::vector ip_info = k8sMetadata.GetInfoByIpFromCache(remote_ip); if (ip_info == nullptr) { - remote_ip_vec.push_back(remote_ip); + remoteIpVec.push_back(remote_ip); res = false; } else { e.SetTag("peerWorkloadName", ip_info->workloadName);