perf: configurable HTTP compression, NR auto-disable, response time log config

config/config.go

@@ -135,6 +135,20 @@ type Config struct {
 	// New services should leave this false (the default). Set to true only if you
 	// have existing OpenTracing instrumentation that hasn't been migrated to OTEL.
 	OTLPUseOpenTracingBridge bool `envconfig:"OTLP_USE_OPENTRACING_BRIDGE" default:"false"`
+
+	// Throughput tuning
+
+	// DisableHTTPCompression disables gzip/zstd compression for HTTP gateway responses
+	DisableHTTPCompression bool `envconfig:"DISABLE_HTTP_COMPRESSION" default:"false"`
+	// HTTPCompressionMinSize is the minimum response body size (bytes) before compression is applied.
+	// Responses smaller than this are sent uncompressed. Applies to both gzip and zstd.
+	HTTPCompressionMinSize int `envconfig:"HTTP_COMPRESSION_MIN_SIZE" default:"256"`
+	// ResponseTimeLogLevel sets the log level for per-request response time logging.
+	// Valid values: "debug", "info", "warn", "error". Invalid values default to "info".
+	ResponseTimeLogLevel string `envconfig:"RESPONSE_TIME_LOG_LEVEL" default:"info"`
+	// ResponseTimeLogErrorOnly when true, only logs response time for requests that return an error.
+	// Successful requests are not logged. Default behavior logs all requests.
+	ResponseTimeLogErrorOnly bool `envconfig:"RESPONSE_TIME_LOG_ERROR_ONLY" default:"false"`
 }
 
 // Validate checks the configuration for common misconfigurations and returns

core.go

@@ -17,7 +17,7 @@
 	"golang.org/x/sync/errgroup"
 
 	"github.com/go-coldbrew/core/config"
 	"github.com/go-coldbrew/interceptors"
 	"github.com/go-coldbrew/log"
 	"github.com/go-coldbrew/log/loggers"
 	"github.com/go-coldbrew/options"
@@ -111,6 +111,11 @@
 	if !c.config.DisableAutoMaxProcs {
 		SetupAutoMaxProcs()
 	}
