udpate

Signed-off-by: Hang Yan <[email protected]>

pkg/agent/openflow/client.go

@@ -934,7 +934,7 @@ func (c *client) generatePipelines() {
 			c.enableL7FlowExporter)
 		c.activatedFeatures = append(c.activatedFeatures, c.featurePodConnectivity)
 		c.traceableFeatures = append(c.traceableFeatures, c.featurePodConnectivity)
-		c.sampleFeatures = append(c.sampleFeatures, c.featurePodConnectivity)
+		c.samplingFeatures = append(c.samplingFeatures, c.featurePodConnectivity)
 
 		c.featureService = newFeatureService(c.cookieAllocator,
 			c.nodeIPChecker,
@@ -950,7 +950,7 @@ func (c *client) generatePipelines() {
 			c.connectUplinkToBridge)
 		c.activatedFeatures = append(c.activatedFeatures, c.featureService)
 		c.traceableFeatures = append(c.traceableFeatures, c.featureService)
-		c.sampleFeatures = append(c.sampleFeatures, c.featureService)
+		c.samplingFeatures = append(c.samplingFeatures, c.featureService)
 	}
 
 	if c.nodeType == config.ExternalNode {
@@ -1249,8 +1249,8 @@ func (c *client) InstallPacketSamplingFlows(dataplaneTag uint8, senderOnly, rece
 	cacheKey := fmt.Sprintf("%x", dataplaneTag)
 	var flows []binding.Flow
 
-	for _, f := range c.sampleFeatures {
-		flows = append(flows, f.flowsToSample(dataplaneTag,
+	for _, f := range c.samplingFeatures {
+		flows = append(flows, f.flowsToSampling(dataplaneTag,
 			c.ovsMetersAreSupported,
 			senderOnly,
 			receiverOnly,

pkg/agent/openflow/pipeline.go

@@ -422,7 +422,7 @@ type client struct {
 	traceableFeatures []traceableFeature
 
 	featurePacketSampling *featurePacketSampling
-	samplingFeatures        []samplingFeature
+	samplingFeatures      []samplingFeature
 
 	pipelines map[binding.PipelineID]binding.Pipeline
 
@@ -886,9 +886,9 @@ func matchTransportHeader(packet *binding.Packet, flowBuilder binding.FlowBuilde
 	return flowBuilder
 }
 
-// flowsToSample generates flows for packet sampling. DSCP flag is used as a mark for the target flow.
+// flowsToSampling generates flows for packet sampling. DSCP flag is used as a mark for the target flow.
 // When output, the flag will be cleared.
-func (f *featurePodConnectivity) flowsToSample(dataplaneTag uint8,
+func (f *featurePodConnectivity) flowsToSampling(dataplaneTag uint8,
 	ovsMetersAreSupported,
 	senderOnly bool,
 	receiverOnly bool,
@@ -1242,8 +1242,8 @@ func (f *featurePodConnectivity) flowsToTrace(dataplaneTag uint8,
 	return flows
 }
 
-// flowsToTrace is used to generate flows for PacketSampling in featureService.
-func (f *featureService) flowsToSample(dataplaneTag uint8,
+// flowsToSampling is used to generate flows for PacketSampling in featureService.
+func (f *featureService) flowsToSampling(dataplaneTag uint8,
 	ovsMetersAreSupported,
 	senderOnly bool,
 	receiverOnly bool,