()
| 747 | } |
| 748 | |
| 749 | func (c *client) localIP() net.IP { |
| 750 | if c.proxy.localNode.addr != nil { |
| 751 | return c.proxy.localNode.addr.IP |
| 752 | } else { |
| 753 | switch a := c.conn.LocalAddr().(type) { |
| 754 | case *net.TCPAddr: |
| 755 | return a.IP |
| 756 | case *net.IPAddr: |
| 757 | return a.IP |
| 758 | default: |
| 759 | panic("unhandled local address type") |
| 760 | } |
| 761 | } |
| 762 | } |
| 763 | |
| 764 | func (c *client) filterSystemPeerValues(stmt *parser.SelectStatement, filtered []*message.ColumnMetadata, peer *node, peerCount int) (row []message.Column, err error) { |
| 765 | return parser.FilterValues(stmt, filtered, func(name string) (value message.Column, err error) { |
no test coverage detected