}

// Dial connects to a ADS server, with optional MTLS authentication if a cert dir is specified.
func (a *ADSC) Dial() error {
	conn, err := dialWithConfig(&a.cfg.Config)
	if err != nil {
		return err
	}
	a.conn = conn
	return nil
}

func dialWithConfig(config *Config) (*grpc.ClientConn, error) {
	defaultGrpcDialOptions := defaultGrpcDialOptions()
	var grpcDialOptions []grpc.DialOption

	c.sendNodeMeta.Store(true)
	c.xdsClient = xdsClient
	go c.handleRecv()
	for _, w := range c.initialWatches {
		c.request(w)
	}
	return nil
}

func (c *Client) Dial() error {
	conn, err := dialWithConfig(&c.cfg.Config)
	if err != nil {
		return err
	}
	c.conn = conn
	return nil
}

// reconnect will create a new stream
func (c *Client) reconnect() {
	c.mutex.RLock()
	if c.closed {