add grpc support

TODO.md

@@ -1,8 +1,10 @@
 # TODO
 
-- [x] Pattern for extending config
+- [ ] Finish implementing GRPC service support
+- [ ] Expand tracing
 
 ## Done
 - [x] Unit tests
+- [x] Pattern for extending config
 - [x] HTTP Logging Middleware
 - [x] Fix panic with OTEL disabled

go.mod

@@ -28,7 +28,7 @@ require (
 	github.com/go-logr/logr v1.4.2 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect
 	github.com/google/uuid v1.6.0 // indirect
-	github.com/grpc-ecosystem/grpc-gateway/v2 v2.26.0 // indirect
+	github.com/grpc-ecosystem/grpc-gateway/v2 v2.26.1 // indirect
 	github.com/klauspost/compress v1.17.11 // indirect
 	github.com/mattn/go-colorable v0.1.14 // indirect
 	github.com/mattn/go-isatty v0.0.20 // indirect
@@ -39,11 +39,11 @@ require (
 	go.opentelemetry.io/auto/sdk v1.1.0 // indirect
 	go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.34.0 // indirect
 	go.opentelemetry.io/proto/otlp v1.5.0 // indirect
-	golang.org/x/net v0.34.0 // indirect
+	golang.org/x/net v0.35.0 // indirect
-	golang.org/x/sys v0.29.0 // indirect
+	golang.org/x/sys v0.30.0 // indirect
-	golang.org/x/text v0.21.0 // indirect
+	golang.org/x/text v0.22.0 // indirect
-	google.golang.org/genproto/googleapis/api v0.0.0-20250127172529-29210b9bc287 // indirect
+	google.golang.org/genproto/googleapis/api v0.0.0-20250212204824-5a70512c5d8b // indirect
-	google.golang.org/genproto/googleapis/rpc v0.0.0-20250127172529-29210b9bc287 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20250212204824-5a70512c5d8b // indirect
 	google.golang.org/grpc v1.70.0 // indirect
-	google.golang.org/protobuf v1.36.4 // indirect
+	google.golang.org/protobuf v1.36.5 // indirect
 )

go.sum

@@ -27,6 +27,8 @@ github.com/grpc-ecosystem/grpc-gateway/v2 v2.25.1 h1:VNqngBF40hVlDloBruUehVYC3Ar
 github.com/grpc-ecosystem/grpc-gateway/v2 v2.25.1/go.mod h1:RBRO7fro65R6tjKzYgLAFo0t1QEXY1Dp+i/bvpRiqiQ=
 github.com/grpc-ecosystem/grpc-gateway/v2 v2.26.0 h1:VD1gqscl4nYs1YxVuSdemTrSgTKrwOWDK0FVFMqm+Cg=
 github.com/grpc-ecosystem/grpc-gateway/v2 v2.26.0/go.mod h1:4EgsQoS4TOhJizV+JTFg40qx1Ofh3XmXEQNBpgvNT40=
+github.com/grpc-ecosystem/grpc-gateway/v2 v2.26.1 h1:e9Rjr40Z98/clHv5Yg79Is0NtosR5LXRvdr7o/6NwbA=
+github.com/grpc-ecosystem/grpc-gateway/v2 v2.26.1/go.mod h1:tIxuGz/9mpox++sgp9fJjHO0+q1X9/UOWd798aAm22M=
 github.com/klauspost/compress v1.17.11 h1:In6xLpyWOi1+C7tXUUWv2ot1QvBjxevKAaI6IXrJmUc=
 github.com/klauspost/compress v1.17.11/go.mod h1:pMDklpSncoRMuLFrf1W9Ss9KT+0rH90U12bZKk7uwG0=
 github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
@@ -125,25 +127,35 @@ golang.org/x/net v0.33.0 h1:74SYHlV8BIgHIFC/LrYkOGIwL19eTYXQ5wc6TBuO36I=
 golang.org/x/net v0.33.0/go.mod h1:HXLR5J+9DxmrqMwG9qjGCxZ+zKXxBru04zlTvWlWuN4=
 golang.org/x/net v0.34.0 h1:Mb7Mrk043xzHgnRM88suvJFwzVrRfHEHJEl5/71CKw0=
 golang.org/x/net v0.34.0/go.mod h1:di0qlW3YNM5oh6GqDGQr92MyTozJPmybPK4Ev/Gm31k=
+golang.org/x/net v0.35.0 h1:T5GQRQb2y08kTAByq9L4/bz8cipCdA8FbRTXewonqY8=
+golang.org/x/net v0.35.0/go.mod h1:EglIi67kWsHKlRzzVMUD93VMSWGFOMSZgxFjparz1Qk=
 golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.29.0 h1:TPYlXGxvx1MGTn2GiZDhnjPA9wZzZeGKHHmKhHYvgaU=
 golang.org/x/sys v0.29.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.30.0 h1:QjkSwP/36a20jFYWkSue1YwXzLmsV5Gfq7Eiy72C1uc=
+golang.org/x/sys v0.30.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/text v0.21.0 h1:zyQAAkrwaneQ066sspRyJaG9VNi/YJ1NfzcGB3hZ/qo=
 golang.org/x/text v0.21.0/go.mod h1:4IBbMaMmOPCJ8SecivzSH54+73PCFmPWxNTLm+vZkEQ=
+golang.org/x/text v0.22.0 h1:bofq7m3/HAFvbF51jz3Q9wLg3jkvSPuiZu/pD1XwgtM=
+golang.org/x/text v0.22.0/go.mod h1:YRoo4H8PVmsu+E3Ou7cqLVH8oXWIHVoX0jqUWALQhfY=
 google.golang.org/genproto/googleapis/api v0.0.0-20250102185135-69823020774d h1:H8tOf8XM88HvKqLTxe755haY6r1fqqzLbEnfrmLXlSA=
 google.golang.org/genproto/googleapis/api v0.0.0-20250102185135-69823020774d/go.mod h1:2v7Z7gP2ZUOGsaFyxATQSRoBnKygqVq2Cwnvom7QiqY=
 google.golang.org/genproto/googleapis/api v0.0.0-20250106144421-5f5ef82da422 h1:GVIKPyP/kLIyVOgOnTwFOrvQaQUzOzGMCxgFUOEmm24=
 google.golang.org/genproto/googleapis/api v0.0.0-20250106144421-5f5ef82da422/go.mod h1:b6h1vNKhxaSoEI+5jc3PJUCustfli/mRab7295pY7rw=
 google.golang.org/genproto/googleapis/api v0.0.0-20250127172529-29210b9bc287 h1:A2ni10G3UlplFrWdCDJTl7D7mJ7GSRm37S+PDimaKRw=
 google.golang.org/genproto/googleapis/api v0.0.0-20250127172529-29210b9bc287/go.mod h1:iYONQfRdizDB8JJBybql13nArx91jcUk7zCXEsOofM4=
+google.golang.org/genproto/googleapis/api v0.0.0-20250212204824-5a70512c5d8b h1:i+d0RZa8Hs2L/MuaOQYI+krthcxdEbEM2N+Tf3kJ4zk=
+google.golang.org/genproto/googleapis/api v0.0.0-20250212204824-5a70512c5d8b/go.mod h1:iYONQfRdizDB8JJBybql13nArx91jcUk7zCXEsOofM4=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20250102185135-69823020774d h1:xJJRGY7TJcvIlpSrN3K6LAWgNFUILlO+OMAqtg9aqnw=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20250102185135-69823020774d/go.mod h1:3ENsm/5D1mzDyhpzeRi1NR784I0BcofWBoSc5QqqMK4=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20250106144421-5f5ef82da422 h1:3UsHvIr4Wc2aW4brOaSCmcxh9ksica6fHEr8P1XhkYw=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20250106144421-5f5ef82da422/go.mod h1:3ENsm/5D1mzDyhpzeRi1NR784I0BcofWBoSc5QqqMK4=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20250127172529-29210b9bc287 h1:J1H9f+LEdWAfHcez/4cvaVBox7cOYT+IU6rgqj5x++8=
 google.golang.org/genproto/googleapis/rpc v0.0.0-20250127172529-29210b9bc287/go.mod h1:8BS3B93F/U1juMFq9+EDk+qOT5CO1R9IzXxG3PTqiRk=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20250212204824-5a70512c5d8b h1:FQtJ1MxbXoIIrZHZ33M+w5+dAP9o86rgpjoKr/ZmT7k=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20250212204824-5a70512c5d8b/go.mod h1:8BS3B93F/U1juMFq9+EDk+qOT5CO1R9IzXxG3PTqiRk=
 google.golang.org/grpc v1.69.2 h1:U3S9QEtbXC0bYNvRtcoklF3xGtLViumSYxWykJS+7AU=
 google.golang.org/grpc v1.69.2/go.mod h1:vyjdE6jLBI76dgpDojsFGNaHlxdjXN9ghpnd2o7JGZ4=
 google.golang.org/grpc v1.70.0 h1:pWFv03aZoHzlRKHWicjsZytKAiYCtNS0dHbXnIdq7jQ=
@@ -154,6 +166,8 @@ google.golang.org/protobuf v1.36.2 h1:R8FeyR1/eLmkutZOM5CWghmo5itiG9z0ktFlTVLuTm
 google.golang.org/protobuf v1.36.2/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE=
 google.golang.org/protobuf v1.36.4 h1:6A3ZDJHn/eNqc1i+IdefRzy/9PokBTPvcqMySR7NNIM=
 google.golang.org/protobuf v1.36.4/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE=
+google.golang.org/protobuf v1.36.5 h1:tPhr+woSbjfYvY6/GPufUoYizxw1cF/yFoxJ2fmpwlM=
+google.golang.org/protobuf v1.36.5/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=

pkg/app/app.go

@@ -1,44 +1,15 @@
 package app
 
 import (
-	"context"
 	"errors"
-	"net"
-	"net/http"
 
 	"github.com/rs/zerolog"
 	"go.opentelemetry.io/otel/codes"
-	"go.opentelemetry.io/otel/trace"
 
 	"gitea.libretechconsulting.com/rmcguire/go-app/pkg/config"
-	"gitea.libretechconsulting.com/rmcguire/go-app/pkg/otel"
-	"gitea.libretechconsulting.com/rmcguire/go-app/pkg/srv"
 )
 
-type App struct {
+func (a *App) Done() <-chan any {
-	AppContext    context.Context
-	HTTP          *AppHTTP
-	cfg           *config.AppConfig
-	l             *zerolog.Logger
-	tracer        trace.Tracer
-	shutdownFuncs []shutdownFunc
-	appDone       chan interface{}
-}
-
-type AppHTTP struct {
-	Funcs          []srv.HTTPFunc        // Handle funcs to serve
-	Middleware     []http.Handler        // Optional middleware. Next handler called by app framework.
-	HealthChecks   []srv.HealthCheckFunc // Health-check functions to be called by health endpoint
-	CustomListener net.Listener          // Optional listener for http server
-	httpDone       <-chan interface{}
-}
-
-type (
-	healthCheckFunc func(context.Context) error
-	shutdownFunc    func(context.Context) error
-)
-
-func (a *App) Done() <-chan interface{} {
 	return a.appDone
 }
 
@@ -51,8 +22,8 @@ func (a *App) MustRun() {
 	a.cfg = config.MustFromCtx(a.AppContext)
 	a.l = zerolog.Ctx(a.AppContext)
 	a.shutdownFuncs = make([]shutdownFunc, 0)
-	a.appDone = make(chan interface{})
+	a.appDone = make(chan any)
-	a.HTTP.httpDone = make(chan interface{})
+	a.HTTP.httpDone = make(chan any)
 
 	if len(a.HTTP.Funcs) < 1 {
 		a.l.Warn().Msg("no http funcs provided, only serving health and metrics")
@@ -60,11 +31,17 @@ func (a *App) MustRun() {
 
 	// Start OTEL
 	a.initOTEL()
-	var initSpan trace.Span
+	ctx, initSpan := a.tracer.Start(a.AppContext, "init")
-	_, initSpan = a.tracer.Start(a.AppContext, "init")
+	defer initSpan.End()
 
 	// Start HTTP
-	a.initHTTP()
+	if err := a.initHTTP(ctx); err != nil {
+		initSpan.RecordError(err)
+		initSpan.SetStatus(codes.Error, err.Error())
+	}
+
+	// Start GRPC
+	a.initGRPC()
 
 	// Monitor app lifecycle
 	go a.run()
@@ -76,26 +53,4 @@ func (a *App) MustRun() {
 		Str("logLevel", a.cfg.Logging.Level).
 		Msg("app initialized")
 	initSpan.SetStatus(codes.Ok, "")
-	initSpan.End()
-}
-
-func (a *App) initHTTP() {
-	var httpShutdown shutdownFunc
-	httpShutdown, a.HTTP.httpDone = srv.MustInitHTTPServer(
-		&srv.HTTPServerOpts{
-			Ctx:              a.AppContext,
-			HandleFuncs:      a.HTTP.Funcs,
-			Middleware:       a.HTTP.Middleware,
-			HealthCheckFuncs: a.HTTP.HealthChecks,
-			CustomListener:   a.HTTP.CustomListener,
-		},
-	)
-	a.shutdownFuncs = append(a.shutdownFuncs, httpShutdown)
-}
-
-func (a *App) initOTEL() {
-	var otelShutdown shutdownFunc
-	a.AppContext, otelShutdown = otel.Init(a.AppContext)
-	a.shutdownFuncs = append(a.shutdownFuncs, otelShutdown)
-	a.tracer = otel.MustTracerFromCtx(a.AppContext)
 }

pkg/app/app_init.go

@@ -0,0 +1,55 @@
+package app
+
+import (
+	"context"
+
+	"go.opentelemetry.io/otel/attribute"
+	"go.opentelemetry.io/otel/codes"
+
+	"gitea.libretechconsulting.com/rmcguire/go-app/pkg/otel"
+	"gitea.libretechconsulting.com/rmcguire/go-app/pkg/srv"
+)
+
+func (a *App) initGRPC() {
+}
+
+func (a *App) initHTTP(ctx context.Context) error {
+	var err error
+	var httpShutdown shutdownFunc
+
+	_, span := a.tracer.Start(ctx, "init.http")
+	defer span.End()
+
+	span.SetAttributes(
+		attribute.Int("numHTTPFuncs", len(a.HTTP.Funcs)),
+		attribute.Int("numHTTPMiddlewares", len(a.HTTP.Middleware)),
+		attribute.Int("numHTTPHealthChecks", len(a.HTTP.HealthChecks)),
+	)
+
+	httpShutdown, a.HTTP.httpDone, err = srv.InitHTTPServer(
+		&srv.HTTPServerOpts{
+			Ctx:              a.AppContext,
+			HandleFuncs:      a.HTTP.Funcs,
+			Middleware:       a.HTTP.Middleware,
+			HealthCheckFuncs: a.HTTP.HealthChecks,
+		},
+	)
+
+	a.shutdownFuncs = append(a.shutdownFuncs, httpShutdown)
+
+	if err != nil {
+		span.RecordError(err)
+		span.SetStatus(codes.Error, err.Error())
+	} else {
+		span.SetStatus(codes.Ok, "")
+	}
+
+	return err
+}
+
+func (a *App) initOTEL() {
+	var otelShutdown shutdownFunc
+	a.AppContext, otelShutdown = otel.Init(a.AppContext)
+	a.shutdownFuncs = append(a.shutdownFuncs, otelShutdown)
+	a.tracer = otel.MustTracerFromCtx(a.AppContext)
+}

pkg/app/app_types.go

@@ -0,0 +1,47 @@
+package app
+
+import (
+	"context"
+	"net/http"
+
+	"github.com/rs/zerolog"
+	"go.opentelemetry.io/otel/trace"
+	"google.golang.org/grpc"
+
+	"gitea.libretechconsulting.com/rmcguire/go-app/pkg/config"
+	"gitea.libretechconsulting.com/rmcguire/go-app/pkg/srv"
+)
+
+type App struct {
+	AppContext    context.Context
+	HTTP          *AppHTTP
+	GRPC          *AppGRPC
+	cfg           *config.AppConfig
+	l             *zerolog.Logger
+	tracer        trace.Tracer
+	shutdownFuncs []shutdownFunc
+	appDone       chan any
+}
+
+type AppGRPC struct {
+	Services []*GRPCService
+	GRPCOpts []grpc.ServerOption
+}
+
+type GRPCService struct {
+	Name    string            // Descriptive name of service
+	Type    *grpc.ServiceDesc // Type (from protoc generated code)
+	Service any               // Implementation of GRPCService.Type (ptr)
+}
+
+type AppHTTP struct {
+	Funcs        []srv.HTTPFunc
+	Middleware   []http.Handler
+	HealthChecks []srv.HealthCheckFunc
+	httpDone     <-chan any
+}
+
+type (
+	healthCheckFunc func(context.Context) error
+	shutdownFunc    func(context.Context) error
+)

pkg/config/types.go

@@ -1,32 +1,13 @@
 package config
 
-import "time"
-
 // Default Settings
 var DefaultConfig = &AppConfig{
 	Environment: "development",
 	Version:     getVersion(),
-	Logging: &LogConfig{
+	Logging:     defaultLoggingConfig,
-		Enabled:    true,
+	HTTP:        defaultHTTPConfig,
-		Level:      "info",
+	OTEL:        defaultOTELConfig,
-		Format:     LogFormatJSON,
+	GRPC:        defaultGRPCConfig,
-		Output:     "stderr",
-		TimeFormat: TimeFormatLong,
-	},
-	HTTP: &HTTPConfig{
-		Listen:       "127.0.0.1:8080",
-		LogRequests:  false,
-		ReadTimeout:  "10s",
-		WriteTimeout: "10s",
-		IdleTimeout:  "1m",
-	},
-	OTEL: &OTELConfig{
-		Enabled:            true,
-		PrometheusEnabled:  true,
-		PrometheusPath:     "/metrics",
-		StdoutEnabled:      false,
-		MetricIntervalSecs: 30,
-	},
 }
 
 type AppConfig struct {
@@ -39,58 +20,5 @@ type AppConfig struct {
 	Logging *LogConfig  `yaml:"logging,omitempty"`
 	HTTP    *HTTPConfig `yaml:"http,omitempty"`
 	OTEL    *OTELConfig `yaml:"otel,omitempty"`
-}
+	GRPC    *GRPCConfig `yaml:"grpc,omitempty"`
-
-// Logging Configuration
-type LogConfig struct {
-	Enabled    bool       `yaml:"enabled,omitempty" env:"APP_LOG_ENABLED"`
-	Level      string     `yaml:"level,omitempty" env:"APP_LOG_LEVEL"`
-	Format     LogFormat  `yaml:"format,omitempty" env:"APP_LOG_FORMAT"`
-	Output     LogOutput  `yaml:"output,omitempty" env:"APP_LOG_OUTPUT"`
-	TimeFormat TimeFormat `yaml:"timeFormat,omitempty" env:"APP_LOG_TIME_FORMAT"`
-}
-
-type LogFormat string
-
-const (
-	LogFormatConsole LogFormat = "console"
-	LogFormatJSON    LogFormat = "json"
-)
-
-type TimeFormat string
-
-const (
-	TimeFormatShort   TimeFormat = "short"
-	TimeFormatLong    TimeFormat = "long"
-	TimeFormatUnix    TimeFormat = "unix"
-	TimeFormatRFC3339 TimeFormat = "rfc3339"
-	TimeFormatOff     TimeFormat = "off"
-)
-
-type LogOutput string
-
-const (
-	LogOutputStdout LogOutput = "stdout"
-	LogOutputStderr LogOutput = "stderr"
-)
-
-// HTTP Configuration
-type HTTPConfig struct {
-	Listen       string `yaml:"listen,omitempty" env:"APP_HTTP_LISTEN"`
-	LogRequests  bool   `yaml:"logRequests" env:"APP_HTTP_LOG_REQUESTS"`
-	ReadTimeout  string `yaml:"readTimeout" env:"APP_HTTP_READ_TIMEOUT"`   // Go duration (e.g. 10s)
-	WriteTimeout string `yaml:"writeTimeout" env:"APP_HTTP_WRITE_TIMEOUT"` // Go duration (e.g. 10s)
-	IdleTimeout  string `yaml:"idleTimeout" env:"APP_HTTP_IDLE_TIMEOUT"`   // Go duration (e.g. 10s)
-	rT           *time.Duration
-	wT           *time.Duration
-	iT           *time.Duration
-}
-
-// OTEL Configuration
-type OTELConfig struct {
-	Enabled            bool   `yaml:"enabled,omitempty" env:"APP_OTEL_ENABLED"`
-	PrometheusEnabled  bool   `yaml:"prometheusEnabled,omitempty" env:"APP_OTEL_PROMETHEUS_ENABLED"`
-	PrometheusPath     string `yaml:"prometheusPath,omitempty" env:"APP_OTEL_PROMETHEUS_PATH"`
-	StdoutEnabled      bool   `yaml:"stdoutEnabled,omitempty" env:"APP_OTEL_STDOUT_ENABLED"`
-	MetricIntervalSecs int    `yaml:"metricIntervalSecs,omitempty" env:"APP_OTEL_METRIC_INTERVAL_SECS"`
 }

pkg/config/types_grpc.go

@@ -0,0 +1,14 @@
+package config
+
+var defaultGRPCConfig = &GRPCConfig{
+	LogRequests:           false,
+	EnableReflection:      true,
+	EnableInstrumentation: true,
+}
+
+type GRPCConfig struct {
+	Listen                string `yaml:"listen" env:"APP_GRPC_LISTEN"`
+	LogRequests           bool   `yaml:"logRequests" env:"APP_GRPC_LOG_REQUESTS"`
+	EnableReflection      bool   `yaml:"enableReflection" env:"APP_GRPC_ENABLE_REFLECTION"`
+	EnableInstrumentation bool   `yaml:"enableInstrumentation" env:"APP_GRPC_ENABLE_INSTRUMENTATION"` // requires OTEL
+}

pkg/config/types_http.go

@@ -0,0 +1,23 @@
+package config
+
+import "time"
+
+var defaultHTTPConfig = &HTTPConfig{
+	Listen:       "127.0.0.1:8080",
+	LogRequests:  false,
+	ReadTimeout:  "10s",
+	WriteTimeout: "10s",
+	IdleTimeout:  "1m",
+}
+
+// HTTP Configuration
+type HTTPConfig struct {
+	Listen       string `yaml:"listen,omitempty" env:"APP_HTTP_LISTEN"`
+	LogRequests  bool   `yaml:"logRequests" env:"APP_HTTP_LOG_REQUESTS"`
+	ReadTimeout  string `yaml:"readTimeout" env:"APP_HTTP_READ_TIMEOUT"`   // Go duration (e.g. 10s)
+	WriteTimeout string `yaml:"writeTimeout" env:"APP_HTTP_WRITE_TIMEOUT"` // Go duration (e.g. 10s)
+	IdleTimeout  string `yaml:"idleTimeout" env:"APP_HTTP_IDLE_TIMEOUT"`   // Go duration (e.g. 10s)
+	rT           *time.Duration
+	wT           *time.Duration
+	iT           *time.Duration
+}

pkg/config/types_logging.go

@@ -0,0 +1,42 @@
+package config
+
+var defaultLoggingConfig = &LogConfig{
+	Enabled:    true,
+	Level:      "info",
+	Format:     LogFormatJSON,
+	Output:     "stderr",
+	TimeFormat: TimeFormatLong,
+}
+
+// Logging Configuration
+type LogConfig struct {
+	Enabled    bool       `yaml:"enabled,omitempty" env:"APP_LOG_ENABLED"`
+	Level      string     `yaml:"level,omitempty" env:"APP_LOG_LEVEL"`
+	Format     LogFormat  `yaml:"format,omitempty" env:"APP_LOG_FORMAT"`
+	Output     LogOutput  `yaml:"output,omitempty" env:"APP_LOG_OUTPUT"`
+	TimeFormat TimeFormat `yaml:"timeFormat,omitempty" env:"APP_LOG_TIME_FORMAT"`
+}
+
+type LogFormat string
+
+const (
+	LogFormatConsole LogFormat = "console"
+	LogFormatJSON    LogFormat = "json"
+)
+
+type TimeFormat string
+
+const (
+	TimeFormatShort   TimeFormat = "short"
+	TimeFormatLong    TimeFormat = "long"
+	TimeFormatUnix    TimeFormat = "unix"
+	TimeFormatRFC3339 TimeFormat = "rfc3339"
+	TimeFormatOff     TimeFormat = "off"
+)
+
+type LogOutput string
+
+const (
+	LogOutputStdout LogOutput = "stdout"
+	LogOutputStderr LogOutput = "stderr"
+)

pkg/config/types_otel.go

@@ -0,0 +1,18 @@
+package config
+
+var defaultOTELConfig = &OTELConfig{
+	Enabled:            true,
+	PrometheusEnabled:  true,
+	PrometheusPath:     "/metrics",
+	StdoutEnabled:      false,
+	MetricIntervalSecs: 30,
+}
+
+// OTEL Configuration
+type OTELConfig struct {
+	Enabled            bool   `yaml:"enabled,omitempty" env:"APP_OTEL_ENABLED"`
+	PrometheusEnabled  bool   `yaml:"prometheusEnabled,omitempty" env:"APP_OTEL_PROMETHEUS_ENABLED"`
+	PrometheusPath     string `yaml:"prometheusPath,omitempty" env:"APP_OTEL_PROMETHEUS_PATH"`
+	StdoutEnabled      bool   `yaml:"stdoutEnabled,omitempty" env:"APP_OTEL_STDOUT_ENABLED"`
+	MetricIntervalSecs int    `yaml:"metricIntervalSecs,omitempty" env:"APP_OTEL_METRIC_INTERVAL_SECS"`
+}

pkg/otel/otel.go

@@ -201,7 +201,7 @@ func (s *settings) newMeterProvider(ctx context.Context) (*metric.MeterProvider,
 	host, set := os.LookupEnv("OTEL_EXPORTER_OTLP_ENDPOINT")
 	var otlpExporter *otlpmetricgrpc.Exporter
 	if set && host != "" {
-		if exp, err := otlpmetricgrpc.New(ctx, otlpmetricgrpc.WithInsecure()); err != nil {
+		if exp, err := otlpmetricgrpc.New(ctx); err != nil {
 			return nil, fmt.Errorf("otlpmetricgrpc.New: %w", err)
 		} else {
 			otlpExporter = exp

pkg/srv/http.go

@@ -130,23 +130,19 @@ func prepHTTPServer(opts *HTTPServerOpts) *http.Server {
 
 // Returns a shutdown func and a done channel if the
 // server aborts abnormally. Panics on error.
-func MustInitHTTPServer(opts *HTTPServerOpts) (
+func InitHTTPServer(opts *HTTPServerOpts) (
-	func(context.Context) error, <-chan interface{},
+	func(context.Context) error, <-chan any, error,
 ) {
-	shutdownFunc, doneChan, err := InitHTTPServer(opts)
+	return initHTTPServer(opts)
-	if err != nil {
-		panic(err)
-	}
-	return shutdownFunc, doneChan
 }
 
 // Returns a shutdown func and a done channel if the
 // server aborts abnormally. Returns error on failure to start
-func InitHTTPServer(opts *HTTPServerOpts) (
+func initHTTPServer(opts *HTTPServerOpts) (
-	func(context.Context) error, <-chan interface{}, error,
+	func(context.Context) error, <-chan any, error,
 ) {
 	l := zerolog.Ctx(opts.Ctx)
-	doneChan := make(chan interface{})
+	doneChan := make(chan any)
 
 	var server *http.Server