conn

Documentation

Index

• Constants
• Variables
• type Any
• 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 (client *HttpClient) Do(meta task.Meta, req *http.Request) (*http.Response, error)
  • func (client *HttpClient) Get(meta task.Meta, url string) (*http.Response, error)
  • func (client *HttpClient) Info() string
  • func (client *HttpClient) NRead() int
  • func (client *HttpClient) NWrite() int
  • func (client *HttpClient) Release()
• type Pool
  • func New(conf *conf.Conf, maxconn int64, target []string, retry int) *Pool
  • func (pool *Pool) Close()
  • func (pool *Pool) Get(meta task.Meta, ctx context.Context) *Conn
  • func (pool *Pool) GetHttp(meta task.Meta, ctx context.Context) (*HttpClient, error)
  • func (pool *Pool) Put(c *Conn)

Constants

const (
	CONN_ERR = "conn err"
	CONN_ADD = "conn add"
	CONN_GET = "conn get"
	CONN_PUT = "conn put"
	CONN_END = "conn end"
)

const CONN = "conn"

const HTTP = "http"

const POOL = "pool"

Variables

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

Types

type Any

type Any = interface{}

type Conn

type Conn struct {
	net.Conn
	// 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

	DoCount   int
	GetCount  int
	PostCount int
	ErrCount  int

	Logger func(...Any)
	// contains filtered or unexported fields
}

func (*HttpClient) Do

func (client *HttpClient) Do(meta task.Meta, req *http.Request) (*http.Response, error)

func (*HttpClient) Get

func (client *HttpClient) Get(meta task.Meta, url string) (*http.Response, error)

func (*HttpClient) Info

func (client *HttpClient) Info() string

func (*HttpClient) NRead

func (client *HttpClient) NRead() int

func (*HttpClient) NWrite

func (client *HttpClient) NWrite() int

func (*HttpClient) Release

func (client *HttpClient) Release()

type Pool

type Pool struct {
	Logger func(...Any)

	sync.Pool
	// contains filtered or unexported fields
}

func New

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

func (*Pool) Close

func (pool *Pool) Close()

func (*Pool) Get

func (pool *Pool) Get(meta task.Meta, ctx context.Context) *Conn

func (*Pool) GetHttp

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

func (*Pool) Put

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