Files
streamctl/pkg/observability/observe_panic.go
2024-08-04 15:19:50 +01:00

18 lines
291 B
Go

package observability
import (
"context"
"github.com/facebookincubator/go-belt"
"github.com/facebookincubator/go-belt/tool/experimental/errmon"
)
func PanicIfNotNil(ctx context.Context, r any) {
if r == nil {
return
}
errmon.ObserveRecoverCtx(ctx, r)
belt.Flush(ctx)
panic(r)
}