create wrapper around Mirror method

Author: asiyani

pkg/mirror/example_noworktree_test.go

@@ -48,7 +48,7 @@ repositories:
 
 	// perform 1st mirror to ensure all repositories
 	// initial mirror might take longer
-	if err := repos.Mirror(ctx, 5*time.Minute); err != nil {
+	if err := repos.MirrorAll(ctx, 5*time.Minute); err != nil {
 		panic(err)
 	}
 

pkg/mirror/example_worktree_test.go

@@ -51,7 +51,7 @@ repositories:
 
 	// perform 1st mirror to ensure all repositories
 	// initial mirror might take longer
-	if err := repos.Mirror(ctx, 5*time.Minute); err != nil {
+	if err := repos.MirrorAll(ctx, 5*time.Minute); err != nil {
 		panic(err)
 	}
 

pkg/mirror/repo_pool.go

@@ -68,11 +68,11 @@ func (rp *RepoPool) AddRepository(repo *Repository) error {
 	return nil
 }
 
-// Mirror will trigger mirror on every repo in foreground with given timeout.
+// MirrorAll will trigger mirror on every repo in foreground with given timeout.
 // It will error out if any of the repository mirror errors.
-// Ideally Mirror should be used for the first mirror cycle to ensure repositories are
+// Ideally MirrorAll should be used for the first mirror cycle to ensure repositories are
 // successfully mirrored
-func (rp *RepoPool) Mirror(ctx context.Context, timeout time.Duration) error {
+func (rp *RepoPool) MirrorAll(ctx context.Context, timeout time.Duration) error {
 	for _, repo := range rp.repos {
 		mCtx, cancel := context.WithTimeout(ctx, timeout)
 		err := repo.Mirror(mCtx)
@@ -85,6 +85,16 @@ func (rp *RepoPool) Mirror(ctx context.Context, timeout time.Duration) error {
 	return nil
 }
 
+// Mirror is wrapper around repositories Mirror method
+func (rp *RepoPool) Mirror(ctx context.Context, remote string) error {
+	repo, err := rp.Repository(remote)
+	if err != nil {
+		return err
+	}
+
+	return repo.Mirror(ctx)
+}
+
 // StartLoop will start mirror loop on all repositories
 // if its not already started
 func (rp *RepoPool) StartLoop() {

pkg/mirror/z_e2e_test.go

@@ -1165,7 +1165,7 @@ func Test_RepoPool_Success(t *testing.T) {
 	}
 
 	// run initial mirror
-	if err := rp.Mirror(context.TODO(), testTimeout); err != nil {
+	if err := rp.MirrorAll(context.TODO(), testTimeout); err != nil {
 		t.Fatalf("unexpected err:%s", err)
 	}