Function DefaultMiddleware

internal/rivermiddleware/middleware.go:18–20

DefaultMiddleware returns the default middleware that River applies to all jobs. This includes internal middleware like the resumable step middleware.

()

// DefaultMiddleware returns the default middleware that River applies to all
// jobs. This includes internal middleware like the resumable step middleware.
func DefaultMiddleware() []rivertype.Middleware {
	return []rivertype.Middleware{&ResumableMiddleware{}}
}

// ResumableMiddleware is internal middleware that enables resumable step
// functionality. It reads the last completed step and cursor data from job