connection

package

v0.0.0-...-3cdde17 Latest Latest Go to latest Published: Apr 27, 2024 License: GPL-3.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/josexy/mini-ss

Links

Open Source Insights

Documentation ¶

Index ¶

type BufioConn
- func NewBufioConn(c net.Conn) *BufioConn
- func (c *BufioConn) Peek(n int) ([]byte, error)
- func (c *BufioConn) Read(p []byte) (int, error)
type CompressConn
- func NewCompressConn(c net.Conn) *CompressConn
- func (c *CompressConn) Read(b []byte) (int, error)
- func (c *CompressConn) Write(b []byte) (int, error)
type ConnExt
type ConnWithReader
- func NewConnWithReader(conn net.Conn, readers ...io.Reader) *ConnWithReader
- func (c *ConnWithReader) Read(b []byte) (int, error)
type GrpcStreamConn
- func NewGrpcClientStreamConn(sc grpc.ClientStream, conn *grpc.ClientConn) *GrpcStreamConn
- func NewGrpcServerStreamConn(ss grpc.ServerStream, lAddr net.Addr) *GrpcStreamConn
- func (c *GrpcStreamConn) Close() error
- func (c *GrpcStreamConn) CloseSender() error
- func (c *GrpcStreamConn) LocalAddr() net.Addr
- func (rw GrpcStreamConn) Read(b []byte) (int, error)
- func (c *GrpcStreamConn) RemoteAddr() net.Addr
- func (c *GrpcStreamConn) SetDeadline(t time.Time) error
- func (c *GrpcStreamConn) SetReadDeadline(t time.Time) error
- func (c *GrpcStreamConn) SetWriteDeadline(t time.Time) error
- func (rw GrpcStreamConn) Write(b []byte) (int, error)
type ObfsConn
- func NewObfsConn(c net.Conn, host string, server bool) *ObfsConn
- func (c *ObfsConn) Handshake() (err error)
- func (c *ObfsConn) Read(b []byte) (n int, err error)
- func (c *ObfsConn) Write(b []byte) (n int, err error)
type QuicCipherConn
- func NewQuicCipherConn(conn net.PacketConn, key []byte) *QuicCipherConn
- func (c *QuicCipherConn) ReadFrom(b []byte) (n int, addr net.Addr, err error)
- func (c *QuicCipherConn) WirteTo(b []byte, addr net.Addr) (n int, err error)
type QuicConn
- func NewQuicConn(stream quic.Stream, laddr, raddr net.Addr) *QuicConn
- func (c *QuicConn) LocalAddr() net.Addr
- func (c *QuicConn) RemoteAddr() net.Addr
type WebsocketConn
- func NewWebsocketConn(c *websocket.Conn) *WebsocketConn
- func (c *WebsocketConn) Close() error
- func (c *WebsocketConn) LocalAddr() net.Addr
- func (c *WebsocketConn) Read(b []byte) (int, error)
- func (c *WebsocketConn) RemoteAddr() net.Addr
- func (c *WebsocketConn) SetDeadline(t time.Time) error
- func (c *WebsocketConn) SetReadDeadline(t time.Time) error
- func (c *WebsocketConn) SetWriteDeadline(t time.Time) error
- func (c *WebsocketConn) Write(b []byte) (int, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BufioConn ¶

type BufioConn struct {
	net.Conn
	// contains filtered or unexported fields
}

func NewBufioConn ¶

func NewBufioConn(c net.Conn) *BufioConn

func (*BufioConn) Peek ¶

func (c *BufioConn) Peek(n int) ([]byte, error)

func (*BufioConn) Read ¶

func (c *BufioConn) Read(p []byte) (int, error)

type CompressConn ¶

type CompressConn struct {
	net.Conn
	// contains filtered or unexported fields
}

func NewCompressConn ¶

func NewCompressConn(c net.Conn) *CompressConn

func (*CompressConn) Read ¶

func (c *CompressConn) Read(b []byte) (int, error)

func (*CompressConn) Write ¶

func (c *CompressConn) Write(b []byte) (int, error)

type ConnExt ¶

type ConnExt interface {
	net.Conn
	CloseSender() error
}

type ConnWithReader ¶

type ConnWithReader struct {
	net.Conn
	// contains filtered or unexported fields
}

func NewConnWithReader ¶

func NewConnWithReader(conn net.Conn, readers ...io.Reader) *ConnWithReader

func (*ConnWithReader) Read ¶

func (c *ConnWithReader) Read(b []byte) (int, error)

type GrpcStreamConn ¶

type GrpcStreamConn struct {
	// contains filtered or unexported fields
}

func NewGrpcClientStreamConn ¶

func NewGrpcClientStreamConn(sc grpc.ClientStream, conn *grpc.ClientConn) *GrpcStreamConn

func NewGrpcServerStreamConn ¶

func NewGrpcServerStreamConn(ss grpc.ServerStream, lAddr net.Addr) *GrpcStreamConn

func (*GrpcStreamConn) Close ¶

func (c *GrpcStreamConn) Close() error

func (*GrpcStreamConn) CloseSender ¶

func (c *GrpcStreamConn) CloseSender() error

func (*GrpcStreamConn) LocalAddr ¶

func (c *GrpcStreamConn) LocalAddr() net.Addr

func (GrpcStreamConn) Read ¶

func (rw GrpcStreamConn) Read(b []byte) (int, error)

func (*GrpcStreamConn) RemoteAddr ¶

func (c *GrpcStreamConn) RemoteAddr() net.Addr

func (*GrpcStreamConn) SetDeadline ¶

func (c *GrpcStreamConn) SetDeadline(t time.Time) error

func (*GrpcStreamConn) SetReadDeadline ¶

func (c *GrpcStreamConn) SetReadDeadline(t time.Time) error

func (*GrpcStreamConn) SetWriteDeadline ¶

func (c *GrpcStreamConn) SetWriteDeadline(t time.Time) error

func (GrpcStreamConn) Write ¶

func (rw GrpcStreamConn) Write(b []byte) (int, error)

type ObfsConn ¶

type ObfsConn struct {
	net.Conn
	// contains filtered or unexported fields
}

func NewObfsConn ¶

func NewObfsConn(c net.Conn, host string, server bool) *ObfsConn

func (*ObfsConn) Handshake ¶

func (c *ObfsConn) Handshake() (err error)

func (*ObfsConn) Read ¶

func (c *ObfsConn) Read(b []byte) (n int, err error)

func (*ObfsConn) Write ¶

func (c *ObfsConn) Write(b []byte) (n int, err error)

Write HTTP/SOCKS payload data into http request body section

type QuicCipherConn ¶

type QuicCipherConn struct {
	net.PacketConn
	// contains filtered or unexported fields
}

func NewQuicCipherConn ¶

func NewQuicCipherConn(conn net.PacketConn, key []byte) *QuicCipherConn

func (*QuicCipherConn) ReadFrom ¶

func (c *QuicCipherConn) ReadFrom(b []byte) (n int, addr net.Addr, err error)

func (*QuicCipherConn) WirteTo ¶

func (c *QuicCipherConn) WirteTo(b []byte, addr net.Addr) (n int, err error)

type QuicConn ¶

type QuicConn struct {
	quic.Stream
	// contains filtered or unexported fields
}

func NewQuicConn ¶

func NewQuicConn(stream quic.Stream, laddr, raddr net.Addr) *QuicConn

func (*QuicConn) LocalAddr ¶

func (c *QuicConn) LocalAddr() net.Addr

func (*QuicConn) RemoteAddr ¶

func (c *QuicConn) RemoteAddr() net.Addr

type WebsocketConn ¶

type WebsocketConn struct {
	// contains filtered or unexported fields
}

func NewWebsocketConn ¶

func NewWebsocketConn(c *websocket.Conn) *WebsocketConn

func (*WebsocketConn) Close ¶

func (c *WebsocketConn) Close() error

func (*WebsocketConn) LocalAddr ¶

func (c *WebsocketConn) LocalAddr() net.Addr

func (*WebsocketConn) Read ¶

func (c *WebsocketConn) Read(b []byte) (int, error)

func (*WebsocketConn) RemoteAddr ¶

func (c *WebsocketConn) RemoteAddr() net.Addr

func (*WebsocketConn) SetDeadline ¶

func (c *WebsocketConn) SetDeadline(t time.Time) error

func (*WebsocketConn) SetReadDeadline ¶

func (c *WebsocketConn) SetReadDeadline(t time.Time) error

func (*WebsocketConn) SetWriteDeadline ¶

func (c *WebsocketConn) SetWriteDeadline(t time.Time) error

func (*WebsocketConn) Write ¶

func (c *WebsocketConn) Write(b []byte) (int, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
proto

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL