| 86 | } |
| 87 | |
| 88 | func (o *rawTCPService) EstablishConnection(ctx context.Context, dest string, logger *zerolog.Logger) (OriginConnection, error) { |
| 89 | conn, err := o.dialer.DialContext(ctx, "tcp", dest) |
| 90 | if err != nil { |
| 91 | return nil, err |
| 92 | } |
| 93 | |
| 94 | originConn := &tcpConnection{ |
| 95 | Conn: conn, |
| 96 | writeTimeout: o.writeTimeout, |
| 97 | logger: logger, |
| 98 | } |
| 99 | return originConn, nil |
| 100 | } |
| 101 | |
| 102 | func (o *tcpOverWSService) EstablishConnection(ctx context.Context, dest string, _ *zerolog.Logger) (OriginConnection, error) { |
| 103 | var err error |