dataflow

Documentation

Index

• func NewMultipartHelper() contract.MultipartDfInterface
• type Dataflow
  • func NewDataflow(client contract.ClientInterface, middlewareHandle contract.RequestMiddleware, ...) *Dataflow
  • func (d *Dataflow) Any(data contract.BodyEncoder) contract.RequestDataflowInterface
  • func (d *Dataflow) Body(body io.Reader) contract.RequestDataflowInterface
  • func (d *Dataflow) Err() error
  • func (d *Dataflow) Header(key string, values ...string) contract.RequestDataflowInterface
  • func (d *Dataflow) Json(jsonAny interface{}) contract.RequestDataflowInterface
  • func (d *Dataflow) Method(method string) contract.RequestDataflowInterface
  • func (d *Dataflow) Multipart(multipartDf func(multipart contract.MultipartDfInterface)) contract.RequestDataflowInterface
  • func (d *Dataflow) Query(key string, values ...string) contract.RequestDataflowInterface
  • func (d *Dataflow) Request() (response *http.Response, err error)
  • func (d *Dataflow) RequestResHelper() (response contract.ResponseHelper, err error)
  • func (d *Dataflow) Result(result interface{}) (err error)
  • func (d *Dataflow) Uri(uri string) contract.RequestDataflowInterface
  • func (d *Dataflow) Url(requestUrl string) contract.RequestDataflowInterface
  • func (d *Dataflow) WithContext(ctx context.Context) contract.RequestDataflowInterface
  • func (d *Dataflow) Xml(xmlAny interface{}) contract.RequestDataflowInterface
• type MultipartDf
  • func (m *MultipartDf) Boundary(b string) contract.MultipartDfInterface
  • func (m *MultipartDf) Close() error
  • func (m *MultipartDf) Err() error
  • func (m *MultipartDf) Field(fieldName string, reader io.Reader) contract.MultipartDfInterface
  • func (m *MultipartDf) FieldValue(fieldName string, value string) contract.MultipartDfInterface
  • func (m *MultipartDf) FileByPath(fieldName string, filePath string) contract.MultipartDfInterface
  • func (m *MultipartDf) FileMem(fieldName string, fileName string, reader io.Reader) contract.MultipartDfInterface
  • func (m *MultipartDf) GetBoundary() string
  • func (m *MultipartDf) GetContentType() string
  • func (m *MultipartDf) GetReader() io.Reader
  • func (m *MultipartDf) Part(header textproto.MIMEHeader, reader io.Reader) contract.MultipartDfInterface
• type Option
• type Response
  • func (r *Response) GetBody() io.Reader
  • func (r *Response) GetBodyBytes() ([]byte, error)
  • func (r *Response) GetBodyJsonAsMap() (map[string]interface{}, error)
  • func (r *Response) GetHeader(key string) string
  • func (r *Response) GetStatusCode() int

Functions

func NewMultipartHelper

func NewMultipartHelper() contract.MultipartDfInterface

Types

type Dataflow

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

func NewDataflow

func NewDataflow(client contract.ClientInterface, middlewareHandle contract.RequestMiddleware, option *Option) *Dataflow

func (*Dataflow) Any

func (d *Dataflow) Any(data contract.BodyEncoder) contract.RequestDataflowInterface

func (*Dataflow) Body

func (d *Dataflow) Body(body io.Reader) contract.RequestDataflowInterface

func (*Dataflow) Err

func (d *Dataflow) Err() error

func (*Dataflow) Header

func (d *Dataflow) Header(key string, values ...string) contract.RequestDataflowInterface

Header 设置请求头, 对一个 Key 多次调用该方法, values 始终会被后面调用的覆盖

func (*Dataflow) Json

func (d *Dataflow) Json(jsonAny interface{}) contract.RequestDataflowInterface

func (*Dataflow) Method

func (d *Dataflow) Method(method string) contract.RequestDataflowInterface

func (*Dataflow) Multipart

func (d *Dataflow) Multipart(multipartDf func(multipart contract.MultipartDfInterface)) contract.RequestDataflowInterface

func (*Dataflow) Query

func (d *Dataflow) Query(key string, values ...string) contract.RequestDataflowInterface

func (*Dataflow) Request

func (d *Dataflow) Request() (response *http.Response, err error)

func (*Dataflow) RequestResHelper

func (d *Dataflow) RequestResHelper() (response contract.ResponseHelper, err error)

func (*Dataflow) Result

func (d *Dataflow) Result(result interface{}) (err error)

Result 实现了 Json 解码

func (*Dataflow) Uri

func (d *Dataflow) Uri(uri string) contract.RequestDataflowInterface

Uri 请注意 Url 与 Uri 方法是冲突的, Uri方法将 Uri 拼接在 BaseUrl 之后

func (*Dataflow) Url

func (d *Dataflow) Url(requestUrl string) contract.RequestDataflowInterface

func (*Dataflow) WithContext

func (d *Dataflow) WithContext(ctx context.Context) contract.RequestDataflowInterface

func (*Dataflow) Xml

func (d *Dataflow) Xml(xmlAny interface{}) contract.RequestDataflowInterface

type MultipartDf

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

func (*MultipartDf) Boundary

func (m *MultipartDf) Boundary(b string) contract.MultipartDfInterface

func (*MultipartDf) Close

func (m *MultipartDf) Close() error

func (*MultipartDf) Err

func (m *MultipartDf) Err() error

func (*MultipartDf) Field

func (m *MultipartDf) Field(fieldName string, reader io.Reader) contract.MultipartDfInterface

func (*MultipartDf) FieldValue

func (m *MultipartDf) FieldValue(fieldName string, value string) contract.MultipartDfInterface

func (*MultipartDf) FileByPath

func (m *MultipartDf) FileByPath(fieldName string, filePath string) contract.MultipartDfInterface

func (*MultipartDf) FileMem

func (m *MultipartDf) FileMem(fieldName string, fileName string, reader io.Reader) contract.MultipartDfInterface

func (*MultipartDf) GetBoundary

func (m *MultipartDf) GetBoundary() string

func (*MultipartDf) GetContentType

func (m *MultipartDf) GetContentType() string

func (*MultipartDf) GetReader

func (m *MultipartDf) GetReader() io.Reader

func (*MultipartDf) Part

func (m *MultipartDf) Part(header textproto.MIMEHeader, reader io.Reader) contract.MultipartDfInterface

type Option

type Option struct {
	BaseUrl string
}

type Response

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

func (*Response) GetBody

func (r *Response) GetBody() io.Reader

func (*Response) GetBodyBytes

func (r *Response) GetBodyBytes() ([]byte, error)

func (*Response) GetBodyJsonAsMap

func (r *Response) GetBodyJsonAsMap() (map[string]interface{}, error)

func (*Response) GetHeader

func (r *Response) GetHeader(key string) string

func (*Response) GetStatusCode

func (r *Response) GetStatusCode() int