netconn

Documentation

Index

• type FlushWriter
  • func NoopFlusher(w io.Writer) FlushWriter
• type NetConn
  • func DialNewConn(addr string, options ...Option) (NetConn, error)
  • func ErrorNetConn(err error) NetConn
• type Option
  • func WithBufferSize(size int) Option
  • func WithDialFunc(...) Option
  • func WithReadTimeout(d time.Duration) Option
  • func WithTCPKeepAliveDuration(d time.Duration) Option
  • func WithWriteTimeout(d time.Duration) Option

Types

type FlushWriter

type FlushWriter interface {
	io.Writer
	Flush() error
}

FlushWriter ...

func NoopFlusher

func NoopFlusher(w io.Writer) FlushWriter

NoopFlusher ...

type NetConn

type NetConn struct {
	Writer FlushWriter
	Closer io.Closer
	Reader io.ReadCloser
}

NetConn ...

func DialNewConn

func DialNewConn(addr string, options ...Option) (NetConn, error)

DialNewConn ...

func ErrorNetConn

func ErrorNetConn(err error) NetConn

ErrorNetConn ...

type Option

type Option func(conf *config)

Option ...

func WithBufferSize

func WithBufferSize(size int) Option

WithBufferSize ...

func WithDialFunc

func WithDialFunc(dialFunc func(network, address string, timeout time.Duration) (net.Conn, error)) Option

WithDialFunc ...

func WithReadTimeout

func WithReadTimeout(d time.Duration) Option

WithReadTimeout ...

func WithTCPKeepAliveDuration

func WithTCPKeepAliveDuration(d time.Duration) Option

WithTCPKeepAliveDuration sets the tcp keep alive duration

func WithWriteTimeout

func WithWriteTimeout(d time.Duration) Option

WithWriteTimeout ...