(ctx context.Context, authority string, rawConn net.Conn)
| 93 | } |
| 94 | |
| 95 | func (c *clusterTransportCreds) ClientHandshake(ctx context.Context, authority string, rawConn net.Conn) (net.Conn, credentials.AuthInfo, error) { |
| 96 | if isDirectPathCluster(ctx) { |
| 97 | // If attributes have cluster name, and cluster name is not cfe, it's a |
| 98 | // backend address, use ALTS. |
| 99 | return c.alts.ClientHandshake(ctx, authority, rawConn) |
| 100 | } |
| 101 | return c.tls.ClientHandshake(ctx, authority, rawConn) |
| 102 | } |
| 103 | |
| 104 | func (c *clusterTransportCreds) ServerHandshake(conn net.Conn) (net.Conn, credentials.AuthInfo, error) { |
| 105 | return c.tls.ServerHandshake(conn) |
nothing calls this directly
no test coverage detected