withttp

package module

Go to main page

Versions in this module

v0

v0.9.0

Jul 3, 2025

Changes in this version

type Call

+ func (c *Call[T]) Query(k, v string) *Call[T]

type CallReqOptionFunc

+ func Query[T any](k, v string) CallReqOptionFunc[T]

v0.8.0

Jun 29, 2025

Changes in this version

+ func ContentTypeCodec(c string) (codec.Codec, error)

type Call

+ func (c *Call[T]) Assert(fn func(req Response) error) *Call[T]

+ func (c *Call[T]) BasicAuth(user, pass string) *Call[T]

+ func (c *Call[T]) Body(payload any) *Call[T]

+ func (c *Call[T]) BodyStream(rc io.ReadWriteCloser, bodySize int) *Call[T]

+ func (c *Call[T]) ContentLength(length int) *Call[T]

+ func (c *Call[T]) ContentType(ct string) *Call[T]

+ func (c *Call[T]) ExpectedStatusCodes(states ...int) *Call[T]

+ func (c *Call[T]) Header(key, value string, override bool) *Call[T]

+ func (c *Call[T]) HeaderFunc(fn func() (key, value string, override bool)) *Call[T]

+ func (c *Call[T]) IgnoreResponseBody() *Call[T]

+ func (c *Call[T]) Method(method string) *Call[T]

+ func (c *Call[T]) ParseCSV(ignoreLines int, parser csvparser.Parser[T], fn func(T) bool) *Call[T]

+ func (c *Call[T]) ParseJSON() *Call[T]

+ func (c *Call[T]) ParseJSONEachRow(fn func(T) bool) *Call[T]

+ func (c *Call[T]) ParseJSONEachRowChan(out chan<- T) *Call[T]

+ func (c *Call[T]) ParseStream(factory StreamFactory[T], fn func(T) bool) *Call[T]

+ func (c *Call[T]) ParseStreamChan(factory StreamFactory[T], ch chan<- T) *Call[T]

+ func (c *Call[T]) RawBody(payload []byte) *Call[T]

+ func (c *Call[T]) ReadBody() *Call[T]

+ func (c *Call[T]) RequestSniffed(fn func([]byte, error)) *Call[T]

+ func (c *Call[T]) RequestStreamBody(opt StreamCallReqOptionFunc[T]) *Call[T]

+ func (c *Call[T]) URI(raw string) *Call[T]

+ func (c *Call[T]) URL(raw string) *Call[T]

type CallReqOptionFunc

+ func BasicAuth[T any](user, pass string) CallReqOptionFunc[T]

+ func BodyStream[T any](rc io.ReadWriteCloser, bodySize int) CallReqOptionFunc[T]

+ func Body[T any](payload any) CallReqOptionFunc[T]

+ func HeaderFunc[T any](fn func() (string, string, bool)) CallReqOptionFunc[T]

+ func Method[T any](method string) CallReqOptionFunc[T]

+ func RawBody[T any](payload []byte) CallReqOptionFunc[T]

+ func RequestSniffer[T any](fn func([]byte, error)) CallReqOptionFunc[T]

+ func URI[T any](raw string) CallReqOptionFunc[T]

+ func URL[T any](raw string) CallReqOptionFunc[T]

type CallResOptionFunc

+ func Assertion[T any](fn func(res Response) error) CallResOptionFunc[T]

+ func CloseBody[T any]() CallResOptionFunc[T]

+ func ExpectedStatusCodes[T any](states ...int) CallResOptionFunc[T]

+ func IgnoredBody[T any]() CallResOptionFunc[T]

+ func ParseBodyRaw[T any]() CallResOptionFunc[T]

+ func ParseJSON[T any]() CallResOptionFunc[T]

+ func ParseStreamChan[T any](factory StreamFactory[T], out chan<- T) CallResOptionFunc[T]

+ func ParseStream[T any](factory StreamFactory[T], fn func(T) bool) CallResOptionFunc[T]

type FastHttpHttpClientAdapter

+ func Fasthttp() *FastHttpHttpClientAdapter

+ func FasthttpClient(cli *fasthttp.Client) *FastHttpHttpClientAdapter

type NativeHttpClientAdapter

+ func NetHttp() *NativeHttpClientAdapter

+ func NetHttpClient(cli *http.Client) *NativeHttpClientAdapter

type ReqOption

+ func BaseURL(raw string) ReqOption

type ResOption

+ func MockedRes(fn func(response Response)) ResOption

type StreamCallReqOptionFunc

+ func RequestStreamBody[T, U any](r rangeable[U]) StreamCallReqOptionFunc[T]

v0.7.3

Feb 15, 2023

v0.7.2

Feb 15, 2023

v0.7.1

Dec 23, 2022

