asyncwriteconn

Documentation

Index

• type Conn
  • func New(conn net.Conn, options ...OptionSetterFunc) (*Conn, error)
  • func (c *Conn) Close() error
  • func (c *Conn) LocalAddr() net.Addr
  • func (c *Conn) Read(b []byte) (n int, err error)
  • func (c *Conn) RemoteAddr() net.Addr
  • func (c *Conn) SetDeadline(t time.Time) error
  • func (c *Conn) SetReadDeadline(t time.Time) error
  • func (c *Conn) SetWriteDeadline(t time.Time) error
  • func (c *Conn) Write(b []byte) (n int, err error)
• type Metrics
  • func NewMetrics() *Metrics
• type Option
  • func NewOption() *Option
• type OptionSetter
• type OptionSetterFunc
  • func WithMetrics(m *Metrics) OptionSetterFunc
  • func WithOption(o *Option) OptionSetterFunc

Types

type Conn

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

func New

func New(conn net.Conn, options ...OptionSetterFunc) (*Conn, error)

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) LocalAddr

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

func (*Conn) Read

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

func (*Conn) RemoteAddr

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

func (*Conn) SetDeadline

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

func (*Conn) SetReadDeadline

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

func (*Conn) SetWriteDeadline

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

func (*Conn) Write

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

type Metrics

type Metrics = asyncwriter.Metrics

func NewMetrics

func NewMetrics() *Metrics

type Option

type Option = asyncwriter.Option

func NewOption

func NewOption() *Option

type OptionSetter

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

type OptionSetterFunc

type OptionSetterFunc func(*Conn)

func WithMetrics

func WithMetrics(m *Metrics) OptionSetterFunc

func WithOption

func WithOption(o *Option) OptionSetterFunc