format

Author: leandroberetta

pkg/api/write_loki.go

@@ -50,7 +50,7 @@ type WriteLoki struct {
 
 	// Client protocol selection
 	ClientProtocol string          `yaml:"clientProtocol,omitempty" json:"clientProtocol,omitempty" doc:"type of client protocol to use: 'http' or 'grpc' (default: 'http')"`
-	GRPCConfig *GRPCLokiConfig `yaml:"grpcConfig,omitempty" json:"grpcConfig,omitempty" doc:"gRPC client configuration (used only for gRPC client type)"`
+	GRPCConfig     *GRPCLokiConfig `yaml:"grpcConfig,omitempty" json:"grpcConfig,omitempty" doc:"gRPC client configuration (used only for gRPC client type)"`
 }
 
 type GRPCLokiConfig struct {

pkg/pipeline/write/write_loki_test.go

@@ -371,9 +371,9 @@ func hundredFlows() []config.GenericMap {
 
 func TestGRPCClientCreation(t *testing.T) {
 	params := api.WriteLoki{
-		URL:        "localhost:9095",
+		URL:            "localhost:9095",
 		ClientProtocol: "grpc",
-		TenantID:   "test-tenant",
+		TenantID:       "test-tenant",
 		GRPCConfig: &api.GRPCLokiConfig{
 			KeepAlive:        "30s",
 			KeepAliveTimeout: "5s",
@@ -388,9 +388,9 @@ func TestGRPCClientCreation(t *testing.T) {
 
 func TestGRPCClientCreationWithTLS(t *testing.T) {
 	params := api.WriteLoki{
-		URL:        "loki.example.com:9095",
+		URL:            "loki.example.com:9095",
 		ClientProtocol: "grpc",
-		TenantID:   "test-tenant",
+		TenantID:       "test-tenant",
 		GRPCConfig: &api.GRPCLokiConfig{
 			KeepAlive:        "30s",
 			KeepAliveTimeout: "5s",
@@ -422,15 +422,15 @@ func TestBuildGRPCLokiConfig(t *testing.T) {
 		{
 			name: "valid basic gRPC config",
 			input: &api.WriteLoki{
-				URL:        "localhost:9095",
+				URL:            "localhost:9095",
 				ClientProtocol: "grpc",
-				BatchWait:  "2s",
-				BatchSize:  50000,
-				Timeout:    "15s",
-				MinBackoff: "2s",
-				MaxBackoff: "10s",
-				MaxRetries: 5,
-				TenantID:   "test-tenant",
+				BatchWait:      "2s",
+				BatchSize:      50000,
+				Timeout:        "15s",
+				MinBackoff:     "2s",
+				MaxBackoff:     "10s",
+				MaxRetries:     5,
+				TenantID:       "test-tenant",
 				GRPCConfig: &api.GRPCLokiConfig{
 					KeepAlive:        "60s",
 					KeepAliveTimeout: "10s",
@@ -445,21 +445,21 @@ func TestBuildGRPCLokiConfig(t *testing.T) {
 		{
 			name: "missing gRPC config",
 			input: &api.WriteLoki{
-				URL:        "localhost:9095",
+				URL:            "localhost:9095",
 				ClientProtocol: "grpc",
-				TenantID:   "test-tenant",
-				GRPCConfig: nil,
+				TenantID:       "test-tenant",
+				GRPCConfig:     nil,
 			},
 			wantErr: true,
 		},
 		{
 			name: "invalid duration in gRPC config",
 			input: &api.WriteLoki{
-				URL:        "localhost:9095",
+				URL:            "localhost:9095",
 				ClientProtocol: "grpc",
-				BatchWait:  "invalid-duration",
-				TenantID:   "test-tenant",
-				GRPCConfig: &api.GRPCLokiConfig{},
+				BatchWait:      "invalid-duration",
+				TenantID:       "test-tenant",
+				GRPCConfig:     &api.GRPCLokiConfig{},
 			},
 			wantErr: true,
 		},
@@ -554,27 +554,27 @@ func TestWriteLokiValidation(t *testing.T) {
 		{
 			name: "valid HTTP config",
 			config: &api.WriteLoki{
-				URL:        "http://localhost:3100",
+				URL:            "http://localhost:3100",
 				ClientProtocol: "http",
-				BatchSize:  1024,
+				BatchSize:      1024,
 			},
 			wantErr: false,
 		},
 		{
 			name: "valid gRPC config",
 			config: &api.WriteLoki{
-				URL:        "localhost:9095",
+				URL:            "localhost:9095",
 				ClientProtocol: "grpc",
-				BatchSize:  1024,
-				GRPCConfig: &api.GRPCLokiConfig{},
+				BatchSize:      1024,
+				GRPCConfig:     &api.GRPCLokiConfig{},
 			},
 			wantErr: false,
 		},
 		{
 			name: "invalid client type",
 			config: &api.WriteLoki{
 				ClientProtocol: "websocket",
-				BatchSize:  1024,
+				BatchSize:      1024,
 			},
 			wantErr: true,
 			errMsg:  "invalid clientProtocol",
@@ -583,7 +583,7 @@ func TestWriteLokiValidation(t *testing.T) {
 			name: "missing URL for HTTP",
 			config: &api.WriteLoki{
 				ClientProtocol: "http",
-				BatchSize:  1024,
+				BatchSize:      1024,
 			},
 			wantErr: true,
 			errMsg:  "url can't be empty",
@@ -592,28 +592,28 @@ func TestWriteLokiValidation(t *testing.T) {
 			name: "missing URL for gRPC",
 			config: &api.WriteLoki{
 				ClientProtocol: "grpc",
-				BatchSize:  1024,
-				GRPCConfig: &api.GRPCLokiConfig{},
+				BatchSize:      1024,
+				GRPCConfig:     &api.GRPCLokiConfig{},
 			},
 			wantErr: true,
 			errMsg:  "url can't be empty",
 		},
 		{
 			name: "missing gRPC config",
 			config: &api.WriteLoki{
-				URL:        "localhost:9095",
+				URL:            "localhost:9095",
 				ClientProtocol: "grpc",
-				BatchSize:  1024,
+				BatchSize:      1024,
 			},
 			wantErr: true,
 			errMsg:  "grpcConfig is required",
 		},
 		{
 			name: "invalid batch size",
 			config: &api.WriteLoki{
-				URL:        "http://localhost:3100",
+				URL:            "http://localhost:3100",
 				ClientProtocol: "http",
-				BatchSize:  -1,
+				BatchSize:      -1,
 			},
 			wantErr: true,
 			errMsg:  "invalid batchSize",