remove useStreaming field

Author: leandroberetta

api/flowcollector/v1beta2/flowcollector_types.go

@@ -904,10 +904,6 @@ type LokiGRPCConfig struct {
 	//+kubebuilder:default:="5s"
 	// `keepAliveTimeout` is the gRPC keep-alive timeout.
 	KeepAliveTimeout *metav1.Duration `json:"keepAliveTimeout,omitempty"`
-
-	//+kubebuilder:default:=false
-	// `useStreaming` enables streaming mode for real-time log pushing when using gRPC.
-	UseStreaming bool `json:"useStreaming,omitempty"`
 }
 
 // `FlowCollectorLoki` defines the desired state for FlowCollector's Loki client.

bundle/manifests/flows.netobserv.io_flowcollectors.yaml

@@ -3822,11 +3822,6 @@ spec:
                         maximum: 67108864
                         minimum: 1024
                         type: integer
-                      useStreaming:
-                        default: false
-                        description: '`useStreaming` enables streaming mode for real-time
-                          log pushing when using gRPC.'
-                        type: boolean
                     type: object
                   lokiStack:
                     description: |-

bundle/manifests/netobserv-operator.clusterserviceversion.yaml

@@ -492,8 +492,6 @@ spec:
         path: loki.grpcConfig.maxRecvMsgSize
       - displayName: Max send msg size
         path: loki.grpcConfig.maxSendMsgSize
-      - displayName: Use streaming
-        path: loki.grpcConfig.useStreaming
       - displayName: Read timeout
         path: loki.readTimeout
       - path: loki.advanced

config/crd/bases/flows.netobserv.io_flowcollectors.yaml

@@ -3530,10 +3530,6 @@ spec:
                           maximum: 67108864
                           minimum: 1024
                           type: integer
-                        useStreaming:
-                          default: false
-                          description: '`useStreaming` enables streaming mode for real-time log pushing when using gRPC.'
-                          type: boolean
                       type: object
                     lokiStack:
                       description: |-

config/csv/bases/netobserv-operator.clusterserviceversion.yaml

@@ -228,8 +228,6 @@ spec:
           path: loki.grpcConfig.maxRecvMsgSize
         - displayName: Max send msg size
           path: loki.grpcConfig.maxSendMsgSize
-        - displayName: Use streaming
-          path: loki.grpcConfig.useStreaming
         - displayName: Read timeout
           path: loki.readTimeout
         - path: loki.advanced

config/samples/flows_v1beta2_flowcollector.yaml

@@ -150,6 +150,7 @@ spec:
     enable: true
     # Change mode to "LokiStack" to use with the loki operator
     mode: Monolithic
+    clientType: http
     monolithic:
       url: 'http://loki.netobserv.svc:3100/'
       tenantID: netobserv

docs/FlowCollector.md

@@ -7472,15 +7472,6 @@ This is only used when `clientType` is set to `grpc`.
             <i>Maximum</i>: 6.7108864e+07<br/>
         </td>
         <td>false</td>
-      </tr><tr>
-        <td><b>useStreaming</b></td>
-        <td>boolean</td>
-        <td>
-          `useStreaming` enables streaming mode for real-time log pushing when using gRPC.<br/>
-          <br/>
-            <i>Default</i>: false<br/>
-        </td>
-        <td>false</td>
       </tr></tbody>
 </table>
 

go.mod

@@ -119,4 +119,4 @@ require (
 	sigs.k8s.io/structured-merge-diff/v6 v6.3.0 // indirect
 )
 
-replace github.com/netobserv/flowlogs-pipeline => github.com/leandroberetta/flowlogs-pipeline v0.0.0-20250910204200-598934e552bf
+replace github.com/netobserv/flowlogs-pipeline => github.com/leandroberetta/flowlogs-pipeline v0.0.0-20250923005817-c2a742ec7d05

go.sum

@@ -91,8 +91,8 @@ github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
 github.com/kylelemons/godebug v1.1.0 h1:RPNrshWIDI6G2gRW9EHilWtl7Z6Sb1BR0xunSBf0SNc=
 github.com/kylelemons/godebug v1.1.0/go.mod h1:9/0rRGxNHcop5bhtWyNeEfOS8JIWk580+fNqagV/RAw=
-github.com/leandroberetta/flowlogs-pipeline v0.0.0-20250910204200-598934e552bf h1:PmzTpv8FVbLNsggl7lg+cfBQ0UZn2hmYJNBzhZGOj7I=
-github.com/leandroberetta/flowlogs-pipeline v0.0.0-20250910204200-598934e552bf/go.mod h1:lZELP2Lt8KxNeqP8gPbmLWHPWI4EljIIwYbUEJTkHz4=
+github.com/leandroberetta/flowlogs-pipeline v0.0.0-20250923005817-c2a742ec7d05 h1:1+dMb4ZGFF8MBmIjpthaUGRoFeialPBh45pHbntfkY8=
+github.com/leandroberetta/flowlogs-pipeline v0.0.0-20250923005817-c2a742ec7d05/go.mod h1:yFG40dKhX4jRkKngzi03U/ida4MXKoKtoumSROyksw0=
 github.com/mailru/easyjson v0.9.0 h1:PrnmzHw7262yW8sTBwxi1PdJA3Iw/EKBa8psRf7d9a4=
 github.com/mailru/easyjson v0.9.0/go.mod h1:1+xMtQp2MRNVL/V1bOzuP3aP8VNwRW55fQUto+XFtTU=
 github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=

helm/crds/flows.netobserv.io_flowcollectors.yaml

@@ -3534,10 +3534,6 @@ spec:
                           maximum: 67108864
                           minimum: 1024
                           type: integer
-                        useStreaming:
-                          default: false
-                          description: '`useStreaming` enables streaming mode for real-time log pushing when using gRPC.'
-                          type: boolean
                       type: object
                     lokiStack:
                       description: |-