this.client = client;
        this.settings = settings;
        this.indexName = indexName;
        this.supportedFields = settings.array().get(SuggestSettings.DefaultKeys.SUPPORTED_FIELDS);
        this.totalDocNum = getTotal();
    }

    @Override
    public synchronized Map<String, Object> read() {
        while (!isFinished.get() && queue.isEmpty()) {
            addDocumentToQueue();
        }

        return queue.poll();

    public long getTookMs() {
        return tookMs;
    }

    public List<String> getWords() {
        return words;
    }

    public int getNum() {
        return num;
    }

    public long getTotal() {
        return total;
    }

    public List<SuggestItem> getItems() {
        return items;
    }

    }

    @Override
    public long getProgress() {
        return progress;
    }

    @Override
    public long getTotal() {
        return total;
    }

    @Override
    public String getUnit() {
        return unit;
    }

    /**
     * The total amount of work that the build operation is in the progress of performing, or -1 if not known.
     *
     * @return The total amount of work, or -1 if not known.
     */
    long getTotal();

    /**
     * The measure used to express the amount of work.
     *
     * @return The measure used to express the amount of work.
     */
    String getUnit();

        this.name = name;
        this.total = total;
        this.free = free;
    }

    @Override
    public String getName() {
        return name;
    }

    @Override
    public long getTotal() {
        return total;
    }

    @Override
    public long getFree() {
        return free;
    }

    @Override
    public boolean equals(Object o) {
        if (this == o) {

		if err != nil {
			return
		}

		localityLB := &v1alpha3.LocalityLoadBalancerSetting{}
		err = ff.GenerateStruct(localityLB)
		if err != nil {
			return
		}

		enableFailover, err := ff.GetBool()
		if err != nil {
			return
		}
		ApplyLocalityLoadBalancer(loadAssignment, wrappedLocalityLbEndpoints, locality, proxyLabels, localityLB, enableFailover)
	})

        /**
         * Get the total memory of this category in bytes.
         *
         * @return the total memory of this category in bytes
         */
        long getTotal();

        /**
         * Get the free memory of this category in bytes.
         *
         * @return the free memory of this category in bytes
         */
        long getFree();
    }

    /**

        List<PluginExecution> executions = plugin.getExecutions();

        PluginExecution execution = executions.get(0);

        String g0 = execution.getGoals().get(0);

        assertEquals("plexus:runtime", g0);

        configuration = execution.getDelegate().getConfiguration();

        assertEquals(

	"k8s.io/kube-openapi/pkg/validation/spec"
)

var intOrStringFormat = intstr.IntOrString{}.OpenAPISchemaFormat()

func isExtension(schema *spec.Schema, key string) bool {
	v, ok := schema.Extensions.GetBool(key)
	return v && ok
}

func isXIntOrString(schema *spec.Schema) bool {
	// built-in types have the Format while CRDs use extension
	// both are valid, checking both

        Map<String, List<String>> goals = new HashMap<>();
        lifecycle.phases().forEach(phase -> phase.plugins()
                .forEach(plugin -> plugin.getExecutions().forEach(exec -> exec.getGoals()
                        .forEach(goal -> goals.computeIfAbsent(phase.name(), n -> new ArrayList<>())
                                .add(plugin.getGroupId() + ":" + plugin.getArtifactId() + ":" + plugin.getVersion()