MCPcopy
hub / github.com/deepflowio/deepflow / UpdateNativeTag

Function UpdateNativeTag

server/common/module_shared.go:143–159  ·  view source on GitHub ↗

When adding or removing native_tag, you need to call the interface

(op nativetag.NativeTagOP, orgId uint16, nativeTag *nativetag.NativeTag)

Source from the content-addressed store, hash-verified

141
142// When adding or removing native_tag, you need to call the interface
143func UpdateNativeTag(op nativetag.NativeTagOP, orgId uint16, nativeTag *nativetag.NativeTag) error {
144 log.Infof("orgId %d %s native tag: %+v", orgId, op, nativeTag)
145 if ingesterOrgHanders == nil {
146 err := fmt.Errorf("ingester is not ready, update native tag failed")
147 log.Error(err)
148 return err
149 }
150 for _, ingesterOrgHander := range ingesterOrgHanders {
151 err := ingesterOrgHander.UpdateNativeTag(op, orgId, nativeTag)
152 if err != nil {
153 log.Error(err)
154 return err
155 }
156 }
157 nativetag.UpdateNativeTag(op, orgId, nativeTag)
158 return nil
159}

Callers

nothing calls this directly

Calls 4

ErrorMethod · 0.65
UpdateNativeTagMethod · 0.65
InfofMethod · 0.45
ErrorfMethod · 0.45

Tested by

no test coverage detected