http

Documentation

Index

• Constants
• Variables
• func CopyHttpHeader(src, dst http.Header)
• func GetToken(r *http.Request) string
• func NewNoCloseRequest(req *http.Request, s []byte)
• func NewNoCloseStrRequest(req *http.Request, s string)
• func RespErr(w http.ResponseWriter, err error)
• func RespErrMsg(w http.ResponseWriter, msg string)
• func RespErrRep(w http.ResponseWriter, rep *errcode.ErrRep)
• func RespErrcode(w http.ResponseWriter, code errcode.ErrCode)
• func Response[T any](w http.ResponseWriter, code errcode.ErrCode, msg string, data T)
• func Stream(w http.ResponseWriter)
• func StreamWriter(w http.ResponseWriter, writer func(w io.Writer) bool)
• type Body
• type HandlerFuncs
  • func (hs *HandlerFuncs) Add(handler http.HandlerFunc)
  • func (hs HandlerFuncs) HandlerFunc() http.HandlerFunc
  • func (hs HandlerFuncs) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Handlers
  • func (hs Handlers) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Header
  • func NewHeader() *Header
  • func (h *Header) Add(k, v string) *Header
  • func (h Header) Clone() Header
  • func (h *Header) IntoHttpHeader(header http.Header)
  • func (h *Header) Set(k, v string) *Header
• type HttpResponse
• type IHttpResponse
• type NoCloseBody
  • func NewNoCloseBody(s []byte) *NoCloseBody
  • func (r *NoCloseBody) Close() error
  • func (r *NoCloseBody) Len() int
  • func (r *NoCloseBody) Read(b []byte) (n int, err error)
  • func (r *NoCloseBody) Size() int64
• type NoCloseStrBody
  • func NewNoCloseStrBody(s string) *NoCloseStrBody
  • func (r *NoCloseStrBody) Close() error
  • func (r *NoCloseStrBody) Len() int
  • func (r *NoCloseStrBody) Read(b []byte) (n int, err error)
  • func (r *NoCloseStrBody) Size() int64
• type ReceiveData
  • func NewReceivesData(code errcode.ErrCode, msg string, data any) *ReceiveData
  • func (r *ReceiveData) Response(w http.ResponseWriter, httpcode int)
  • func (r *ReceiveData) UnmarshalData(v any) error
• type RequestAt
  • func NewRequestAt() *RequestAt
  • func NewRequestAtByTime(t time.Time) *RequestAt
  • func (r *RequestAt) String() string
• type ResAnyData
• type ResData
  • func NewResData[T any](code errcode.ErrCode, msg string, data T) *ResData[T]
  • func (res *ResData[T]) Response(w http.ResponseWriter, httpcode int)
• type ResponseRecorder
  • func NewRecorder(header http.Header) *ResponseRecorder
  • func (rw *ResponseRecorder) Flush()
  • func (rw *ResponseRecorder) Header() http.Header
  • func (rw *ResponseRecorder) Reset()
  • func (rw *ResponseRecorder) Result() *http.Response
  • func (rw *ResponseRecorder) Write(buf []byte) (int, error)
  • func (rw *ResponseRecorder) WriteHeader(code int)
  • func (rw *ResponseRecorder) WriteString(str string) (int, error)

Constants

const (
	// ContentJavascriptHeaderValue header value for JSONP & Javascript data.
	ContentJavascriptHeaderValue = "text/javascript"
	// ContentHtmlHeaderValue is the  string of text/html response header's content type value.
	ContentHtmlHeaderValue = "text/html"
	ContentCssHeaderValue  = "text/css"
	// ContentTextHeaderValue header value for Text data.
	ContentTextHeaderValue = "text/plain"
	// ContentXmlHeaderValue header value for XML data.
	ContentXmlHeaderValue = "text/xml"
	// ContentMarkdownHeaderValue custom key/content type, the real is the text/html.
	ContentMarkdownHeaderValue = "text/markdown"
	// ContentYamlTextHeaderValue header value for YAML plain text.
	ContentYamlTextHeaderValue = "text/yaml"

	// ContentFormMultipartHeaderValue header value for post multipart form data.
	ContentFormMultipartHeaderValue = "multipart/form-data"

	// ContentBinaryHeaderValue header value for binary data.
	ContentBinaryHeaderValue = "application/octet-stream"
	// ContentWebassemblyHeaderValue header value for web assembly files.
	ContentWebassemblyHeaderValue = "application/wasm"
	// ContentJsonHeaderValue header value for JSON data.
	ContentJsonHeaderValue = "application/json"
	// ContentJsonProblemHeaderValue header value for JSON API problem error.
	// Read more at: https://tools.ietf.org/html/rfc7807
	ContentJsonProblemHeaderValue = "application/problem+json"
	// ContentXmlProblemHeaderValue header value for XML API problem error.
	// Read more at: https://tools.ietf.org/html/rfc7807
	ContentXmlProblemHeaderValue           = "application/problem+xml"
	ContentJavascriptUnreadableHeaderValue = "application/javascript"
	// ContentXmlUnreadableHeaderValue obsolete header value for XML.
	ContentXmlUnreadableHeaderValue = "application/xml"
	// ContentYamlHeaderValue header value for YAML data.
	ContentYamlHeaderValue = "application/x-yaml"
	// ContentProtobufHeaderValue header value for Protobuf messages data.
	ContentProtobufHeaderValue = "application/x-protobuf"
	// ContentMsgPackHeaderValue header value for MsgPack data.
	ContentMsgPackHeaderValue = "application/msgpack"
	// ContentMsgPack2HeaderValue alternative header value for MsgPack data.
	ContentMsgPack2HeaderValue = "application/x-msgpack"
	// ContentFormHeaderValue header value for post form data.
	ContentFormHeaderValue = "application/x-www-form-urlencoded"

	// ContentGrpcHeaderValue Content-Type header value for gRPC.
	ContentGrpcHeaderValue      = "application/grpc"
	ContentGrpcWebHeaderValue   = "application/grpc-web"
	ContentPdfHeaderValue       = "application/pdf"
	ContentJsonUtf8HeaderValue  = "application/json;charset=utf-8"
	ContentFormParamHeaderValue = "application/x-www-form-urlencoded;param=value"

	ContentImagePngHeaderValue  = "image/png"
	ContentImageJpegHeaderValue = "image/jpeg"
	ContentImageGifHeaderValue  = "image/gif"
	ContentImageBmpHeaderValue  = "image/bmp"
	ContentImageWebpHeaderValue = "image/webp"
	ContentImageAvifHeaderValue = "image/avif"
	//ContentImageHeifHeaderValue = "image/heif"
	ContentImageSvgHeaderValue              = "image/svg+xml"
	ContentImageTiffHeaderValue             = "image/tiff"
	ContentImageXIconHeaderValue            = "image/x-icon"
	ContentImageVndMicrosoftIconHeaderValue = "image/vnd.microsoft.icon"

	ContentCharsetUtf8HeaderValue = "charset=UTF-8"
)

const (
	HeaderDeviceInfo = "Device-AuthInfo"
	HeaderLocation   = "Location"
	HeaderArea       = "Area"
)

const (
	HeaderUserAgent                   = "User-Agent"
	HeaderXForwardedFor               = "X-Forwarded-For"
	HeaderXAccelBuffering             = "X-Accel-Buffering"
	HeaderAuth                        = "HeaderAuth"
	HeaderContentType                 = "Content-Type"
	HeaderTrace                       = "Tracing"
	HeaderTraceID                     = "Tracing-ID"
	HeaderTraceBin                    = "Tracing-Bin"
	HeaderAuthorization               = "Authorization"
	HeaderCookie                      = "Cookie"
	HeaderCookieValueToken            = "token"
	HeaderCookieValueDel              = "del"
	HeaderContentDisposition          = "Content-Disposition"
	HeaderContentEncoding             = "Content-Encoding"
	HeaderReferer                     = "Referer"
	HeaderAccept                      = "Accept"
	HeaderAcceptLanguage              = "Accept-Language"
	HeaderAcceptEncoding              = "Accept-Encoding"
	HeaderCacheControl                = "Cache-Control"
	HeaderSetCookie                   = "Set-Cookie"
	HeaderTrailer                     = "Trailer"
	HeaderTransferEncoding            = "Transfer-Encoding"
	HeaderInternal                    = "Internal"
	HeaderTE                          = "TE"
	HeaderLastModified                = "Last-Modified"
	HeaderContentLength               = "Content-Length"
	HeaderAccessControlRequestMethod  = "Access-Control-Request-Method"
	HeaderAccessControlRequestHeaders = "Access-Control-Request-Headers"
	HeaderOrigin                      = "Origin"
	HeaderConnection                  = "Connection"
	HeaderRange                       = "Range"
	HeaderContentRange                = "Content-Range"
	HeaderAcceptRanges                = "Accept-Ranges"
)

const (
	HeaderGrpcTraceBin = "grpc-trace-bin"
	HeaderGrpcInternal = "grpc-internal"
)

const DefaultRemoteAddr = "1.2.3.4"

DefaultRemoteAddr is the default remote address to return in RemoteAddr if an explicit DefaultRemoteAddr isn't set on ResponseRecorder.

Variables

var ResponseOk = []byte(`{"code":0,"message":"OK"}`)

var ResponseSysErr = []byte(`{"code":10000,"message":"系统错误"}`)

Functions

func CopyHttpHeader

func CopyHttpHeader(src, dst http.Header)

func GetToken

func GetToken(r *http.Request) string

func NewNoCloseRequest

func NewNoCloseRequest(req *http.Request, s []byte)

func NewNoCloseStrRequest

func NewNoCloseStrRequest(req *http.Request, s string)

func RespErr

func RespErr(w http.ResponseWriter, err error)

func RespErrMsg

func RespErrMsg(w http.ResponseWriter, msg string)

func RespErrRep

func RespErrRep(w http.ResponseWriter, rep *errcode.ErrRep)

func RespErrcode

func RespErrcode(w http.ResponseWriter, code errcode.ErrCode)

func Response

func Response[T any](w http.ResponseWriter, code errcode.ErrCode, msg string, data T)

func Stream

func Stream(w http.ResponseWriter)

func StreamWriter

func StreamWriter(w http.ResponseWriter, writer func(w io.Writer) bool)

Types

type Body

type Body map[string]interface{}

type HandlerFuncs

type HandlerFuncs []http.HandlerFunc

func (*HandlerFuncs) Add

func (hs *HandlerFuncs) Add(handler http.HandlerFunc)

func (HandlerFuncs) HandlerFunc

func (hs HandlerFuncs) HandlerFunc() http.HandlerFunc

func (HandlerFuncs) ServeHTTP

func (hs HandlerFuncs) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Handlers

type Handlers []http.Handler

func (Handlers) ServeHTTP

func (hs Handlers) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Header

type Header []string

func NewHeader

func NewHeader() *Header

func (*Header) Add

func (h *Header) Add(k, v string) *Header

func (Header) Clone

func (h Header) Clone() Header

func (*Header) IntoHttpHeader

func (h *Header) IntoHttpHeader(header http.Header)

func (*Header) Set

func (h *Header) Set(k, v string) *Header

type HttpResponse

type HttpResponse struct {
	Header     map[string]string `json:"header"`
	Body       []byte            `json:"body"`
	StatusCode int               `json:"status"`
}

type IHttpResponse

type IHttpResponse interface {
	Header() http.Header
	Body() []byte
	StatusCode() int
}

type NoCloseBody

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

func NewNoCloseBody

func NewNoCloseBody(s []byte) *NoCloseBody

适用于轮询

func (*NoCloseBody) Close

func (r *NoCloseBody) Close() error

func (*NoCloseBody) Len

func (r *NoCloseBody) Len() int

func (*NoCloseBody) Read

func (r *NoCloseBody) Read(b []byte) (n int, err error)

func (*NoCloseBody) Size

func (r *NoCloseBody) Size() int64

type NoCloseStrBody

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

func NewNoCloseStrBody

func NewNoCloseStrBody(s string) *NoCloseStrBody

适用于轮询

func (*NoCloseStrBody) Close

func (r *NoCloseStrBody) Close() error

func (*NoCloseStrBody) Len

func (r *NoCloseStrBody) Len() int

func (*NoCloseStrBody) Read

func (r *NoCloseStrBody) Read(b []byte) (n int, err error)

func (*NoCloseStrBody) Size

func (r *NoCloseStrBody) Size() int64

type ReceiveData

type ReceiveData struct {
	Code    errcode.ErrCode `json:"code"`
	Message string          `json:"message,omitempty"`
	//验证码
	Details json.RawMessage `json:"details,omitempty"`
}

func NewReceivesData

func NewReceivesData(code errcode.ErrCode, msg string, data any) *ReceiveData

func (*ReceiveData) Response

func (r *ReceiveData) Response(w http.ResponseWriter, httpcode int)

func (*ReceiveData) UnmarshalData

func (r *ReceiveData) UnmarshalData(v any) error

type RequestAt

type RequestAt struct {
	Time       time.Time
	TimeStamp  int64
	TimeString string
}

func NewRequestAt

func NewRequestAt() *RequestAt

func NewRequestAtByTime

func NewRequestAtByTime(t time.Time) *RequestAt

func (*RequestAt) String

func (r *RequestAt) String() string

type ResAnyData

type ResAnyData = ResData[any]

type ResData

type ResData[T any] struct {
	Code    errcode.ErrCode `json:"code"`
	Message string          `json:"message,omitempty"`
	//验证码
	Details T `json:"details,omitempty"`
}

func NewResData

func NewResData[T any](code errcode.ErrCode, msg string, data T) *ResData[T]

func (*ResData[T]) Response

func (res *ResData[T]) Response(w http.ResponseWriter, httpcode int)

type ResponseRecorder

type ResponseRecorder struct {
	// Code is the HTTP response code set by WriteHeader.
	//
	// Note that if a Handler never calls WriteHeader or Write,
	// this might end up being 0, rather than the implicit
	// http.StatusOK. To get the implicit value, use the Result
	// method.
	Code int

	HeaderMap http.Header

	// Body is the buffer to which the Handler's Write calls are sent.
	// If nil, the Writes are silently discarded.
	Body *bytes.Buffer

	// Flushed is whether the Handler called Flush.
	Flushed bool
	// contains filtered or unexported fields
}

ResponseRecorder is an implementation of http.ResponseWriter that records its mutations for later inspection in tests.

func NewRecorder

func NewRecorder(header http.Header) *ResponseRecorder

NewRecorder returns an initialized ResponseRecorder.

func (*ResponseRecorder) Flush

func (rw *ResponseRecorder) Flush()

Flush implements http.Flusher. To test whether Flush was called, see rw.Flushed.

func (*ResponseRecorder) Header

func (rw *ResponseRecorder) Header() http.Header

Header implements http.ResponseWriter. It returns the response headers to mutate within a handler. To test the headers that were written after a handler completes, use the Result method and see the returned Response value's Header.

func (*ResponseRecorder) Reset

func (rw *ResponseRecorder) Reset()

func (*ResponseRecorder) Result

func (rw *ResponseRecorder) Result() *http.Response

Result returns the response generated by the handler.

The returned Response will have at least its StatusCode, Header, Body, and optionally Trailer populated. More fields may be populated in the future, so callers should not DeepEqual the result in tests.

The Response.Header is a snapshot of the headers at the time of the first write call, or at the time of this call, if the handler never did a write.

The Response.Body is guaranteed to be non-nil and Body.Read call is guaranteed to not return any error other than io.EOF.

Result must only be called after the handler has finished running.

func (*ResponseRecorder) Write

func (rw *ResponseRecorder) Write(buf []byte) (int, error)

Write implements http.ResponseWriter. The data in buf is written to rw.Body, if not nil.

func (*ResponseRecorder) WriteHeader

func (rw *ResponseRecorder) WriteHeader(code int)

WriteHeader implements http.ResponseWriter.

func (*ResponseRecorder) WriteString

func (rw *ResponseRecorder) WriteString(str string) (int, error)

WriteString implements io.StringWriter. The data in str is written to rw.Body, if not nil.