// limitations under the License.

package multicluster

import (
	"istio.io/istio/pkg/cluster"
	"istio.io/istio/pkg/kube"
)

type Fake struct {
	handlers []handler
}

func (f *Fake) registerHandler(h handler) {
	f.handlers = append(f.handlers, h)
}

func (f *Fake) Add(id cluster.ID, client kube.Client, stop chan struct{}) {
	for _, handler := range f.handlers {
		handler.clusterAdded(&Cluster{

  CHECK(corert);
  auto fallback_op_handler = tensorflow::tfd::CreateKernelFallbackOpHandler(
      corert->get(), corert->get()->GetHostContext()->GetHostDeviceRef());
  CHECK(fallback_op_handler);
  corert.get()->RegisterOpHandler("tfkernel", fallback_op_handler.get());
  return std::move(corert.get());
}

tfrt::RCArray<tfrt::AsyncValue> CreateTestArguments(const tfrt::Function* func,

			ObjectFilter: ec.client.ObjectFilter(),
		})
		// Register callbacks for events.
		registerHandlers(ec.Controller, ec.serviceExports, "ServiceExports", ec.onServiceExportEvent, nil)

		// Set the discoverability policy for the clusterset.local host.

From this connection individual requests can be made.

Each handler, with optional subroutes can be registered with the manager using 
`Manager.RegisterXHandler(handlerID, handler, subroutes...)`.

A `Handler()` function provides an HTTP handler, which should be hooked up to the appropriate route on the server.