From 641dc0e3b84351afc188e2bcf6ba447fc99a82e1 Mon Sep 17 00:00:00 2001 From: Jan Eitzinger Date: Mon, 30 Mar 2026 16:49:27 +0200 Subject: [PATCH] Run gofumpt --- internal/graph/schema.resolvers.go | 16 +++++++++------- .../metricstoreclient/cc-metric-store-queries.go | 1 - internal/repository/config.go | 8 ++++---- pkg/archive/parquet/writer.go | 8 ++++---- pkg/metricstore/checkpoint.go | 1 - 5 files changed, 17 insertions(+), 17 deletions(-) diff --git a/internal/graph/schema.resolvers.go b/internal/graph/schema.resolvers.go index 9cfb808e..898ea84e 100644 --- a/internal/graph/schema.resolvers.go +++ b/internal/graph/schema.resolvers.go @@ -1072,10 +1072,12 @@ func (r *Resolver) Query() generated.QueryResolver { return &queryResolver{r} } // SubCluster returns generated.SubClusterResolver implementation. func (r *Resolver) SubCluster() generated.SubClusterResolver { return &subClusterResolver{r} } -type clusterResolver struct{ *Resolver } -type jobResolver struct{ *Resolver } -type metricValueResolver struct{ *Resolver } -type mutationResolver struct{ *Resolver } -type nodeResolver struct{ *Resolver } -type queryResolver struct{ *Resolver } -type subClusterResolver struct{ *Resolver } +type ( + clusterResolver struct{ *Resolver } + jobResolver struct{ *Resolver } + metricValueResolver struct{ *Resolver } + mutationResolver struct{ *Resolver } + nodeResolver struct{ *Resolver } + queryResolver struct{ *Resolver } + subClusterResolver struct{ *Resolver } +) diff --git a/internal/metricstoreclient/cc-metric-store-queries.go b/internal/metricstoreclient/cc-metric-store-queries.go index 1119d70c..fa2bea25 100644 --- a/internal/metricstoreclient/cc-metric-store-queries.go +++ b/internal/metricstoreclient/cc-metric-store-queries.go @@ -236,4 +236,3 @@ func (ccms *CCMetricStore) buildNodeQueries( return queries, assignedScope, nil } - diff --git a/internal/repository/config.go b/internal/repository/config.go index a201bb6b..f932836e 100644 --- a/internal/repository/config.go +++ b/internal/repository/config.go @@ -63,10 +63,10 @@ func DefaultConfig() *RepositoryConfig { MaxIdleConnections: 4, ConnectionMaxLifetime: time.Hour, ConnectionMaxIdleTime: 10 * time.Minute, - MinRunningJobDuration: 600, // 10 minutes - DbCacheSizeMB: 2048, // 2GB per connection - DbSoftHeapLimitMB: 16384, // 16GB process-wide - BusyTimeoutMs: 60000, // 60 seconds + MinRunningJobDuration: 600, // 10 minutes + DbCacheSizeMB: 2048, // 2GB per connection + DbSoftHeapLimitMB: 16384, // 16GB process-wide + BusyTimeoutMs: 60000, // 60 seconds } } diff --git a/pkg/archive/parquet/writer.go b/pkg/archive/parquet/writer.go index bfe4490f..11cdad9e 100644 --- a/pkg/archive/parquet/writer.go +++ b/pkg/archive/parquet/writer.go @@ -133,10 +133,10 @@ func (pt *prefixedTarget) WriteFile(name string, data []byte) error { // ClusterAwareParquetWriter organizes Parquet output by cluster. // Each cluster gets its own subdirectory with a cluster.json config file. type ClusterAwareParquetWriter struct { - target ParquetTarget - maxSizeMB int - writers map[string]*ParquetWriter - clusterCfgs map[string]*schema.Cluster + target ParquetTarget + maxSizeMB int + writers map[string]*ParquetWriter + clusterCfgs map[string]*schema.Cluster } // NewClusterAwareParquetWriter creates a writer that routes jobs to per-cluster ParquetWriters. diff --git a/pkg/metricstore/checkpoint.go b/pkg/metricstore/checkpoint.go index fbf56a15..c2b86415 100644 --- a/pkg/metricstore/checkpoint.go +++ b/pkg/metricstore/checkpoint.go @@ -100,7 +100,6 @@ func Checkpointing(wg *sync.WaitGroup, ctx context.Context) { ms := GetMemoryStore() wg.Go(func() { - d := 12 * time.Hour // default checkpoint interval if Keys.CheckpointInterval != "" { parsed, err := time.ParseDuration(Keys.CheckpointInterval)