def METHOD_NAME(
    self,
    awscli_pod_session,
    mcg_obj,
    bucket_factory,
    bucketclass,
    replication_bucketclass,
    s3bench,
    wait_time=120,
):
    """
    Test unidirectional bucket replication adding objects to:
        - Object buckets - backingstore
        - Namespace buckets - namespacestore
    """
    replication_buckets = bucket_factory(
        amount=self.MCG_BUCKET,
        bucketclass=replication_bucketclass,
        verify_health=False,
    )
    endpoints = list()
    source_buckets = list()
    for bucket in replication_buckets:
        replication_policy = ("basic-replication-rule", bucket.name, None)
        source_bucket = bucket_factory(
            amount=1,
            bucketclass=bucketclass,
            replication_policy=replication_policy,
            verify_health=False,
        )[0]
        end_point = (
            "http://"
            + mcg_obj.s3_internal_endpoint.split("/")[2].split(":")[0]
            + "/"
            + f"{source_bucket.name}"
        )
        endpoints.append(end_point)
        source_bucket.verify_health(timeout=180)
        source_buckets.append(source_bucket)
    for endpoint in endpoints:
        s3bench.run_benchmark(
            num_obj=self.MCG_S3_OBJ,
            timeout=7200,
            access_key=mcg_obj.access_key_id,
            secret_key=mcg_obj.access_key,
            end_point=endpoint,
            run_mode="pg",
        )
    time.sleep(wait_time)
    # Restart Noobaa-core pod
    scale_noobaa_lib.noobaa_running_node_restart(pod_name="noobaa-db")
    # Verify bucket replication
    for i in range(len(replication_buckets)):
        compare_bucket_object_list(
            mcg_obj, replication_buckets[i].name, source_buckets[i].name
        )