v0.7.0

Oct 14, 2022

Changes in this version

type Call

+ func (c *Call[T]) Log(w io.Writer)

+ func (c *Call[T]) WithLogger(l logger) *Call[T]

+ type Client interface

+ Do func(ctx context.Context, req Request) (Response, error)

+ Request func() (Request, error)

type Header

+ Header func(k string) (string, bool)

+ RangeHeaders func(func(string, string))

type Request

+ Method func() string

v0.6.0

Oct 6, 2022

Changes in this version

+ type CSVStream struct

+ func (s *CSVStream[T]) Data() T

+ func (s *CSVStream[T]) Err() error

+ func (s *CSVStream[T]) Next(ctx context.Context) bool

type Call

+ func (c *Call[T]) WithParseCSV(ignoreLines int, parser csvparser.Parser[T], fn func(T) bool) *Call[T]

type Stream

+ func NewCSVStream(r io.Reader, ignoreLines int, parser csvparser.Parser[T]) Stream[T]

type StreamFactory

+ func NewCSVStreamFactory(ignoreLines int, parser csvparser.Parser[T]) StreamFactory[T]

v0.5.1

Sep 22, 2022

v0.5.0

Sep 7, 2022

Changes in this version

+ var ErrInsufficientParams = errors.New("insufficient params")

+ func B2S(data []byte) string

+ func CreateAuthorizationHeader(kind authHeaderKind, user, pass string) (string, error)

+ func S2B(s string) (bts []byte)

type Call

+ func (c *Call[T]) WithBasicAuth(user, pass string) *Call[T]

type CallReqOptionFunc

+ func WithBasicAuth(user, pass string) CallReqOptionFunc[T]

type FastHttpHttpClientAdapter

+ func WithFasthttp() *FastHttpHttpClientAdapter

+ func WithFasthttpClient(cli *fasthttp.Client) *FastHttpHttpClientAdapter

+ type Header interface

+ AddHeader func(k, v string)

+ GetHeader func(k string) (string, bool)

+ SetHeader func(k, v string)

type NativeHttpClientAdapter

+ func WithNetHttp() *NativeHttpClientAdapter

+ func WithNetHttpClient(cli *http.Client) *NativeHttpClientAdapter

v0.4.0

Sep 1, 2022

Changes in this version

type Call

+ ReqShouldSniff bool

+ ReqStreamSniffer func([]byte, error)

+ func (c *Call[T]) WithRequestSniffed(fn func([]byte, error)) *Call[T]

type CallReqOptionFunc

+ func WithRequestSniffer(fn func([]byte, error)) CallReqOptionFunc[T]

+ type Channel chan T

+ func (c Channel[T]) Range(fn func(int, T) bool)

+ func (c Channel[T]) Serialize() bool

+ type NewLineStream struct

+ func (s *NewLineStream) Data() []byte

+ func (s *NewLineStream) Err() error

+ func (s *NewLineStream) Next(_ context.Context) bool

+ type ProxyStream struct

+ func (s *ProxyStream) Data() []byte

+ func (s *ProxyStream) Err() error

+ func (s *ProxyStream) Next(_ context.Context) bool

type Slice

+ func (s Slice[T]) Serialize() bool

type Stream

+ func NewNewLineStream(r io.Reader) Stream[[]byte]

+ func NewProxyStream(r io.Reader, bufferSize int) Stream[[]byte]

type StreamFactory

+ func NewNewLineStreamFactory() StreamFactory[[]byte]

+ func NewProxyStreamFactory(bufferSize int) StreamFactory[[]byte]

+ type StreamFromReader struct

+ func NewStreamFromReader(r io.Reader, sf StreamFactory[[]byte]) StreamFromReader

+ func (r StreamFromReader) Range(fn func(int, []byte) bool)

+ func (r StreamFromReader) Serialize() bool

v0.3.0

Aug 31, 2022

Changes in this version

+ func BytesEquals(a, b []byte) bool

+ func EncodeStream(ctx context.Context, r rangeable[T], req Request, encoder codec.Encoder) (err error)

type Call

+ ReqIsStream bool

+ ReqStreamWriter func(ctx context.Context, c *Call[T], res Request, wg *sync.WaitGroup) error

+ func (c *Call[T]) WithIgnoreResponseBody() *Call[T]

+ func (c *Call[T]) WithParseJSONEachRow(fn func(T) bool) *Call[T]

+ func (c *Call[T]) WithParseJSONEachRowChan(out chan<- T) *Call[T]

+ func (c *Call[T]) WithParseStream(factory StreamFactory[T], fn func(T) bool) *Call[T]

+ func (c *Call[T]) WithParseStreamChan(factory StreamFactory[T], ch chan<- T) *Call[T]

