Method Do

esapi/api.cluster.info.go:68–171

Do executes the request and returns response or error.

(providedCtx context.Context, transport Transport)

// Do executes the request and returns response or error.
func (r ClusterInfoRequest) Do(providedCtx context.Context, transport Transport) (*Response, error) {
	var (
		method string
		path   strings.Builder
		params map[string]string
		ctx    context.Context
	)

	if instrument, ok := r.Instrument.(Instrumentation); ok {
		ctx = instrument.Start(providedCtx, "cluster.info")
		defer instrument.Close(ctx)
	}
	if ctx == nil {
		ctx = providedCtx
	}

	method = "GET"

	if len(r.Target) == 0 {
		return nil, errors.New("target is required and cannot be nil or empty")
	}

	path.Grow(7 + 1 + len("_info") + 1 + len(strings.Join(r.Target, ",")))
	path.WriteString("http://")
	path.WriteString("/")
	path.WriteString("_info")
	path.WriteString("/")
	path.WriteString(strings.Join(r.Target, ","))
	if instrument, ok := r.Instrument.(Instrumentation); ok {
		instrument.RecordPathPart(ctx, "target", strings.Join(r.Target, ","))
	}

	params = make(map[string]string)

	if r.Pretty {
		params["pretty"] = "true"
	}

	if r.Human {
		params["human"] = "true"
	}

	if r.ErrorTrace {
		params["error_trace"] = "true"
	}

	if len(r.FilterPath) > 0 {
		params["filter_path"] = strings.Join(r.FilterPath, ",")
	}

	req, err := newRequest(method, path.String(), nil)
	if err != nil {
		if instrument, ok := r.Instrument.(Instrumentation); ok {
			instrument.RecordError(ctx, err)
		}
		return nil, err
	}