| 294 | } |
| 295 | |
| 296 | type errorHandlerWrapper struct { |
| 297 | HandleErrorFunc func(ctx context.Context, job *rivertype.JobRow, err error) *jobexecutor.ErrorHandlerResult |
| 298 | HandlePanicFunc func(ctx context.Context, job *rivertype.JobRow, panicVal any, trace string) *jobexecutor.ErrorHandlerResult |
| 299 | } |
| 300 | |
| 301 | func (h *errorHandlerWrapper) HandleError(ctx context.Context, job *rivertype.JobRow, err error) *jobexecutor.ErrorHandlerResult { |
| 302 | return h.HandleErrorFunc(ctx, job, err) |
nothing calls this directly
no outgoing calls
no test coverage detected