Function resolveOptions

options.go:204–281

resolveOptions applies opts, resolves addresses, creates the transport via elastictransport.NewClient, and returns the resolved settings. metaHeaderSuffix is appended to the meta header (e.g. "hl=1" for TypedClient).

(opts []Option, metaHeaderSuffix string)

//
// metaHeaderSuffix is appended to the meta header (e.g. "hl=1" for TypedClient).
func resolveOptions(opts []Option, metaHeaderSuffix string) (*resolvedOptions, error) {
	var co clientOptions
	var errs []error
	for _, opt := range opts {
		if err := opt.apply(&co); err != nil {
			errs = append(errs, err)
		}
	}
	if len(errs) > 0 {
		return nil, fmt.Errorf("client options: %w", errors.Join(errs...))
	}

	if len(co.addresses) > 0 && co.cloudID != "" {
		return nil, errors.New("cannot create client: both Addresses and CloudID are set")
	}

	var addrs []string
	switch {
	case co.cloudID != "":
		cloudAddr, err := addrFromCloudID(co.cloudID)
		if err != nil {
			return nil, fmt.Errorf("cannot create client: cannot parse CloudID: %s", err)
		}
		addrs = append(addrs, cloudAddr)
	case len(co.addresses) > 0:
		addrs = append(addrs, co.addresses...)
	default:
		addrs = addrsFromEnvironment()
	}

	urls, err := addrsToURLs(addrs)
	if err != nil {
		return nil, fmt.Errorf("cannot create client: %s", err)
	}

	if len(urls) == 0 {
		u, parseErr := parseDefaultURL()
		if parseErr != nil {
			return nil, parseErr
		}
		urls = append(urls, u)
	}

	tpOpts := []elastictransport.Option{
		elastictransport.WithUserAgent(userAgent),
		elastictransport.WithURLs(urls...),
	}

	if urls[0].User != nil {
		username := urls[0].User.Username()
		password, _ := urls[0].User.Password()
		tpOpts = append(tpOpts, elastictransport.WithBasicAuth(username, password))
	}

	tpOpts = append(tpOpts, co.transportOptions...)

	tp, err := elastictransport.NewClient(tpOpts...)
	if err != nil {