+ func (c *Call[T]) WithRequestStreamBody(opt StreamCallReqOptionFunc[T]) *Call[T]

+ type CallReqOption interface

+ Configure func(c *Call[T], r Request) error

type CallResOptionFunc

+ func WithParseJSON() CallResOptionFunc[T]

+ func WithParseStream(factory StreamFactory[T], fn func(T) bool) CallResOptionFunc[T]

+ func WithParseStreamChan(factory StreamFactory[T], out chan<- T) CallResOptionFunc[T]

type ContentType

+ var ContentTypeJSONEachRow ContentType = "application/jsoneachrow"

+ type Slice []T

+ func (s Slice[T]) Range(fn func(int, T) bool)

+ type StreamCallReqOption interface

+ type StreamCallReqOptionFunc func(c *Call[T], req Request) error

+ func WithRequestStreamBody(r rangeable[U]) StreamCallReqOptionFunc[T]

+ func (s StreamCallReqOptionFunc[T]) Configure(c *Call[T], req Request) error

v0.2.0

Aug 30, 2022

Changes in this version

+ var ContentTypeJSON = "application/json"

+ var ErrUnknownContentType = errors.New("unknown content type")

+ func BtsIsset(bts []byte) bool

+ func EncodeBody(payload any, contentType ContentType) (bts []byte, err error)

+ func StrIsset(s string) bool

+ type CalReqOption interface

+ Configure func(c *Call[T], r Request) error

type Call

+ ReqContentType ContentType

+ func (c *Call[T]) CallEndpoint(ctx context.Context, e *Endpoint) (err error)

+ func (c *Call[T]) WithBody(payload any) *Call[T]

+ func (c *Call[T]) WithBodyStream(rc io.ReadCloser, bodySize int) *Call[T]

+ func (c *Call[T]) WithContentLength(length int) *Call[T]

+ func (c *Call[T]) WithContentType(ct ContentType) *Call[T]

+ func (c *Call[T]) WithParseJSON() *Call[T]

+ type CallReqOptionFunc func(c *Call[T], res Request) error

+ func WithBody(payload any) CallReqOptionFunc[T]

+ func WithBodyStream(rc io.ReadCloser, bodySize int) CallReqOptionFunc[T]

+ func WithContentType(ct ContentType) CallReqOptionFunc[T]

+ func WithHeader(k, v string, override bool) CallReqOptionFunc[T]

+ func WithHeaderFunc(fn func() (string, string, bool)) CallReqOptionFunc[T]

+ func WithMethod(method string) CallReqOptionFunc[T]

+ func (f CallReqOptionFunc[T]) Configure(c *Call[T], req Request) error

type CallResOptionFunc

+ func WithParseBodyRaw() CallResOptionFunc[T]

+ type ContentType string

+ func (c ContentType) Codec() (codec.Codec, error)

+ func (c ContentType) IsJSON() bool

+ func (c ContentType) String() string

type ReqOption

+ func WithBaseURL(raw string) ReqOption

type Request

+ Body func() []byte

+ BodyStream func() io.ReadCloser

+ SetBodyStream func(rc io.ReadCloser, bodySize int)

type ResOption

+ func WithMockedRes(fn func(response Response)) ResOption

v0.1.0

Aug 29, 2022

Changes in this version

+ var ErrAssertion = errors.New("assertion was unmet")

+ var ErrUnexpectedStatusCode = errors.Wrap(ErrAssertion, "unexpected status code")

+ func ConfigureHeader(req Request, key, value string, override bool) error

+ func ReadJSON(rc io.ReadCloser) (res T, err error)

+ func ReadStream(rc io.ReadCloser, factory StreamFactory[T], fn func(T) bool) (err error)

+ func ReadStreamChan(rc io.ReadCloser, factory StreamFactory[T], out chan<- T) (err error)

+ type Call struct

+ BodyParsed T

+ BodyRaw []byte

+ Req Request

+ ReqBodyRaw []byte

+ Res Response

+ func NewCall(client client) *Call[T]

+ func (c *Call[T]) Call(ctx context.Context, e *Endpoint) (err error)

+ func (c *Call[T]) Request(opts ...ReqOption) *Call[T]

+ func (c *Call[T]) Response(opts ...ResOption) *Call[T]

+ func (c *Call[T]) WithAssert(fn func(req Response) error) *Call[T]

+ func (c *Call[T]) WithExpectedStatusCodes(states ...int) *Call[T]

+ func (c *Call[T]) WithHeader(key, value string, override bool) *Call[T]

+ func (c *Call[T]) WithHeaderFunc(fn func() (key, value string, override bool)) *Call[T]

+ func (c *Call[T]) WithIgnoreBody() *Call[T]

+ func (c *Call[T]) WithJSON() *Call[T]

