part

Documentation

Index

• Variables
• func Cookies_List_2_Map(Cookies []*http.Cookie) (o map[string]string)
• func Cookies_String_2_Map(Cookies string) (o map[string]string)
• func IsCancel(e error) bool
• func IsTimeout(e error) bool
• func Map_2_Cookies_String(Cookies map[string]string) (o string)
• func ToForm(m map[string]string) (postStr string, contentType string)
• type CookieJson
  • func (t *CookieJson) FromCookie(cookie *http.Cookie)
  • func (t *CookieJson) FromJson(cookie_in_json []byte) error
  • func (t *CookieJson) ToCookie() (http.Cookie, error)
  • func (t *CookieJson) ToJson() ([]byte, error)
• type RawReqRes
  • func NewRawReqRes() *RawReqRes
  • func (t RawReqRes) Read(p []byte) (n int, err error)
  • func (t RawReqRes) ReqClose() error
  • func (t RawReqRes) ReqCloseWithError(e error) error
  • func (t RawReqRes) ReqWrite(p []byte) (n int, err error)
  • func (t RawReqRes) ResClose() error
  • func (t RawReqRes) ResCloseWithError(e error) error
  • func (t RawReqRes) ResRead(p []byte) (n int, err error)
  • func (t RawReqRes) Write(p []byte) (n int, err error)
• type Req
  • func New() *Req
  • func (t *Req) Cancel()
  • func (t *Req) Close()
  • func (t *Req) IsLive() bool
  • func (t *Req) Reqf(val Rval) error
  • func (t *Req) Wait() (err error)
• type Rval

Variables

var (
	ErrEmptyUrl         = errors.New("ErrEmptyUrl")
	ErrCantRetry        = errors.New("ErrCantRetry")
	ErrNewRequest       = errors.New("ErrNewRequest")
	ErrClientDo         = errors.New("ErrClientDo")
	ErrResponFileCreate = errors.New("ErrResponFileCreate")
	ErrWriteRes         = errors.New("ErrWriteRes")
	ErrReadRes          = errors.New("ErrReadRes")
	ErrPostStrOrRawPipe = errors.New("ErrPostStrOrRawPipe")
)

Functions

func Cookies_List_2_Map

func Cookies_List_2_Map(Cookies []*http.Cookie) (o map[string]string)

func Cookies_String_2_Map

func Cookies_String_2_Map(Cookies string) (o map[string]string)

func IsCancel

func IsCancel(e error) bool

func IsTimeout

func IsTimeout(e error) bool

func Map_2_Cookies_String

func Map_2_Cookies_String(Cookies map[string]string) (o string)

func ToForm

func ToForm(m map[string]string) (postStr string, contentType string)

Types

type CookieJson

type CookieJson struct {
	Name  string `json:"Name"`
	Value string `json:"Value"`

	Path       string `json:"Path"`       // optional
	Domain     string `json:"Domain"`     // optional
	Expires    string `json:"Expires"`    // time.Time in RFC1123
	RawExpires string `json:"RawExpires"` // for reading cookies only

	// MaxAge=0 means no 'Max-Age' attribute specified.
	// MaxAge<0 means delete cookie now, equivalently 'Max-Age: 0'
	// MaxAge>0 means Max-Age attribute present and given in seconds
	MaxAge   int           `json:"MaxAge"`
	Secure   bool          `json:"Secure"`
	HttpOnly bool          `json:"HttpOnly"`
	SameSite http.SameSite `json:"SameSite"` // Go 1.11
	Raw      string        `json:"Raw"`
	Unparsed []string      `json:"Unparsed"` // Raw text of unparsed attribute-value pairs
}

func (*CookieJson) FromCookie

func (t *CookieJson) FromCookie(cookie *http.Cookie)

func (*CookieJson) FromJson

func (t *CookieJson) FromJson(cookie_in_json []byte) error

func (*CookieJson) ToCookie

func (t *CookieJson) ToCookie() (http.Cookie, error)

func (*CookieJson) ToJson

func (t *CookieJson) ToJson() ([]byte, error)

type RawReqRes

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

func NewRawReqRes

func NewRawReqRes() *RawReqRes

func (RawReqRes) Read

func (t RawReqRes) Read(p []byte) (n int, err error)

func (RawReqRes) ReqClose

func (t RawReqRes) ReqClose() error

func (RawReqRes) ReqCloseWithError

func (t RawReqRes) ReqCloseWithError(e error) error

func (RawReqRes) ReqWrite

func (t RawReqRes) ReqWrite(p []byte) (n int, err error)

func (RawReqRes) ResClose

func (t RawReqRes) ResClose() error

func (RawReqRes) ResCloseWithError

func (t RawReqRes) ResCloseWithError(e error) error

func (RawReqRes) ResRead

func (t RawReqRes) ResRead(p []byte) (n int, err error)

func (RawReqRes) Write

func (t RawReqRes) Write(p []byte) (n int, err error)

type Req

type Req struct {
	// 当Async为true时，必须在Wait()之后读取，否则有DATA RACE可能
	Respon []byte
	// 当Async为true时，必须在Wait()之后读取，否则有DATA RACE可能
	Response *http.Response
	UsedTime time.Duration
	// contains filtered or unexported fields
}

func New

func New() *Req

func (*Req) Cancel

func (t *Req) Cancel()

func (*Req) Close

func (t *Req) Close()

func (*Req) IsLive

func (t *Req) IsLive() bool

func (*Req) Reqf

func (t *Req) Reqf(val Rval) error

func (*Req) Wait

func (t *Req) Wait() (err error)

type Rval

type Rval struct {
	Method  string
	Url     string
	PostStr string
	Proxy   string
	Retry   int
	// Millisecond
	Timeout int
	// Millisecond
	SleepTime int
	// Millisecond
	WriteLoopTO      int
	JustResponseCode bool
	NoResponse       bool
	// 当Async为true时，Respon、Response必须在Wait()之后读取，否则有DATA RACE可能
	Async   bool
	Cookies []*http.Cookie
	Ctx     context.Context

	SaveToPath string
	// 为避免write阻塞导致panic，请使用此项目io包中的NewPipe()，或在ctx done时，自行关闭pipe writer reader
	SaveToPipe *pio.IOpipe

	RawPipe *RawReqRes

	Header map[string]string
}