@@ -40,24 +40,24 @@ func TestStandaloneUpgrade(t *testing.T) {
4040 unprivilegedAvailable = true
4141 }
4242 t .Run (fmt .Sprintf ("Upgrade %s to %s (privileged)" , startVersion , define .Version ()), func (t * testing.T ) {
43- testStandaloneUpgrade (t , startVersion , define .Version (), false )
43+ testStandaloneUpgrade (t , startVersion , define .Version (), atesting . ArtifactFetcher (), upgradetest . WithUnprivileged ( false ) )
4444 })
4545 if unprivilegedAvailable {
4646 t .Run (fmt .Sprintf ("Upgrade %s to %s (unprivileged)" , startVersion , define .Version ()), func (t * testing.T ) {
47- testStandaloneUpgrade (t , startVersion , define .Version (), true )
47+ testStandaloneUpgrade (t , startVersion , define .Version (), atesting . ArtifactFetcher (), upgradetest . WithUnprivileged ( true ) )
4848 })
4949 }
5050 }
5151}
5252
53- func testStandaloneUpgrade (t * testing.T , startVersion * version.ParsedSemVer , endVersion string , unprivileged bool ) {
53+ func testStandaloneUpgrade (t * testing.T , startVersion * version.ParsedSemVer , endVersion string , fetcher atesting. Fetcher , upgradeOpts ... upgradetest. UpgradeOpt ) {
5454 ctx , cancel := testcontext .WithDeadline (t , context .Background (), time .Now ().Add (10 * time .Minute ))
5555 defer cancel ()
5656
5757 startFixture , err := atesting .NewFixture (
5858 t ,
5959 startVersion .String (),
60- atesting .WithFetcher (atesting . ArtifactFetcher () ),
60+ atesting .WithFetcher (fetcher ),
6161 )
6262 require .NoError (t , err , "error creating previous agent fixture" )
6363
@@ -73,6 +73,6 @@ func testStandaloneUpgrade(t *testing.T, startVersion *version.ParsedSemVer, end
7373 return
7474 }
7575
76- err = upgradetest .PerformUpgrade (ctx , startFixture , endFixture , t , upgradetest . WithUnprivileged ( unprivileged ) )
76+ err = upgradetest .PerformUpgrade (ctx , startFixture , endFixture , t , upgradeOpts ... )
7777 assert .NoError (t , err )
7878}
0 commit comments