// implementations of certain APIs that are required for calibration.
// `module_op` is the input graph to be quantized and it should contain
// StableHLO ops.
//
// Returns a quantized `ModuleOp` in StableHLO, potentially wrapped inside a
// XlaCallModuleOp. Returns a non-OK status if quantization fails, or any of
// `saved_model_bundle` or `quantization_py_function_lib` is a nullptr.
absl::StatusOr<mlir::ModuleOp> RunQuantization(

	log.Infof("Creating operator metrics exporter available at %s", metricsOptions.BindAddress)
	registry := ctrlmetrics.Registry.(*prometheus.Registry)
	wrapped := prometheus.WrapRegistererWithPrefix("istio_install_operator_", registry)

	if _, err := monitoring.RegisterPrometheusExporter(wrapped, registry); err != nil {
		log.Warnf("Error while building exporter: %v", err)
	}

	log.Info("Registering Components.")

// RUN: flatbuffer_translate -mlir-to-tflite-flatbuffer --emit-stablehlo-ops=true %s -o - | flatbuffer_translate --tflite-flatbuffer-to-mlir --disable-vhlo-to-stablehlo=true - -o - | FileCheck %s
// test stablehlo roundtrip

//test TF ops wrapped in stablehlo custom_call

// Identity function to make the exporter happy
func.func @main(%arg0: tensor<4xi8>) -> tensor<4xi8> {
  func.return %arg0 : tensor<4xi8>
}

	return true
}

// Returns the keys of all the wrapped envoyfilters.
func (efw *EnvoyFilterWrapper) Keys() []string {
	if efw == nil {
		return nil
	}
	keys := sets.String{}
	for _, patches := range efw.Patches {
		for _, patch := range patches {
			keys.Insert(patch.Key())
		}
	}
	return sets.SortedList(keys)
}

// Returns the keys of all the wrapped envoyfilters.

	}
}

func (c *DeadlineConn) setWriteDeadline() {
	if c.writeDeadline > 0 {
		c.Conn.SetWriteDeadline(time.Now().UTC().Add(c.writeDeadline))
	}
}

// Read - reads data from the connection using wrapped buffered reader.
func (c *DeadlineConn) Read(b []byte) (n int, err error) {
	c.setReadDeadline()
	n, err = c.Conn.Read(b)
	return n, err
}

// Write - writes data to the connection.

            sb.append(ste.toString());
            sb.append(SystemProperties.getInstance().getLineSeparator());
        }
        deprecation.put("stackTrace", sb.toString());
        // the properties are wrapped to an enclosing map to improve the readability of the trace files
        return Collections.singletonMap("deprecation", deprecation);
    }

            [fromString(), "command.execute(null, (File) null)", "", ""],
            [fromString(), "command.execute((String[]) null, (File) null)", "", ""],
            // type-wrapped arguments
            [fromString(), "command.execute((String[]) ['FOOBAR=foobar'], null)", "", "foobar"],
            [fromString(), "command.execute((List) ['FOOBAR=foobar'], null)", "", "foobar"],

type JSON struct {
	Object interface{}
}

// DeepCopy creates a deep copy of the wrapped JSON value.
func (j JSON) DeepCopy() JSON {
	return JSON{runtime.DeepCopyJSONValue(j.Object)}
}

// DeepCopyInto creates a deep copy of the wrapped JSON value and stores it in into.
func (j JSON) DeepCopyInto(into *JSON) {
	into.Object = runtime.DeepCopyJSONValue(j.Object)

}

func ZeroArgumentFunctionBinding(binding func() ref.Val) decls.OverloadOpt {
	return func(o *decls.OverloadDecl) (*decls.OverloadDecl, error) {
		wrapped, err := decls.FunctionBinding(func(values ...ref.Val) ref.Val { return binding() })(o)
		if err != nil {
			return nil, err
		}
		if len(wrapped.ArgTypes()) != 0 {
			return nil, fmt.Errorf("function binding must have 0 arguments")
		}
		return o, nil
	}
}

func (b *secretVolumeMounter) SetUpAt(dir string, mounterArgs volume.MounterArgs) error {
	klog.V(3).Infof("Setting up volume %v for pod %v at %v", b.volName, b.pod.UID, dir)

	// Wrap EmptyDir, let it do the setup.
	wrapped, err := b.plugin.host.NewWrapperMounter(b.volName, wrappedVolumeSpec(), &b.pod, *b.opts)
	if err != nil {
		return err
	}

	optional := b.source.Optional != nil && *b.source.Optional