dataflow

package
v0.0.13-0...-246b94f Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 25, 2020 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// DefaultClient The default http client, which has a connection pool
	DefaultClient = http.Client{}
	// DefaultBenchClient is the default http client used by the benchmark,
	// which has a connection pool
	DefaultBenchClient = http.Client{
		Transport: &http.Transport{
			MaxIdleConnsPerHost: 10000,
		},
	}
)

Functions

func Register 

func Register(name string, filter NewFilter)

func ToBodyType 

func ToBodyType(s string) color.BodyType

ToBodyType Returns the http body type, which mainly affects color highlighting

Types

type Bencher 

type Bencher interface {
	Concurrent(c int) Bencher
	Number(n int) Bencher
	Rate(rate int) Bencher
	Durations(d time.Duration) Bencher
	Loop(func(c *Context) error) Bencher
	GetReport(r *bench.Report) Bencher
	Do() error
}

type Context 

type Context struct {
	Code  int //http code
	Error error

	*DataFlow
}

Context struct

type Curl 

type Curl interface {
	LongOption() Curl
	GenAndSend() Curl
	SetOutput(w io.Writer) Curl
	Do() error
}

type DataFlow 

type DataFlow struct {
	Req
	// contains filtered or unexported fields
}

DataFlow is the core data structure, including the encoder and decoder of http data

func DELETE 

func DELETE(url string) *DataFlow

DELETE send HTTP DELETE method

func GET 

func GET(url string) *DataFlow

GET send HTTP GET method 

func HEAD(url string) *DataFlow

HEAD send HTTP HEAD method

func OPTIONS 

func OPTIONS(url string) *DataFlow

OPTIONS send HTTP OPTIONS method

func PATCH 

func PATCH(url string) *DataFlow

PATCH send HTTP PATCH method

func POST 

func POST(url string) *DataFlow

POST send HTTP POST method

func PUT 

func PUT(url string) *DataFlow

PUT send HTTP PUT method

func (*DataFlow) BindBody 

func (df *DataFlow) BindBody(obj interface{}) *DataFlow

BindBody parse the variables in http body to obj. obj must be a pointer variable

func (*DataFlow) BindHeader 

func (df *DataFlow) BindHeader(obj interface{}) *DataFlow

BindHeader parse http header to obj variable. obj must be a pointer variable Support string/int/float/slice ... types

func (*DataFlow) BindJSON 

func (df *DataFlow) BindJSON(obj interface{}) *DataFlow

BindJSON parse the json string in http body to obj. obj must be a pointer variable

func (*DataFlow) BindXML 

func (df *DataFlow) BindXML(obj interface{}) *DataFlow

BindXML parse the xml string in http body to obj. obj must be a pointer variable

func (*DataFlow) BindYAML 

func (df *DataFlow) BindYAML(obj interface{}) *DataFlow

BindYAML parse the yaml string in http body to obj. obj must be a pointer variable

func (*DataFlow) Callback 

func (df *DataFlow) Callback(cb func(*Context) error) *DataFlow

Callback parse the http body into obj according to the condition (json or string)

func (*DataFlow) Code 

func (df *DataFlow) Code(httpCode *int) *DataFlow

Code parse the http code into the variable httpCode

func (*DataFlow) DELETE 

func (df *DataFlow) DELETE(url string) *DataFlow

DELETE send HTTP DELETE method

func (*DataFlow) Debug 

func (df *DataFlow) Debug(d ...interface{}) *DataFlow

Debug start debug mode

func (*DataFlow) Do 

func (df *DataFlow) Do() (err error)

Do send function

func (*DataFlow) E 

func (df *DataFlow) E() *export

E filter function, use this function to turn on the filter function

func (*DataFlow) Export 

func (df *DataFlow) Export() *export

Export filter function, use this function to turn on the filter function

func (*DataFlow) F 

func (df *DataFlow) F() *filter

F filter function, use this function to turn on the filter function

func (*DataFlow) Filter 

func (df *DataFlow) Filter() *filter

Filter filter function, use this function to turn on the filter function

func (*DataFlow) GET 

func (df *DataFlow) GET(url string) *DataFlow

GET send HTTP GET method

func (*DataFlow) GetHost 

func (df *DataFlow) GetHost() (string, error)

GetHost return value->host or host:port

func (*DataFlow) HEAD 

func (df *DataFlow) HEAD(url string) *DataFlow

HEAD send HTTP HEAD method

func (*DataFlow) IsDebug 

func (df *DataFlow) IsDebug() bool

func (*DataFlow) OPTIONS 

func (df *DataFlow) OPTIONS(url string) *DataFlow

OPTIONS send HTTP OPTIONS method

func (*DataFlow) PATCH 

func (df *DataFlow) PATCH(url string) *DataFlow

PATCH send HTTP PATCH method

func (*DataFlow) POST 

func (df *DataFlow) POST(url string) *DataFlow

POST send HTTP POST method

func (*DataFlow) PUT 

func (df *DataFlow) PUT(url string) *DataFlow

PUT send HTTP PUT method

func (*DataFlow) SetBody 

func (df *DataFlow) SetBody(obj interface{}) *DataFlow

SetBody set the data to the http body, Support string/bytes/io.Reader

func (*DataFlow) SetCookies 

func (df *DataFlow) SetCookies(c ...*http.Cookie) *DataFlow

SetCookies set cookies

func (*DataFlow) SetForm 

func (df *DataFlow) SetForm(obj ...interface{}) *DataFlow

SetForm send form data to the http body, Support struct/map/array/slice

func (*DataFlow) SetGout 

