net

Documentation

Index

• Constants
• func Dial(addr string, opts ...DialOption) (c net.Conn, err error)
• func DialContext(ctx context.Context, addr string, opts ...DialOption) (c net.Conn, err error)
• type AfterHook
• type AfterHookFunc
• type BeforeHook
• type BeforeHookFunc
• type DialMetas
  • func GetDialMetasFromContext(ctx context.Context) DialMetas
  • func (m DialMetas) Value(key interface{}) interface{}
• type DialOption
  • func WithAfterHook(hook AfterHook) DialOption
  • func WithKeepAlive(keepAlive time.Duration) DialOption
  • func WithLocalAddr(laddr string) DialOption
  • func WithProtocol(protocol string) DialOption
  • func WithProxy(proxyType string, address string) DialOption
  • func WithProxyAuth(auth *ProxyAuth) DialOption
  • func WithTLSConfig(tlsConfig *tls.Config) DialOption
  • func WithTLSConfigAndPriority(priority uint64, tlsConfig *tls.Config) DialOption
  • func WithTimeout(timeout time.Duration) DialOption
• type ProxyAuth
  • func ParseProxyURL(proxyURL string) (proxyType string, address string, auth *ProxyAuth, err error)
• type SharedConn
  • func NewSharedConn(conn net.Conn) (*SharedConn, io.Reader)
  • func NewSharedConnSize(conn net.Conn, bufSize int) (*SharedConn, io.Reader)
  • func (sc *SharedConn) Read(p []byte) (n int, err error)
  • func (sc *SharedConn) ResetBuf(buffer []byte) (err error)

Constants

const (
	DefaultAfterHookPriority = 10
)

Functions

func Dial

func Dial(addr string, opts ...DialOption) (c net.Conn, err error)

func DialContext

func DialContext(ctx context.Context, addr string, opts ...DialOption) (c net.Conn, err error)

Types

type AfterHook

type AfterHook struct {
	// smaller value will be called first, 0 is reserved for private use.
	// If caller set this 0, use DefaultAfterHookPriority instead.
	Priority uint64
	Hook     AfterHookFunc
}

type AfterHookFunc

type AfterHookFunc func(ctx context.Context, c net.Conn, addr string) (context.Context, net.Conn, error)

type BeforeHook

type BeforeHook struct {
	Hook BeforeHookFunc
}

type BeforeHookFunc

type BeforeHookFunc func(ctx context.Context, addr string) context.Context

type DialMetas

type DialMetas map[interface{}]interface{}

func GetDialMetasFromContext

func GetDialMetasFromContext(ctx context.Context) DialMetas

func (DialMetas) Value

func (m DialMetas) Value(key interface{}) interface{}

type DialOption

type DialOption interface {
	// contains filtered or unexported methods
}

func WithAfterHook

func WithAfterHook(hook AfterHook) DialOption

func WithKeepAlive

func WithKeepAlive(keepAlive time.Duration) DialOption

func WithLocalAddr

func WithLocalAddr(laddr string) DialOption

func WithProtocol

func WithProtocol(protocol string) DialOption

func WithProxy

func WithProxy(proxyType string, address string) DialOption

func WithProxyAuth

func WithProxyAuth(auth *ProxyAuth) DialOption

func WithTLSConfig

func WithTLSConfig(tlsConfig *tls.Config) DialOption

func WithTLSConfigAndPriority

func WithTLSConfigAndPriority(priority uint64, tlsConfig *tls.Config) DialOption

func WithTimeout

func WithTimeout(timeout time.Duration) DialOption

type ProxyAuth

type ProxyAuth struct {
	Username string
	Passwd   string
}

func ParseProxyURL

func ParseProxyURL(proxyURL string) (proxyType string, address string, auth *ProxyAuth, err error)

type SharedConn

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

func NewSharedConn

func NewSharedConn(conn net.Conn) (*SharedConn, io.Reader)

the bytes you read in io.Reader, will be reserved in SharedConn

func NewSharedConnSize

func NewSharedConnSize(conn net.Conn, bufSize int) (*SharedConn, io.Reader)

func (*SharedConn) Read

func (sc *SharedConn) Read(p []byte) (n int, err error)

Not thread safety.

func (*SharedConn) ResetBuf

func (sc *SharedConn) ResetBuf(buffer []byte) (err error)