+	// Auto-disable NewRelic when no license key is configured to avoid
+	// interceptor overhead for services that don't use NR.
+	if !c.config.DisableNewRelic && c.config.NewRelicLicenseKey == "" {
+		c.config.DisableNewRelic = true
+	}
 	if !c.config.DisableNewRelic {
 		err := SetupNewRelic(nrName, c.config.NewRelicLicenseKey, c.config.NewRelicDistributedTracing)
 		if err != nil {
@@ -121,7 +126,7 @@
 	SetupEnvironment(c.config.Environment)
 	SetupReleaseName(c.config.ReleaseName)
 	SetupHystrixPrometheus()
-	ConfigureInterceptors(c.config.DoNotLogGRPCReflection, c.config.TraceHeaderName)
+	ConfigureInterceptors(c.config.DoNotLogGRPCReflection, c.config.TraceHeaderName, c.config.ResponseTimeLogLevel, c.config.ResponseTimeLogErrorOnly)
 	if !c.config.DisableSignalHandler {
 		dur := time.Second * 10
 		if c.config.ShutdownDurationInSeconds > 0 {
@@ -390,7 +395,14 @@
 	// Start HTTP server (and proxy calls to gRPC server endpoint)
 	gatewayAddr := fmt.Sprintf("%s:%d", c.config.ListenHost, c.config.HTTPPort)
 	promHandler := promhttp.Handler()
-	gzipHandler := gzhttp.GzipHandler(tracingWrapper(mux))
+	var gzipHandler http.Handler = tracingWrapper(mux)
+	if !c.config.DisableHTTPCompression {
+		wrapper, err := gzhttp.NewWrapper(gzhttp.MinSize(c.config.HTTPCompressionMinSize))
+		if err != nil {
+			return nil, fmt.Errorf("failed to create compression handler: %v", err)
+		}
+		gzipHandler = wrapper(gzipHandler)
+	}
 	gwServer := &http.Server{
 		Addr: gatewayAddr,
 		Handler: http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {

core_coverage_test.go

@@ -1165,5 +1165,5 @@ func TestSetupOpenTelemetry_MissingServiceName(t *testing.T) {
 }
 
 func TestConfigureInterceptors_BothBranches(t *testing.T) {
-	ConfigureInterceptors(true, "X-My-Trace")
+	ConfigureInterceptors(true, "X-My-Trace", "info", false)
 }

go.sum

@@ -175,8 +175,6 @@ github.com/go-coldbrew/errors v0.2.6 h1:rNOI+XcxuyrN/t3e7zDBVUVzcYBNmhyjatsnJg9M
 github.com/go-coldbrew/errors v0.2.6/go.mod h1:jFXeN7Q74fggbIEZu/68vhRX1ob2zfc+2sy0osVfBlY=
 github.com/go-coldbrew/hystrixprometheus v0.1.2 h1:WSt4FtYr8xNDKgdGWYpMfXGFIK7zdDSBwDSbpuPhBHI=
 github.com/go-coldbrew/hystrixprometheus v0.1.2/go.mod h1:OrNRHHxZagpmQXNp//oHKOemGSU0ScOqEcJgeKbJ+wg=
-github.com/go-coldbrew/interceptors v0.1.13 h1:YVHOldoe3I1VqtGfAwn0jhpiPmSfA/irVpNJOCFfICc=
-github.com/go-coldbrew/interceptors v0.1.13/go.mod h1:brTTe9j2BSpavK0zDqU2cVvIf8LAdMyu+7vNeVsL5Vk=
 github.com/go-coldbrew/log v0.2.8 h1:aF+vw23zMyh5S9vhhofERiaPpSDyeJH1Tv1CYREn/a0=
 github.com/go-coldbrew/log v0.2.8/go.mod h1:RKvGzMZMt7FpQ9u36adkDigRxkOvRj1diwgAgRJZH4E=
 github.com/go-coldbrew/options v0.2.6 h1:Nr93v7PbO+EYLHhzA8biGumaTTSHLHqTYLg70n/foXE=

initializers.go

@@ -321,10 +321,8 @@ func SetupHystrixPrometheus() {
 	})
 }
 
-// ConfigureInterceptors configures the interceptors package with the provided
-// DoNotLogGRPCReflection is a boolean that indicates whether to log the grpc.reflection.v1alpha.ServerReflection service calls in logs
-// traceHeaderName is the name of the header to use for tracing (e.g. X-Trace-Id) - if empty, defaults to X-Trace-Id
-func ConfigureInterceptors(DoNotLogGRPCReflection bool, traceHeaderName string) {
+// ConfigureInterceptors configures the interceptors package with the provided settings.
+func ConfigureInterceptors(DoNotLogGRPCReflection bool, traceHeaderName string, responseTimeLogLevel string, responseTimeLogErrorOnly bool) {
 	if DoNotLogGRPCReflection {
 		interceptors.FilterMethods = append(
 			interceptors.FilterMethods,
@@ -334,6 +332,14 @@ func ConfigureInterceptors(DoNotLogGRPCReflection bool, traceHeaderName string)
 	if traceHeaderName != "" {
 		notifier.SetTraceHeaderName(traceHeaderName)
 	}
+	if responseTimeLogLevel != "" {
+		level, err := loggers.ParseLevel(responseTimeLogLevel)
+		if err != nil {
+			level = loggers.InfoLevel
+		}
+		interceptors.SetResponseTimeLogLevel(context.Background(), level)
+	}
+	interceptors.SetResponseTimeLogErrorOnly(responseTimeLogErrorOnly)
 }
 
 // SetupAutoMaxProcs sets up the GOMAXPROCS to match Linux container CPU quota