conn

Documentation

Index

• Variables
• type Conn
  • func (conn *Conn) Close() error
  • func (conn *Conn) Info() string
  • func (conn *Conn) Read(b []byte) (int, error)
  • func (conn *Conn) Write(b []byte) (int, error)
• type HttpClient
  • func (hc *HttpClient) Close()
  • func (hc *HttpClient) Do(req *http.Request) (*http.Response, error)
  • func (hc *HttpClient) Get(url string) (*http.Response, error)
  • func (hc *HttpClient) Info() string
  • func (hc *HttpClient) NRead() int64
  • func (hc *HttpClient) NWrite() int64
• type Pool
  • func New(conf *conf.Conf, addrs []string, limit int64, retry int) *Pool
  • func (pool *Pool) Get(ctx context.Context) *Conn
  • func (pool *Pool) GetHttp(ctx context.Context) (*HttpClient, error)
  • func (pool *Pool) Put(c *Conn)

Variables

var (
	ErrTypeError = errors.New("type error")
	ErrUnknown   = errors.New("unknown error")
)

Types

type Conn

type Conn struct {
	net.Conn

	ID int64
	// contains filtered or unexported fields
}

func (*Conn) Close

func (conn *Conn) Close() error

func (*Conn) Info

func (conn *Conn) Info() string

func (*Conn) Read

func (conn *Conn) Read(b []byte) (int, error)

func (*Conn) Write

func (conn *Conn) Write(b []byte) (int, error)

type HttpClient

type HttpClient struct {
	*http.Client

	PostCount int64
	GetCount  int64
	DoCount   int64
	ErrCount  int64
	// contains filtered or unexported fields
}

func (*HttpClient) Close

func (hc *HttpClient) Close()

func (*HttpClient) Do

func (hc *HttpClient) Do(req *http.Request) (*http.Response, error)

func (*HttpClient) Get

func (hc *HttpClient) Get(url string) (*http.Response, error)

func (*HttpClient) Info

func (hc *HttpClient) Info() string

func (*HttpClient) NRead

func (hc *HttpClient) NRead() int64

func (*HttpClient) NWrite

func (hc *HttpClient) NWrite() int64

type Pool

type Pool struct {
	ID int64
	sync.Pool
	// contains filtered or unexported fields
}

func New

func New(conf *conf.Conf, addrs []string, limit int64, retry int) *Pool

func (*Pool) Get

func (pool *Pool) Get(ctx context.Context) *Conn

func (*Pool) GetHttp

func (pool *Pool) GetHttp(ctx context.Context) (*HttpClient, error)

func (*Pool) Put

func (pool *Pool) Put(c *Conn)