Function dialOptions

internal/proxy/proxy.go:286–317

dialOptions interprets appropriate dial options for a particular instance configuration

(c Config, i InstanceConnConfig)

// dialOptions interprets appropriate dial options for a particular instance
// configuration
func dialOptions(c Config, i InstanceConnConfig) []cloudsqlconn.DialOption {
	var opts []cloudsqlconn.DialOption

	if i.IAMAuthN != nil {
		opts = append(opts, cloudsqlconn.WithDialIAMAuthN(*i.IAMAuthN))
	}
	if i.SQLDataEnabled != nil && *i.SQLDataEnabled || c.SQLDataEnabled {
		opts = append(opts, cloudsqlconn.WithSQLData())
	}

	switch {
	// If private IP is enabled at the instance level, or private IP is enabled globally
	// add the option.
	case i.PrivateIP != nil && *i.PrivateIP || i.PrivateIP == nil && c.PrivateIP:
		opts = append(opts, cloudsqlconn.WithPrivateIP())
	// If PSC is enabled at the instance level, or PSC is enabled globally
	// add the option.
	case i.PSC != nil && *i.PSC || i.PSC == nil && c.PSC:
		opts = append(opts, cloudsqlconn.WithPSC())
	case c.AutoIP:
		opts = append(opts, cloudsqlconn.WithAutoIP())
	default:
		// assume public IP by default
	}
	if networkType(&c, i) == "unix" {
		opts = append(opts, cloudsqlconn.WithMdxClientProtocolType("uds"))
	} else {
		opts = append(opts, cloudsqlconn.WithMdxClientProtocolType("tcp"))
	}

	return opts
}

func parseImpersonationChain(chain string) (string, []string) {
	accts := strings.Split(chain, ",")