remove useStreaming field

Author: leandroberetta

docs/api.md

@@ -330,7 +330,6 @@ Following is the supported API format for writing to loki:
              maxSendMsgSize: maximum message size the client can send
              keepAlive: keep alive interval
              keepAliveTimeout: keep alive timeout
-             useStreaming: use streaming for real-time log pushing
              tls: TLS configuration
                  enabled: enable TLS
                  certFile: path to client certificate file

go.mod

@@ -171,4 +171,4 @@ require (
 
 replace github.com/vmware/go-ipfix => github.com/jotak/go-ipfix v0.0.0-20250708115123-407c539ea101
 
-replace github.com/netobserv/loki-client-go => github.com/leandroberetta/loki-client-go v0.0.0-20250910180315-84da2ae0cd4b
+replace github.com/netobserv/loki-client-go => github.com/leandroberetta/loki-client-go v0.0.0-20250923004934-a3e68fd6a596

go.sum

@@ -208,8 +208,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/loki-client-go v0.0.0-20250910180315-84da2ae0cd4b h1:bZFg5ZB45OzbkO9x8EgW1vrsJ9xethOlgCTrTwqf798=
-github.com/leandroberetta/loki-client-go v0.0.0-20250910180315-84da2ae0cd4b/go.mod h1:Zb/jtD3Lnu88Poo+jnhTASzxYnvncmHOoZaT93xQjJ8=
+github.com/leandroberetta/loki-client-go v0.0.0-20250923004934-a3e68fd6a596 h1:FhZHtZsaCa4LMhgTrU+eM1iTnl2X1L1yrSRQjGHiJOo=
+github.com/leandroberetta/loki-client-go v0.0.0-20250923004934-a3e68fd6a596/go.mod h1:Zb/jtD3Lnu88Poo+jnhTASzxYnvncmHOoZaT93xQjJ8=
 github.com/libp2p/go-reuseport v0.4.0 h1:nR5KU7hD0WxXCJbmw7r2rhRYruNRl2koHw8fQscQm2s=
 github.com/libp2p/go-reuseport v0.4.0/go.mod h1:ZtI03j/wO5hZVDFo2jKywN6bYKWLOy8Se6DrI2E1cLU=
 github.com/mailru/easyjson v0.9.0 h1:PrnmzHw7262yW8sTBwxi1PdJA3Iw/EKBa8psRf7d9a4=

pkg/api/write_loki.go

@@ -59,7 +59,6 @@ type GRPCLokiConfig struct {
 	MaxSendMsgSize   int            `yaml:"maxSendMsgSize,omitempty" json:"maxSendMsgSize,omitempty" doc:"maximum message size the client can send"`
 	KeepAlive        string         `yaml:"keepAlive,omitempty" json:"keepAlive,omitempty" doc:"keep alive interval"`
 	KeepAliveTimeout string         `yaml:"keepAliveTimeout,omitempty" json:"keepAliveTimeout,omitempty" doc:"keep alive timeout"`
-	UseStreaming     bool           `yaml:"useStreaming,omitempty" json:"useStreaming,omitempty" doc:"use streaming for real-time log pushing"`
 	TLS              *GRPCTLSConfig `yaml:"tls,omitempty" json:"tls,omitempty" doc:"TLS configuration"`
 }
 

pkg/pipeline/write/write_loki.go

@@ -189,7 +189,6 @@ func buildGRPCLokiConfig(c *api.WriteLoki) (grpc.Config, error) {
 		MaxSendMsgSize:   c.GRPCConfig.MaxSendMsgSize,
 		KeepAlive:        keepAlive,
 		KeepAliveTimeout: keepAliveTimeout,
-		UseStreaming:     c.GRPCConfig.UseStreaming,
 		BackoffConfig: backoff.BackoffConfig{
 			MinBackoff: minBackoff,
 			MaxBackoff: maxBackoff,

pkg/pipeline/write/write_loki_test.go

@@ -379,7 +379,6 @@ func TestGRPCClientCreation(t *testing.T) {
 			MaxSendMsgSize:   16 * 1024 * 1024,
 			KeepAlive:        "30s",
 			KeepAliveTimeout: "5s",
-			UseStreaming:     false,
 		},
 	}
 
@@ -399,7 +398,6 @@ func TestGRPCClientCreationWithTLS(t *testing.T) {
 			MaxSendMsgSize:   16 * 1024 * 1024,
 			KeepAlive:        "30s",
 			KeepAliveTimeout: "5s",
-			UseStreaming:     false,
 			TLS: &api.GRPCTLSConfig{
 				Enabled:            true,
 				CertFile:           "/path/to/cert.pem",
@@ -442,7 +440,6 @@ func TestBuildGRPCLokiConfig(t *testing.T) {
 					MaxSendMsgSize:   8 * 1024 * 1024,
 					KeepAlive:        "60s",
 					KeepAliveTimeout: "10s",
-					UseStreaming:     true,
 				},
 			},
 			wantErr: false,
@@ -569,7 +566,6 @@ func TestGRPCConfigValidation(t *testing.T) {
 				MaxSendMsgSize:   16 * 1024 * 1024,
 				KeepAlive:        "30s",
 				KeepAliveTimeout: "5s",
-				UseStreaming:     false,
 			},
 			wantErr: false,
 		},