Function mustResumableState

resumable.go:153–160

(ctx context.Context)

}

func mustResumableState(ctx context.Context) *rivermiddleware.ResumableState {
	state, ok := resumableStateFromContext(ctx)
	if !ok {
		panic(errResumableStepNotInWorker)
	}

	return state
}

func registerResumableStepName(state *rivermiddleware.ResumableState, name string) bool {
	if _, ok := state.AllStepNames[name]; ok {