func (df *DataFlow) SetGout(out *Gout)

func (*DataFlow) SetHeader 

func (df *DataFlow) SetHeader(obj ...interface{}) *DataFlow

SetHeader send http header, Support struct/map/slice types

func (*DataFlow) SetHost 

func (df *DataFlow) SetHost(host string) *DataFlow

SetHost set host

func (*DataFlow) SetJSON 

func (df *DataFlow) SetJSON(obj interface{}) *DataFlow

SetJSON send json to the http body, Support raw json(string, []byte)/struct/map types

func (*DataFlow) SetMethod 

func (df *DataFlow) SetMethod(method string) *DataFlow

SetMethod set method

func (*DataFlow) SetProxy 

func (df *DataFlow) SetProxy(proxyURL string) *DataFlow

SetProxy 函数会修改Transport，请像对待全局变量一样对待SetProxy

func (*DataFlow) SetQuery 

func (df *DataFlow) SetQuery(obj ...interface{}) *DataFlow

SetQuery send URL query string, Support string/[]byte/struct/map/slice types

func (*DataFlow) SetRequest 

func (df *DataFlow) SetRequest(req *http.Request) *DataFlow

func (*DataFlow) SetSOCKS4 

func (df *DataFlow) SetSOCKS4(addr string) *DataFlow

func (*DataFlow) SetSOCKS5 

func (df *DataFlow) SetSOCKS5(addr string) *DataFlow

SetSOCKS5 函数会修改Transport,请像对待全局变量一样对待SetSOCKS5

func (*DataFlow) SetTimeout 

func (df *DataFlow) SetTimeout(d time.Duration) *DataFlow

SetTimeout set timeout, and WithContext are mutually exclusive functions

func (*DataFlow) SetURL 

func (df *DataFlow) SetURL(url string) *DataFlow

SetURL set url

func (*DataFlow) SetWWWForm 

func (df *DataFlow) SetWWWForm(obj ...interface{}) *DataFlow

SetWWWForm send x-www-form-urlencoded to the http body, Support struct/map/array/slice types

func (*DataFlow) SetXML 

func (df *DataFlow) SetXML(obj interface{}) *DataFlow

SetXML send xml to the http body

func (*DataFlow) SetYAML 

func (df *DataFlow) SetYAML(obj interface{}) *DataFlow

SetYAML send yaml to the http body, Support struct,map types

func (*DataFlow) UnixSocket 

func (df *DataFlow) UnixSocket(path string) *DataFlow

UnixSocket 函数会修改Transport, 请像对待全局变量一样对待UnixSocket

func (*DataFlow) WithContext 

func (df *DataFlow) WithContext(c context.Context) *DataFlow

WithContext set context, and SetTimeout are mutually exclusive functions

type DebugFunc 

type DebugFunc func(*DebugOption)

DebugFunc DebugOpt is a function that manipulates core data structures

func (DebugFunc) Apply 

func (f DebugFunc) Apply(o *DebugOption)

Apply is an interface for operating DebugOption

type DebugOpt 

type DebugOpt interface {
	Apply(*DebugOption)
}

DebugOpt is an interface for operating DebugOption

func NoColor 

func NoColor() DebugOpt

NoColor Turn off color highlight debug mode

func Trace 

func Trace() DebugOpt

type DebugOption 

type DebugOption struct {
	Write       io.Writer
	Debug       bool
	Color       bool
	Trace       bool
	ReqBodyType string
	RspBodyType string
	TraceInfo
}

DebugOption Debug mode core data structure

type Do 

type Do interface {
	Do(*http.Request) (*http.Response, error)
}

type Export 

type Export interface {
	Curl()
}

type Filter 

type Filter interface {
	Bench() Bencher
	Retry() Retry
}

type Gout 

type Gout struct {
	*http.Client
	DataFlow // TODO 优化
	// contains filtered or unexported fields
}

Gout is the data structure at the beginning of everything

func New 

func New(c ...*http.Client) *Gout

New function is mainly used when passing custom http client

type NewFilter 

type NewFilter interface {
	New(*DataFlow) interface{}
}

type Req 

type Req struct {
	Err error
	// contains filtered or unexported fields
}

Req controls core data structure of http request

func (*Req) Bind 

func (r *Req) Bind(req *http.Request, resp *http.Response) (err error)

func (*Req) Client 

func (r *Req) Client() *http.Client

func (*Req) Do 

func (r *Req) Do() (err error)

Do Send function

func (*Req) GetContext 

func (r *Req) GetContext() context.Context

func (*Req) Request 

func (r *Req) Request() (req *http.Request, err error)

Request Get the http.Request object

func (*Req) Reset 

func (r *Req) Reset()

Reset 重置 Req结构体 req 结构布局说明，以decode为例 body 可以支持text, json, yaml, xml，所以定义成接口形式 headerDecode只有一个可能，就定义为具体类型。这里他们的decode实现也不一样 有没有必要，归一化成一种??? TODO:

type Retry 

type Retry interface {
	Attempt(attempt int) Retry
	WaitTime(waitTime time.Duration) Retry
	MaxWaitTime(maxWaitTime time.Duration) Retry
	Func(func(c *Context) error) Retry
	Do() error
}

type TraceInfo 

type TraceInfo struct {
	DnsDuration         time.Duration
	ConnDuration        time.Duration
	TLSDuration         time.Duration
	RequestDuration     time.Duration
	WaitResponeDuration time.Duration
	ResponseDuration    time.Duration
	TotalDuration       time.Duration
	// contains filtered or unexported fields
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.