def METHOD_NAME(
    provider: str,
    probe_builder: Callable[
        [EndpointMonitoringProvider, list[Endpoint]], Optional[OpenshiftResource]
    ],
    integration: str,
    integration_version: str,
    dry_run: bool,
    thread_pool_size: int,
    internal: bool,
    use_jump_host: bool,
    defer=None,
) -> None:
    # prepare
    desired_endpoints = get_endpoints(provider)
    namespaces = [p.namespace for p in desired_endpoints if p.namespace]
    if namespaces:
        ri, oc_map = ob.fetch_current_state(
            namespaces,
            thread_pool_size=thread_pool_size,
            internal=internal,
            use_jump_host=use_jump_host,
            integration=integration,
            integration_version=integration_version,
            override_managed_types=["Probe"],
        )
        defer(oc_map.cleanup)
        # reconcile
        for ep_mon_provider, endpoints in desired_endpoints.items():
            probe = probe_builder(ep_mon_provider, endpoints)
            if probe:
                fill_desired_state(ep_mon_provider, probe, ri)
        ob.realize_data(dry_run, oc_map, ri, thread_pool_size, recycle_pods=False)
        if ri.has_error_registered():
            raise ClosedBoxReconcilerError("ResourceInventory has registered errors")