mirror of
https://github.com/bitechdev/ResolveSpec.git
synced 2026-07-02 17:37:37 +00:00
Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| d648614611 |
@@ -42,6 +42,10 @@ type Config struct {
|
|||||||
// AutoTLSEmail is the email for Let's Encrypt registration (optional but recommended)
|
// AutoTLSEmail is the email for Let's Encrypt registration (optional but recommended)
|
||||||
AutoTLSEmail string
|
AutoTLSEmail string
|
||||||
|
|
||||||
|
// PanicHandler is called when a request handler panics.
|
||||||
|
// If nil, the default middleware.PanicRecovery is used (logs, records metric, returns 500).
|
||||||
|
PanicHandler func(w http.ResponseWriter, r *http.Request, rcv any)
|
||||||
|
|
||||||
// Graceful shutdown configuration
|
// Graceful shutdown configuration
|
||||||
// ShutdownTimeout is the maximum time to wait for graceful shutdown
|
// ShutdownTimeout is the maximum time to wait for graceful shutdown
|
||||||
// Default: 30 seconds
|
// Default: 30 seconds
|
||||||
|
|||||||
+16
-2
@@ -452,8 +452,19 @@ func newInstance(cfg Config) (*serverInstance, error) {
|
|||||||
handler = gz(handler)
|
handler = gz(handler)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Wrap with the panic recovery middleware
|
// Wrap with panic recovery — use caller-supplied handler if provided
|
||||||
handler = middleware.PanicRecovery(handler)
|
if cfg.PanicHandler != nil {
|
||||||
|
handler = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
defer func() {
|
||||||
|
if rcv := recover(); rcv != nil {
|
||||||
|
cfg.PanicHandler(w, r, rcv)
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
handler.ServeHTTP(w, r)
|
||||||
|
})
|
||||||
|
} else {
|
||||||
|
handler = middleware.PanicRecovery(handler)
|
||||||
|
}
|
||||||
|
|
||||||
// Configure TLS if any TLS option is enabled
|
// Configure TLS if any TLS option is enabled
|
||||||
tlsConfig, certFile, keyFile, err := configureTLS(cfg)
|
tlsConfig, certFile, keyFile, err := configureTLS(cfg)
|
||||||
@@ -475,6 +486,9 @@ func newInstance(cfg Config) (*serverInstance, error) {
|
|||||||
// The GODEBUG=http2xconnect=1 flag is read by net/http's init(); setting it here
|
// The GODEBUG=http2xconnect=1 flag is read by net/http's init(); setting it here
|
||||||
// ensures it propagates to subprocesses and any future process restarts.
|
// ensures it propagates to subprocesses and any future process restarts.
|
||||||
// For the current process, set GODEBUG=http2xconnect=1 in the environment before launch.
|
// For the current process, set GODEBUG=http2xconnect=1 in the environment before launch.
|
||||||
|
if httpServer.Protocols == nil {
|
||||||
|
httpServer.Protocols = &http.Protocols{}
|
||||||
|
}
|
||||||
if cfg.HTTP2 {
|
if cfg.HTTP2 {
|
||||||
if existing := os.Getenv("GODEBUG"); !strings.Contains(existing, "http2xconnect=1") {
|
if existing := os.Getenv("GODEBUG"); !strings.Contains(existing, "http2xconnect=1") {
|
||||||
if existing == "" {
|
if existing == "" {
|
||||||
|
|||||||
Reference in New Issue
Block a user