// limitations under the License.

package api

import (
	"context"
	"encoding/json"
	"fmt"
	"os"
	"path/filepath"
	"strings"
	"testing"
	"time"

	promv1 "github.com/prometheus/client_golang/api/prometheus/v1"
	"github.com/prometheus/common/model"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"

	"istio.io/istio/pkg/config/protocol"
	"istio.io/istio/pkg/http/headers"

/**
 * Requests that the client present the given prompt to the user and return the user's response as a single line of text.
 *
 * The response is delivered to the {@link UserInputReader} service.
 */
public abstract class PromptOutputEvent extends RenderableOutputEvent implements InteractiveEvent {
    public PromptOutputEvent(long timestamp) {
        super(timestamp, "prompt", LogLevel.QUIET, null);
    }

    @Override

        param("channel", "adhoc")
        param("checks", "all")
        text("runs", "10", display = ParameterDisplay.PROMPT, allowEmpty = false)
        text("warmups", "3", display = ParameterDisplay.PROMPT, allowEmpty = false)
        text(
            "scenario",
            "",
            display = ParameterDisplay.PROMPT,
            allowEmpty = false,

            display = ParameterDisplay.PROMPT,
            allowEmpty = false,
            description = "The test task you want to run"
        )
        text(
            testNameParameterName,
            """org.gradle.api.tasks.CachedTaskExecutionIntegrationTest.outputs*are*correctly*loaded*from*cache""",
            display = ParameterDisplay.PROMPT,
            allowEmpty = false,

	return c.api[cluster.Name()]
}

func (c *kubeComponent) RawQuery(cluster cluster.Cluster, promQL string) (model.Value, error) {
	scopes.Framework.Debugf("Query running: %s", promQL)

	v, _, err := c.api[cluster.Name()].Query(context.Background(), promQL, time.Now())
	if err != nil {
		return nil, fmt.Errorf("error querying Prometheus: %v", err)
	}

package org.gradle.internal.logging.events

import spock.lang.Specification

class YesNoQuestionPromptEventTest extends Specification {
    def "formats prompt"() {
        def event = new YesNoQuestionPromptEvent(123, "question?")

        expect:
        event.prompt == "question? [yes, no] " // trailing space
    }

    def "accepts valid input"() {
        def event = new YesNoQuestionPromptEvent(123, "question?")

package org.gradle.internal.logging.events

import spock.lang.Specification

class BooleanQuestionPromptEventTest extends Specification {
    def "formats prompt"() {
        def event = new BooleanQuestionPromptEvent(123, "question?", true)

        expect:
        event.prompt == "question? (default: yes) [yes, no] " // trailing space
    }

    def "accepts valid input"() {

    private OutputEventListener console;

    /**
     * This instance requires access to the "console" pipeline in order to prompt the user when there are validation problems.
     * However, the console pipeline also needs access to this instance in order to handle user input prompt requests.
     * Break this cycle for now using a non-final field.
     */
    public void attachConsole(OutputEventListener console) {

 */

package org.gradle.internal.logging.events

import spock.lang.Specification

class IntQuestionPromptEventTest extends Specification {
    def "formats prompt"() {
        def event = new IntQuestionPromptEvent(123, "question?", 2, 4)
        assert event.prompt == "enter value (min: 2, default: 4): "
    }

    def "accepts valid input"() {
        def event = new IntQuestionPromptEvent(123, "question?", 2, 4)

import org.gradle.util.internal.TextUtil
import spock.lang.Specification

class SelectOptionPromptEventTest extends Specification {
    def "formats prompt"() {
        def event = new SelectOptionPromptEvent(123, "question", ["11", "12", "13"], 1)

        assert event.prompt == TextUtil.toPlatformLineSeparators("""question:
  1: 11
  2: 12
  3: 13
Enter selection (default: 12) [1..3] """)
    }