+ func (c *Call[T]) WithJSONEachRow(fn func(T) bool) *Call[T]

+ func (c *Call[T]) WithJSONEachRowChan(out chan<- T) *Call[T]

+ func (c *Call[T]) WithMethod(method string) *Call[T]

+ func (c *Call[T]) WithRawBody(payload []byte) *Call[T]

+ func (c *Call[T]) WithReadBody() *Call[T]

+ func (c *Call[T]) WithStream(factory StreamFactory[T], fn func(T) bool) *Call[T]

+ func (c *Call[T]) WithStreamChan(factory StreamFactory[T], ch chan<- T) *Call[T]

+ func (c *Call[T]) WithURI(raw string) *Call[T]

+ func (c *Call[T]) WithURL(raw string) *Call[T]

+ type CallResOption interface

+ Parse func(c *Call[T], r Response) error

+ type CallResOptionFunc func(c *Call[T], res Response) error

+ func WithAssertion(fn func(res Response) error) CallResOptionFunc[T]

+ func WithCloseBody() CallResOptionFunc[T]

+ func WithExpectedStatusCodes(states ...int) CallResOptionFunc[T]

+ func WithIgnoredBody() CallResOptionFunc[T]

+ func WithJSON() CallResOptionFunc[T]

+ func WithRawBody() CallResOptionFunc[T]

+ func WithStream(factory StreamFactory[T], fn func(T) bool) CallResOptionFunc[T]

+ func WithStreamChan(factory StreamFactory[T], out chan<- T) CallResOptionFunc[T]

+ func (f CallResOptionFunc[T]) Parse(c *Call[T], res Response) error

+ type Endpoint struct

+ func NewEndpoint(name string) *Endpoint

+ func (e *Endpoint) Request(opts ...ReqOption) *Endpoint

+ func (e *Endpoint) Response(opts ...ResOption) *Endpoint

+ type FastHttpHttpClientAdapter struct

+ func NewDefaultFastHttpHttpClientAdapter() *FastHttpHttpClientAdapter

+ func NewFastHttpHttpClientAdapter(cli *fasthttp.Client) *FastHttpHttpClientAdapter

+ func (a *FastHttpHttpClientAdapter) Do(_ context.Context, req Request) (Response, error)

+ func (a *FastHttpHttpClientAdapter) Request() (Request, error)

+ type JSONEachRowStream struct

+ func (s *JSONEachRowStream[T]) Data() T

+ func (s *JSONEachRowStream[T]) Err() error

+ func (s *JSONEachRowStream[T]) Next(_ context.Context) bool

+ type MockEndpoint struct

+ type MockHttpClientAdapter struct

+ func NewMockHttpClientAdapter() *MockHttpClientAdapter

+ func (a *MockHttpClientAdapter) Do(ctx context.Context, req Request) (Response, error)

+ func (a *MockHttpClientAdapter) Request() (Request, error)

+ type NativeHttpClientAdapter struct

+ func NewDefaultNativeHttpClientAdapter() *NativeHttpClientAdapter

+ func NewNativeHttpClientAdapter(cli *http.Client) *NativeHttpClientAdapter

+ func (a *NativeHttpClientAdapter) Do(ctx context.Context, req Request) (Response, error)

+ func (a *NativeHttpClientAdapter) Request() (Request, error)

+ type ReqOption interface

+ Configure func(r Request) error

+ func WithURI(raw string) ReqOption

+ func WithURL(raw string) ReqOption

+ type ReqOptionFunc func(req Request) error

+ func (f ReqOptionFunc) Configure(req Request) error

+ type Request interface

+ AddHeader func(k, v string)

+ SetBody func(rc io.ReadCloser)

+ SetHeader func(k, v string)

+ SetMethod func(string)

+ SetURL func(*url.URL)

+ URL func() *url.URL

+ type ResOption interface

+ Parse func(r Response) error

+ func WithResMock(fn func(response Response)) ResOption

+ type ResOptionFunc func(res Response) error

+ func (f ResOptionFunc) Parse(res Response) error

+ type Response interface

+ Body func() io.ReadCloser

+ SetBody func(rc io.ReadCloser)

+ SetStatus func(status int)

+ Status func() int

+ StatusText func() string

+ type Stream interface

+ Data func() T

+ Err func() error

+ Next func(ctx context.Context) bool

+ func NewJSONEachRowStream(r io.Reader) Stream[T]

+ type StreamFactory interface

+ Get func(r io.Reader) Stream[T]

+ func NewJSONEachRowStreamFactory() StreamFactory[T]

+ type StreamFactoryFunc func(reader io.Reader) Stream[T]

+ func (f StreamFactoryFunc[T]) Get(r io.Reader) Stream[T]

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL