lowhttp

Apr 12, 2024

Changes in this version

+ const CloseAbnormalClosure

+ const CloseGoingAway

+ const CloseInternalServerErr

+ const CloseInvalidFramePayloadData

+ const CloseMandatoryExtension

+ const CloseMessageTooBig

+ const CloseNoStatusReceived

+ const CloseNormalClosure

+ const ClosePolicyViolation

+ const CloseProtocolError

+ const CloseServiceRestart

+ const CloseTLSHandshake

+ const CloseTryAgainLater

+ const CloseUnsupportedData

+ const DEFAULT_CLOSE_MESSAGE_FIRST_BYTE

+ func FormatCloseMessage(closeCode int, text string) []byte

+ func IsRespFast(raw any) (isHTTPResponse bool)

+ func ReplaceHTTPPacketCookies(packet []byte, m any) []byte

+ func ReplaceHTTPPacketFormEncoded(packet []byte, key, value string) []byte

+ func ReplaceHTTPPacketUploadFile(packet []byte, fieldName, fileName string, fileContent interface{}, ...) []byte

type LowhttpExecConfig

+ BodyStreamReaderHandler func(responseHeader []byte, closer io.ReadCloser)

type LowhttpOpt

+ func WithBodyStreamReaderHandler(t func([]byte, io.ReadCloser)) LowhttpOpt

type LowhttpResponse

+ BareResponse []byte

+ func (l *LowhttpResponse) GetBody() []byte

type QueryParamItem

+ ValueRaw string

Mar 1, 2024

Changes in this version

+ func ExtractURLStringFromHTTPRequest(req any, isHttps bool) (string, error)

+ func ReplaceAllHTTPPacketHeaders(packet []byte, headers map[string]string) []byte

+ func ReplaceAllHTTPPacketPostParamsWithoutEscape(packet []byte, values map[string]string) []byte

+ func ReplaceAllHTTPPacketQueryParamsWithoutEscape(packet []byte, values map[string]string) []byte

type Frame

+ func (f *Frame) GetData() []byte

+ func (f *Frame) GetFirstByte() byte

+ func (f *Frame) GetMask() bool

+ func (f *Frame) GetPayload() []byte

+ func (f *Frame) GetRaw() []byte

+ func (f *Frame) SetData(d []byte)

type LowhttpExecConfig

+ ConnectTimeout time.Duration

+ SNI string

type LowhttpOpt

+ func WithConnectTimeout(timeout time.Duration) LowhttpOpt

+ func WithConnectTimeoutFloat(i float64) LowhttpOpt

+ func WithProxyGetter(getter func() []string) LowhttpOpt

+ func WithSNI(sni string) LowhttpOpt

type QueryParams

+ func (q *QueryParams) Clear()

Jan 5, 2024

Changes in this version

+ func AppendAllHTTPPacketQueryParam(packet []byte, Params map[string][]string) []byte

+ func AppendHTTPPacketHeaderIfNotExist(packet []byte, headerKey string, headerValue any) []byte

+ func BasicResponse() []byte

+ func GetParamsFromBody(contentType string, body []byte) (params map[string]string, useRaw bool, err error)

+ func IGetHTTPInsHeader(headers http.Header, headerKey string) []string

+ func IGetHeader(packet interface{}, headerKey string) []string

+ func ReplaceHTTPPacketQueryParamRaw(packet []byte, rawQuery string) []byte

+ type LowHttpConnPool struct

+ func NewDefaultHttpConnPool() *LowHttpConnPool

type LowhttpExecConfig

+ DNSNoCache bool

type LowhttpOpt

+ func WithDNSNoCache(b bool) LowhttpOpt

Dec 1, 2023

Changes in this version

+ var H1 = "http/1.1"

+ var H2 = "h2"

+ func GetHTTPRequestMethod(packet []byte) string

+ func GetHTTPRequestPath(packet []byte) string

+ func GetHTTPRequestPathWithoutQuery(packet []byte) string

+ func GetUrlFromHTTPRequest(scheme string, packet []byte) string

+ func ServeHTTP2Connection(conn net.Conn, ...) error

type Authentication

+ func GetHttpAuth(authHeader string, opt *LowhttpExecConfig) Authentication

+ type CustomAuthClient struct

+ func (ca *CustomAuthClient) Authenticate(conn net.Conn, config *LowhttpExecConfig) ([]byte, error)

type LowhttpExecConfig

+ Password string

Nov 3, 2023

Changes in this version

+ func BuildLegacyProxyRequest(req []byte) ([]byte, error)

+ func ForceStringToUrl(i string) *url.URL

+ func GetDigestAuthorizationFromRequest(raw []byte, authorization, username, password string) (string, error)

+ func GetDigestAuthorizationFromRequestEx(method, url, body, authorization, username, password string, ...) (*DigestRequest, *DigestAuthorization, error)

+ func ReplaceHTTPPacketQueryParamWithoutEncoding(packet []byte, key, value string) []byte

+ func UrlToHTTPRequest(text string) ([]byte, error)

+ type Authentication interface

+ Authenticate func(conn net.Conn, config *LowhttpExecConfig) ([]byte, error)

+ func GetAuth(auth string, username string, password string) Authentication

+ type BasicAuthentication struct

+ Password string

+ Username string

+ func (ba *BasicAuthentication) Authenticate(conn net.Conn, config *LowhttpExecConfig) ([]byte, error)

+ type DigestAuthentication struct

+ Password string

+ Username string

+ func (da *DigestAuthentication) Authenticate(conn net.Conn, config *LowhttpExecConfig) ([]byte, error)

+ type DigestAuthorization struct

+ Algorithm string

+ Cnonce string

+ Nc int

+ Nonce string

+ Opaque string

+ Qop string

+ Realm string

+ Response string

+ URI string

+ Userhash bool

+ Username string

+ Username_ string

+ func (ah *DigestAuthorization) RefreshAuthorization(dr *DigestRequest) (*DigestAuthorization, error)

+ func (ah *DigestAuthorization) RefreshAuthorizationWithoutConce(dr *DigestRequest) (*DigestAuthorization, error)

+ func (ah *DigestAuthorization) String() string

+ type DigestRequest struct

+ Auth *DigestAuthorization

+ Body string

+ CertVal bool

+ Method string

+ Password string

+ URI string

+ Username string

+ Wa *wwwAuthenticate

+ func NewDigestRequest(username, password, method, uri, body string, useCompleteURL bool) *DigestRequest

+ func (dr *DigestRequest) UpdateRequest(username, password, method, uri, body string, useCompleteURL bool) *DigestRequest

+ func (dr *DigestRequest) UpdateRequestWithUsernameAndPassword(username, password string) *DigestRequest

type LowhttpExecConfig

+ DefaultBufferSize int

+ EnableMaxContentLength bool

+ EnableSystemProxyFromEnv bool

+ ForceLegacyProxy bool

+ MaxContentLength int

+ NativeHTTPRequestInstance *http.Request

+ OverrideEnableSystemProxyFromEnv bool

+ Passwrod string

+ ResponseBodyMirrorWriter io.Writer

+ Username string

type LowhttpOpt

+ func WithDefaultBufferSize(size int) LowhttpOpt

+ func WithEnableSystemProxyFromEnv(b bool) LowhttpOpt

+ func WithForceLegacyProxy(b bool) LowhttpOpt

+ func WithMaxContentLength(m int) LowhttpOpt

+ func WithNativeHTTPRequestInstance(req *http.Request) LowhttpOpt

+ func WithPassword(password string) LowhttpOpt

+ func WithResponseBodyMirrorWriter(w io.Writer) LowhttpOpt

+ func WithUsername(username string) LowhttpOpt

type LowhttpResponse

+ MultiResponseInstances []*http.Response

+ ResponseBodySize int64

+ TooLarge bool

+ TooLargeLimit int64

+ type NtlmAuthentication struct

+ Domain string

+ Password string

+ Username string

+ func (na *NtlmAuthentication) Authenticate(conn net.Conn, config *LowhttpExecConfig) ([]byte, error)

+ type QueryParamItem struct

+ Key string

+ NoAutoEncode bool

+ Raw string

+ Value string

+ func (item *QueryParamItem) Encode() string

+ type QueryParams struct

+ Items []*QueryParamItem

+ NoAutoEncode bool

+ func ExtractQueryFromRequestURI(i string) *QueryParams

+ func NewQueryParams(s string) *QueryParams

+ func ParseQueryParams(s string) *QueryParams

+ func (d *QueryParams) DisableAutoEncode(b bool) *QueryParams

+ func (q *QueryParams) Add(key, val string)

+ func (q *QueryParams) AppendRaw(raw string)

+ func (q *QueryParams) Del(key string)

+ func (q *QueryParams) Encode() string

+ func (q *QueryParams) Get(key string) string

+ func (q *QueryParams) GetAll(key string) []string

+ func (q *QueryParams) GetLast(key string) string

+ func (q *QueryParams) Have(key string) bool

+ func (q *QueryParams) Remove(key string)

+ func (q *QueryParams) Set(key, val string)

Sep 27, 2023

Changes in this version

+ var DefaultLowHttpConnPool = &lowHttpConnPool

+ func BasicRequest() []byte

+ func SetHTTPPacketUrl(packet []byte, rawURL string) []byte

type LowhttpExecConfig

+ ConnPool *lowHttpConnPool

+ WithConnPool bool

type LowhttpOpt

+ func ConnPool(p *lowHttpConnPool) LowhttpOpt

+ func WithConnPool(b bool) LowhttpOpt

Sep 7, 2023

Changes in this version

+ const DoubleCRLF

+ var ReadHTTPRequestFromBufioReader = utils.ReadHTTPRequestFromBufioReader

+ var ReadHTTPRequestFromBytes = utils.ReadHTTPRequestFromBytes

+ var ReadHTTPResponseFromBufioReader = utils.ReadHTTPResponseFromBufioReader

+ var ReadHTTPResponseFromBytes = utils.ReadHTTPResponseFromBytes

+ func FixHTTPRequest(raw []byte) []byte

+ func NewRequestPacketFromMethod(method string, u string, originRequest []byte, originRequestHttps bool, ...) []byte

+ func UrlToGetRequestPacketWithResponse(u string, originRequest, originResponse []byte, originRequestHttps bool, ...) []byte

type LowhttpResponse

+ MultiResponse bool

type RedirectFlow

+ RespRecord *LowhttpResponse

Aug 17, 2023

Changes in this version

+ func DeletePacketEncoding(raw []byte) []byte

Aug 7, 2023

Changes in this version

+ func AppendHTTPPacketFormEncoded(packet []byte, key, value string) []byte

+ func AppendHTTPPacketUploadFile(packet []byte, fieldName, fileName string, fileContent interface{}, ...) []byte

+ func DeleteHTTPPacketForm(packet []byte, key string) []byte

+ func GetHTTPPacketFirstLine(packet []byte) (string, string, string)

+ func IsHeader(headerLine, wantHeader string) bool

+ func IsResp(data any) bool

+ func ReplaceAllHTTPPacketPostParams(packet []byte, values map[string]string) []byte

+ func ReplaceAllHTTPPacketQueryParams(packet []byte, values map[string]string) []byte

+ func ReplaceHTTPPacketBasicAuth(packet []byte, username, password string) []byte

+ func ReplaceHTTPPacketHost(packet []byte, host string) []byte

+ func ReplaceHTTPPacketMethod(packet []byte, newMethod string) []byte

type LowhttpExecConfig

+ ResponseCallback func(response *LowhttpResponse)

+ VerifyCertificate bool

type LowhttpOpt

+ func WithPacketBytes(packet []byte) LowhttpOpt

+ func WithRequest(packet any) LowhttpOpt

+ func WithResponseCallback(h func(i *LowhttpResponse)) LowhttpOpt

+ func WithTimeoutFloat(i float64) LowhttpOpt

+ func WithVerifyCertificate(b bool) LowhttpOpt

type LowhttpResponse

+ func HTTP(opts ...LowhttpOpt) (*LowhttpResponse, error)

+ func HTTPWithoutRedirect(opts ...LowhttpOpt) (*LowhttpResponse, error)

+ type RedirectFlow struct

+ IsHttps bool

+ Request []byte

+ Response []byte

type WebsocketClient

+ func (c *WebsocketClient) WriteClose() error

Jul 20, 2023

Changes in this version

+ func AppendHTTPPacketCookie(packet []byte, key string, value any) []byte

+ func AppendHTTPPacketHeader(packet []byte, headerKey string, headerValue any) []byte

+ func AppendHTTPPacketPath(packet []byte, p string) []byte

+ func AppendHTTPPacketPostParam(packet []byte, key, value string) []byte

+ func AppendHTTPPacketQueryParam(packet []byte, key, value string) []byte

+ func ConnectVulinboxAgent(addr string, handler func(request []byte), onPing ...func()) (func(), error)

+ func ConnectVulinboxAgentEx(addr string, handler func(request []byte), onPing func(), onClose func()) (func(), error)

+ func ConnectVulinboxAgentRaw(addr string, handler func([]byte), onClose func()) (func(), error)

+ func DebugEchoServer() (string, int)

+ func DebugEchoServerContext(ctx context.Context) (string, int)

+ func DeleteHTTPPacketCookie(packet []byte, key string) []byte

+ func DeleteHTTPPacketHeader(packet []byte, headerKey string) []byte

+ func DeleteHTTPPacketPostParam(packet []byte, key string) []byte

+ func DeleteHTTPPacketQueryParam(packet []byte, key string) []byte

+ func FixRequestHostAndPort(r *http.Request)

+ func GetAllHTTPRequestPostParams(packet []byte) map[string]string

+ func GetAllHTTPRequestQueryParams(packet []byte) map[string]string

+ func GetHTTPPacketBody(packet []byte) []byte

+ func GetHTTPPacketContentType(packet []byte) string

+ func GetHTTPPacketCookie(packet []byte, key string) string

+ func GetHTTPPacketCookieFirst(packet []byte, key string) string

+ func GetHTTPPacketCookieValues(packet []byte, key string) []string

+ func GetHTTPPacketCookies(packet []byte) map[string]string

+ func GetHTTPPacketCookiesFull(packet []byte) map[string][]string

+ func GetHTTPPacketHeader(packet []byte, key string) string

+ func GetHTTPPacketHeaders(packet []byte) map[string]string

+ func GetHTTPPacketHeadersFull(packet []byte) map[string][]string

+ func GetHTTPPacketJSONPath(packet []byte, key string) any

+ func GetHTTPPacketJSONValue(packet []byte, key string) any

+ func GetHTTPRequestPostParam(packet []byte, key string) string

+ func GetHTTPRequestPostParamFull(packet []byte, key string) []string

+ func GetHTTPRequestQueryParam(packet []byte, key string) string

+ func GetHTTPRequestQueryParamFull(packet []byte, key string) []string

+ func GetStatusCodeFromResponse(packet []byte) int

+ func IsChunkedHeaderLine(line string) bool

+ func ReplaceHTTPPacketBodyFast(packet []byte, body []byte) []byte

+ func ReplaceHTTPPacketCookie(packet []byte, key string, value any) []byte

+ func ReplaceHTTPPacketFirstLine(packet []byte, firstLine string) []byte

+ func ReplaceHTTPPacketHeader(packet []byte, headerKey string, headerValue any) []byte

+ func ReplaceHTTPPacketPath(packet []byte, p string) []byte

+ func ReplaceHTTPPacketPostParam(packet []byte, key, value string) []byte

+ func ReplaceHTTPPacketQueryParam(packet []byte, key, value string) []byte

+ func SendHTTPRequestWithRawPacketWithRedirectWithGmTLS(https bool, host string, port int, r []byte, timeout time.Duration, ...) ([]byte, [][]byte, error)

+ func SplitHTTPPacket(raw []byte, ...) (string, []byte)

+ func SplitHTTPPacketFast(raw any) (string, []byte)

+ func UrlToRequestPacket(method string, u string, originRequest []byte, originRequestHttps bool, ...) []byte

+ type CurlCommand struct

+ func GetCurlCommand(isHttps bool, req []byte) (*CurlCommand, error)

+ func (c *CurlCommand) String() string

type LowhttpExecConfig

+ DefaultDnsServerType string

+ FromPlugin string

+ RuntimeId string

type LowhttpOpt

+ func WithFromPlugin(fromPlugin string) LowhttpOpt

+ func WithRuntimeId(runtimeId string) LowhttpOpt

type LowhttpResponse

+ FromPlugin string

+ RuntimeId string

Jun 20, 2023

Changes in this version

+ const CookieTimeFormat

+ func CookieSafeQuoteString(i string) string

+ func CookieSafeUnquoteString(i string) string

+ func GetTLSConn(isGM bool, enableHttp2 bool, host string, rawConn net.Conn, ...) (net.Conn, error)

type LowhttpExecConfig

+ GmTLS bool

type LowhttpOpt

+ func WithGmTLS(b bool) LowhttpOpt

May 11, 2023

Changes in this version

+ const BinaryMessage

+ const CRLF

+ const CloseMessage

+ const ContinueMessage

+ const DEFAULT_TEXT_MESSAGE_FISRT_BYTE

+ const EIGHT_BYTE_BIT

+ const FINALBIT

+ const FRAME_TYPE_BIT

+ const MASKBIT

+ const PingMessage

+ const PongMessage

+ const RESET_MESSAGE_TYPE_BIT

+ const RSV1BIT

+ const SEVEN_BIT_SIZE

+ const TWO_BYTE_BIT

+ const TWO_BYTE_SIZE

+ const TextMessage

+ var CookiejarPool sync.Map

+ var GetProxyConn = utils.GetProxyConn

+ var GetProxyConnWithContext = utils.GetProxyConnWithContext

+ var TAIL = []byte

+ func AddConnectionClosed(raw []byte) []byte

+ func AddOrUpgradeCookie(raw []byte, value string) ([]byte, error)

+ func AppendHeaderToHTTPPacket(raw []byte, line string) []byte

+ func CharsetToUTF8(bodyRaw []byte, mimeType string, originCharset string) ([]byte, string)

+ func ComputeWebsocketAcceptKey(websocketKey string) string

+ func ContentEncodingDecode(contentEncoding string, bodyRaw []byte) (finalResult []byte, fixed bool)

+ func ConvertHTTPRequestToFuzzTag(i []byte) []byte

+ func CookiesToString(cookies []*http.Cookie) string

+ func CopyRequest(r *http.Request) *http.Request

+ func CurlToHTTPRequest(i string) ([]byte, error)

+ func ExtractBodyFromHTTPResponseRaw(res []byte) ([]byte, error)

+ func ExtractBoundaryFromBody(raw interface{}) string

+ func ExtractCookieJarFromHTTPResponse(rawResponse []byte) []*http.Cookie

+ func ExtractStatusCodeFromResponse(raw []byte) int

+ func ExtractURLFromHTTPRequest(r *http.Request, https bool) (*url.URL, error)

+ func ExtractURLFromHTTPRequestRaw(req []byte, isHttps bool) (*url.URL, error)

+ func ExtractWebsocketURLFromHTTPRequest(req *http.Request) (bool, string)

+ func FetchBannerFromHostPort(baseCtx context.Context, host string, port interface{}, size int64, ...) []byte

+ func FixHTTPPacketCRLF(raw []byte, noFixLength bool) []byte

+ func FixHTTPRequestOut(raw []byte) []byte

+ func FixHTTPResponse(raw []byte) (rsp []byte, body []byte, _ error)

+ func FixMultipartBody(i []byte) (string, []byte)

+ func GetCookiejar(session interface{}) http.CookieJar

+ func GetHostsFilePath() string

+ func GetOverrideContentType(bodyPrescan []byte, contentType string) (overrideContentType string, originCharset string)

+ func GetRedirectFromHTTPResponse(rawResponse []byte, jsRedirect bool) string

+ func GetSystemEtcHosts() map[string]string

+ func GetSystemHostByName(domain string) (string, bool)

+ func HTTP2RequestToHTTP(framer *http2.Framer) ([]byte, error)

+ func HTTP2ResponseToHTTP(frame *http2.Frame) ([]byte, error)

+ func HTTPPacketForceChunked(raw []byte) []byte

+ func HTTPRequestToHTTP2(schema string, host string, conn net.Conn, raw []byte, noFixContentLength bool) ([]byte, error)

+ func IsMultipartFormDataRequest(req []byte) bool

+ func IsPermessageDeflate(headers http.Header) bool

+ func IsPrint(s string) bool

+ func MergeCookies(cookies ...*http.Cookie) string

+ func MergeUrlFromHTTPRequest(rawRequest []byte, target string, isHttps bool) string

+ func ParseBytesToHTTPResponse(res []byte) (*http.Response, error)

+ func ParseBytesToHttpRequest(raw []byte) (*http.Request, error)

+ func ParseCookie(i string) []*http.Cookie

+ func ParseStringToHTTPResponse(res string) (*http.Response, error)

+ func ParseStringToHttpRequest(raw string) (*http.Request, error)

+ func ParseUrlToHttpRequestRaw(method string, i interface{}) (bool, []byte, error)

+ func ReadHTTPPacketBodySize(raw []byte) (cl int, chunked bool)

+ func ReadHTTPPacketSafe(r *bufio.Reader) ([]byte, error)

+ func ReadHTTPRequest(reader *bufio.Reader) (*http.Request, error)

+ func ReadHTTPRequestEx(reader *bufio.Reader, loadbody bool) (*http.Request, error)

+ func ReadHTTPResponseEx(reader *bufio.Reader, loadbody bool) (*http.Response, []byte, error)

+ func RegisterSaveHTTPFlowHandler(h saveHTTPFlowHandler)

+ func RemoveCEHeaders(headerBytes []byte) []byte

+ func RemoveZeroContentLengthHTTPHeader(raw []byte) []byte

+ func ReplaceHTTPPacketBody(raw []byte, body []byte, chunk bool) []byte

+ func ReplaceHTTPPacketBodyEx(raw []byte, body []byte, chunk bool, forceCL bool) []byte

+ func ReplaceMIMEType(headerBytes []byte, mimeType string) []byte

+ func SaveResponse(r *LowhttpResponse)

+ func SendHTTPRequestRaw(https bool, host string, port int, r *http.Request, timeout time.Duration) ([]byte, error)

+ func SendHTTPRequestRawQuick(https bool, r *http.Request) ([]byte, error)

+ func SendHTTPRequestRawQuickWithTimeout(https bool, r *http.Request, timeout time.Duration) ([]byte, error)

+ func SendHTTPRequestWithRawPacket(forceHttps bool, host string, port int, r []byte, timeout time.Duration, ...) ([]byte, error)

+ func SendHTTPRequestWithRawPacketEx(forceHttps bool, host string, port int, r []byte, timeout time.Duration, ...) ([]byte, bool, error)

+ func SendHTTPRequestWithRawPacketWithRedirect(https bool, host string, port int, r []byte, timeout time.Duration, ...) ([]byte, [][]byte, error)

+ func SendHTTPRequestWithRawPacketWithRedirectEx(https bool, host string, port int, r []byte, timeout time.Duration, ...) ([]byte, [][]byte, error)

+ func SendHTTPRequestWithRawPacketWithRedirectFullEx(https bool, host string, port int, r []byte, timeout time.Duration, ...) ([]byte, [][]byte, error)

+ func SendHTTPRequestWithRawPacketWithRedirectWithContextFullEx(https bool, host string, port int, r []byte, timeout time.Duration, ...) ([]byte, [][]byte, error)

+ func SendHTTPRequestWithRawPacketWithRedirectWithStateFullEx(https bool, host string, port int, r []byte, timeout time.Duration, ...) ([]byte, [][]byte, bool, error)

+ func SendPacketQuick(https bool, packet []byte, timeout float64, proxy ...string) ([]byte, [][]byte, error)

+ func ShouldSendReqContentLength(method string, contentLength int64) bool

+ func SplitHTTPHeader(i string) (string, string)

+ func SplitHTTPHeadersAndBodyFromPacket(raw []byte, hook ...func(line string)) (string, []byte)

+ func SplitHTTPHeadersAndBodyFromPacketEx(raw []byte, mf func(method string, requestUri string, proto string) error, ...) (string, []byte)

+ func SplitHTTPHeadersAndBodyFromPacketEx2(raw []byte, mf func(method string, requestUri string, proto string) error, ...) (string, []byte)

+ func SplitKV(i string) (string, string)

+ func ToLower(s string) (lower string, ok bool)

+ func ToUnquoteFuzzTag(i []byte) string

+ func TrimLeftHTTPPacket(raw []byte) []byte

+ func TrimRightHTTPPacket(raw []byte) []byte

+ func TrimSpaceHTTPPacket(raw []byte) []byte

+ func UrlToGetRequestPacket(u string, originRequest []byte, originRequestHttps bool, ...) []byte

+ func WebsocketFrameToData(frame *Frame) (data []byte)

+ type Frame struct

+ func DataToWebsocketControlFrame(messageType int, data []byte, mask bool) (frame *Frame, err error)

+ func DataToWebsocketFrame(data []byte, firstByte byte, mask bool) (frame *Frame, err error)

+ func (f *Frame) Bytes() ([]byte, []byte)

+ func (f *Frame) GetMaskingKey() []byte

+ func (f *Frame) IsControl() bool

+ func (f *Frame) RawPayloadData() []byte

+ func (f *Frame) SetMaskingKey(r []byte)

+ func (f *Frame) Show()

+ func (f *Frame) Type() int

+ type FrameReader struct

+ func NewFrameReader(r io.Reader, isDeflate bool) *FrameReader

+ func NewFrameReaderFromBufio(r *bufio.Reader, isDeflate bool) *FrameReader

+ func (fr *FrameReader) ReadFrame() (frame *Frame, err error)

+ type FrameWriter struct

+ func NewFrameWriter(w io.Writer, isDeflate bool) *FrameWriter

+ func NewFrameWriterFromBufio(w *bufio.Writer, isDeflate bool) *FrameWriter

+ func (fw *FrameWriter) Flush() error

+ func (fw *FrameWriter) WriteBinary(data []byte, mask bool, headerBytes ...byte) (err error)

+ func (fw *FrameWriter) WriteFrame(frame *Frame, messageTypes ...int) (err error)

+ func (fw *FrameWriter) WritePong(data []byte, mask bool) (err error)

+ func (fw *FrameWriter) WriteRaw(raw []byte) (err error)

+ func (fw *FrameWriter) WriteText(data []byte, mask bool, headerBytes ...byte) (err error)

+ type LowhttpExecConfig struct

+ BeforeDoRequest func([]byte) []byte

+ Ctx context.Context

+ DNSServers []string

+ EtcHosts map[string]string

+ Host string

+ Http2 bool

+ Https bool

+ JsRedirect bool

+ NoFixContentLength bool

+ Packet []byte

+ Port int

+ Proxy []string

+ RedirectHandler func(bool, []byte, []byte) bool

+ RedirectTimes int

+ RequestSource string

+ RetryInStatusCode []int

+ RetryMaxWaitTime time.Duration

+ RetryNotInStatusCode []int

+ RetryTimes int

+ RetryWaitTime time.Duration

+ SaveHTTPFlow bool

+ Session interface{}

+ Timeout time.Duration

+ func NewLowhttpOption() *LowhttpExecConfig

+ type LowhttpOpt func(o *LowhttpExecConfig)

+ func WithBeforeDoRequest(h func([]byte) []byte) LowhttpOpt

+ func WithContext(ctx context.Context) LowhttpOpt

+ func WithDNSServers(servers []string) LowhttpOpt

+ func WithETCHosts(hosts map[string]string) LowhttpOpt

+ func WithHost(host string) LowhttpOpt

+ func WithHttp2(Http2 bool) LowhttpOpt

+ func WithHttps(https bool) LowhttpOpt

+ func WithJsRedirect(jsRedirect bool) LowhttpOpt

+ func WithNoFixContentLength(noFixContentLength bool) LowhttpOpt

+ func WithPacket(packet []byte) LowhttpOpt

+ func WithPort(port int) LowhttpOpt

+ func WithProxy(proxy ...string) LowhttpOpt

+ func WithRedirectHandler(redirectHandler func(bool, []byte, []byte) bool) LowhttpOpt

+ func WithRedirectTimes(redirectTimes int) LowhttpOpt

+ func WithRetryInStatusCode(sc []int) LowhttpOpt

+ func WithRetryMaxWaitTime(retryMaxWaitTime time.Duration) LowhttpOpt

+ func WithRetryNotInStatusCode(sc []int) LowhttpOpt

+ func WithRetryTimes(retryTimes int) LowhttpOpt

+ func WithRetryWaitTime(retryWaitTime time.Duration) LowhttpOpt

+ func WithSaveHTTPFlow(b bool) LowhttpOpt

+ func WithSession(session interface{}) LowhttpOpt

+ func WithSource(s string) LowhttpOpt

+ func WithTimeout(timeout time.Duration) LowhttpOpt

+ type LowhttpResponse struct

+ Http2 bool

+ Https bool

+ PortIsOpen bool

+ Proxy string

+ RawPacket []byte

+ RawRequest []byte

+ RedirectRawPackets [][]byte

+ RemoteAddr string

+ Source string

+ TraceInfo *LowhttpTraceInfo

+ Url string

+ func SendHTTPRequestWithRawPacketWithRedirectWithStateWithOptFullEx(opts ...LowhttpOpt) (*LowhttpResponse, error)

+ func SendHttpRequestWithRawPacketWithOptEx(opts ...LowhttpOpt) (*LowhttpResponse, error)

+ func (l *LowhttpResponse) GetDurationFloat() float64

+ type LowhttpTraceInfo struct

+ AvailableDNSServers []string

+ ConnTime time.Duration

+ DNSTime time.Duration

+ ServerTime time.Duration

+ TotalTime time.Duration

+ func (l *LowhttpTraceInfo) GetServerDurationMS() int64

+ type WebHookServer struct

+ func NewWebHookServer(port int, cb func(data interface{})) *WebHookServer

+ func NewWebHookServerEx(port int, cb func(data interface{})) *WebHookServer

+ func (w *WebHookServer) Addr() string

+ func (w *WebHookServer) Shutdown()

+ func (w *WebHookServer) Start()

+ type WebsocketClient struct

+ Context context.Context

+ FromServerHandler func([]byte)

+ FromServerOnce *sync.Once

+ Request []byte

+ Response []byte

+ func NewWebsocketClient(packet []byte, opt ...WebsocketClientOpt) (*WebsocketClient, error)

+ func (c *WebsocketClient) StartFromServer()

+ func (c *WebsocketClient) Stop()

+ func (c *WebsocketClient) Wait()

+ func (c *WebsocketClient) Write(r []byte) error

+ func (c *WebsocketClient) WriteBinary(r []byte) error

+ func (c *WebsocketClient) WritePong(r []byte) error

+ func (c *WebsocketClient) WriteText(r []byte) error

+ type WebsocketClientConfig struct

+ Context context.Context

+ FromServerHandler func([]byte)

+ Host string

+ Port int

+ Proxy string

+ TLS bool

+ TotalTimeout time.Duration

+ type WebsocketClientOpt func(config *WebsocketClientConfig)

+ func WithWebsocketFromServerHandler(f func([]byte)) WebsocketClientOpt

+ func WithWebsocketHost(t string) WebsocketClientOpt

+ func WithWebsocketPort(t int) WebsocketClientOpt

+ func WithWebsocketProxy(t string) WebsocketClientOpt

+ func WithWebsocketTLS(t bool) WebsocketClientOpt

+ func WithWebsocketTotalTimeout(t float64) WebsocketClientOpt

+ func WithWebsocketWithContext(ctx context.Context) WebsocketClientOpt