mux

Documentation

Index

• type Conn
  • func NewConn(dialFn func() (io.ReadWriteCloser, error)) *Conn
  • func (conn *Conn) NumStreams() int
  • func (conn *Conn) OpenStream() (*smux.Stream, error)
• type Pool
  • func NewPool(maxIdle, maxMux int, dialFn func() (io.ReadWriteCloser, error)) *Pool
  • func (p *Pool) GetStream() (*smux.Stream, error)

Types

type Conn

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

Conn wraps mux session

func NewConn

func NewConn(dialFn func() (io.ReadWriteCloser, error)) *Conn

NewConn method

func (*Conn) NumStreams

func (conn *Conn) NumStreams() int

func (*Conn) OpenStream

func (conn *Conn) OpenStream() (*smux.Stream, error)

OpenStream warps session's openStream with retry

type Pool

type Pool struct {
	MaxIdle int
	MaxMux  int
	// contains filtered or unexported fields
}

Pool implement mux conn pool

func NewPool

func NewPool(maxIdle, maxMux int, dialFn func() (io.ReadWriteCloser, error)) *Pool

NewPool method

func (*Pool) GetStream

func (p *Pool) GetStream() (*smux.Stream, error)

GetStream fetch a stream from conn pool