Skip to content

Commit 3fa69f9

Browse files
rosenlolzf575
authored andcommitted
[ingester] fix query custom k8s labels
Signed-off-by: rosenlo <[email protected]>
1 parent 5f8e8af commit 3fa69f9

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

server/ingester/flow_log/exporter/universal_tag.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -217,15 +217,16 @@ func (u *UniversalTagsManager) getAuto(autoType DeviceType, autoID uint32, isIPv
217217
}
218218

219219
func (u *UniversalTagsManager) QueryCustomK8sLabels(podID uint32) Labels {
220-
return u.podIDLabelsMap[podID]
220+
return u.universalTagMaps.podK8SLabelMap[podID]
221221
}
222222

223223
type UniversalTagsManager struct {
224224
config *config.Config
225225
universalTagMaps *UniversalTagMaps
226226
tapPortNameMap map[uint64]string
227-
podIDLabelsMap map[uint32]Labels
228-
k8sLabelsRegexp *regexp.Regexp
227+
// Deprecated
228+
podIDLabelsMap map[uint32]Labels
229+
k8sLabelsRegexp *regexp.Regexp
229230

230231
connection *sql.DB
231232
grpcSession *grpc.GrpcSession

0 commit comments

Comments
 (0)