tunnel

Aug 4, 2025

Changes in this version

+ var ErrStreamClosed = errors.New("stream closed")

+ func NewInsecureHttpClient() *http.Client

+ type ConnectionProvider struct

+ func NewConnectionProvider(bufferSize int) *ConnectionProvider

+ func (l *ConnectionProvider) Accept() (net.Conn, error)

+ func (l *ConnectionProvider) Addr() net.Addr

+ func (l *ConnectionProvider) Close() error

+ func (l *ConnectionProvider) ProvideConn(conn net.Conn)

+ type WrappedStream struct

+ func NewWrappedStream(stream *connect.BidiStream[v1.TunnelMessage, v1.TunnelMessage], ...) *WrappedStream

+ func NewWrappedStreamFromClient(stream *connect.BidiStreamForClient[v1.TunnelMessage, v1.TunnelMessage], ...) *WrappedStream

+ func (ws *WrappedStream) Dial() (net.Conn, error)

+ func (ws *WrappedStream) HandlePackets(ctx context.Context) error

+ func (ws *WrappedStream) IsReady() bool

+ func (ws *WrappedStream) ProvideConnectionsTo(provider *ConnectionProvider)

+ func (ws *WrappedStream) Shutdown() error

+ type WrappedStreamOptions func(*WrappedStream)

+ func WithHeartbeatInterval(interval time.Duration) WrappedStreamOptions

+ func WithLogger(logger *zap.Logger) WrappedStreamOptions