client

May 22, 2023

Changes in this version

+ const HTTP2PingTimeout

+ const HTTP2ReadIdleTimeout

+ const HTTP2WriteByteTimeout

+ const MaxIdleConnections

type Client

+ func (c Client) Tracer() otelTrace.Tracer

May 15, 2023

Changes in this version

type Client

+ func (c Client) WithTelemetry(tracerProvider otelTrace.TracerProvider, ...) Client

Jan 27, 2023

Changes in this version

+ type ReqDefinitionError struct

+ func (v ReqDefinitionError) SendOrErr(_ context.Context) error

+ func (v ReqDefinitionError) Unwrap() error

type Sendable

+ func NewReqDefinitionError(err error) Sendable

Jan 26, 2023

Changes in this version

+ const ContentTypeApplicationJSON

+ const ContentTypeApplicationJSONRegexp

Dec 7, 2022

Changes in this version

+ type ParallelAPIRequests []Sendable

+ func Parallel(requests ...Sendable) ParallelAPIRequests

+ func (v ParallelAPIRequests) SendOrErr(ctx context.Context, sender Sender) error

Nov 16, 2022

Changes in this version

+ const RetryAttemptContextKey

+ func ContextRetryAttempt(ctx context.Context) (int, bool)

+ type ContextKey string

Nov 2, 2022

Changes in this version

+ type DurationSeconds time.Duration

+ func (d *DurationSeconds) UnmarshalJSON(data []byte) (err error)

+ func (d DurationSeconds) MarshalJSON() ([]byte, error)

+ func (d DurationSeconds) String() string

Oct 26, 2022

Changes in this version

+ const ContentTypeApplicationJsonRegexp

Oct 10, 2022

Changes in this version

type HTTPRequest

+ WithBody func(body any) HTTPRequest

+ WithContentType func(contentType string) HTTPRequest

Sep 27, 2022

Changes in this version

+ const ContentTypeApplicationJson

Jun 20, 2022

Changes in this version

+ const DialTimeout

+ const KeepAlive

+ const MaxConnectionsPerHost

+ const RequestTimeout

+ const ResponseHeaderTimeout

+ const RetriesCount

+ const RetryWaitTimeMax

+ const RetryWaitTimeStart

+ const RunGroupConcurrencyLimit

+ const TLSHandshakeTimeout

+ const WaitGroupConcurrencyLimit

+ func DefaultTransport() http.RoundTripper

+ func Dialer() *net.Dialer

+ func HTTP2Transport() http.RoundTripper

+ func StructToMap(in any, allowedFields []string) (out map[string]any)

+ func ToFormBody(in map[string]any) (out map[string]string)

+ type APIRequest interface

+ Send func(ctx context.Context, sender Sender) (result R, err error)

+ SendOrErr func(ctx context.Context, sender Sender) error

+ WithBefore func(func(ctx context.Context, sender Sender) error) APIRequest[R]

+ WithOnComplete func(func(ctx context.Context, sender Sender, result R, err error) error) APIRequest[R]

+ WithOnError func(func(ctx context.Context, sender Sender, err error) error) APIRequest[R]

+ WithOnSuccess func(func(ctx context.Context, sender Sender, result R) error) APIRequest[R]

+ func NewAPIRequest(result R, requests ...Sendable) APIRequest[R]

+ func NewNoOperationAPIRequest(result R) APIRequest[R]

+ type Client struct

+ func New() Client

+ func NewMockedClient() (Client, *httpmock.MockTransport)

+ func NewTestClient() Client

+ func (c Client) AndTrace(fn TraceFactory) Client

+ func (c Client) Send(ctx context.Context, reqDef HTTPRequest) (res *http.Response, result any, err error)

+ func (c Client) WithBaseURL(baseURLStr string) Client

+ func (c Client) WithHeader(key, value string) Client

+ func (c Client) WithHeaders(headers map[string]string) Client

+ func (c Client) WithRetry(retry RetryConfig) Client

+ func (c Client) WithTransport(transport http.RoundTripper) Client

+ func (c Client) WithUserAgent(v string) Client

+ type HTTPRequest interface

+ AndHeader func(header string, value string) HTTPRequest

+ AndPathParam func(param, value string) HTTPRequest

+ AndQueryParam func(param, value string) HTTPRequest

+ Send func(ctx context.Context, sender Sender) (response HTTPResponse, result any, err error)

+ SendOrErr func(ctx context.Context, sender Sender) error

+ WithBaseURL func(baseURL string) HTTPRequest

+ WithDelete func(url string) HTTPRequest

+ WithError func(err error) HTTPRequest

+ WithFormBody func(form map[string]string) HTTPRequest

+ WithGet func(url string) HTTPRequest

+ WithJSONBody func(body any) HTTPRequest

+ WithMethod func(method string) HTTPRequest

+ WithOnComplete func(...) HTTPRequest

+ WithOnError func(...) HTTPRequest

+ WithOnSuccess func(func(ctx context.Context, sender Sender, response HTTPResponse) error) HTTPRequest

+ WithPathParams func(params map[string]string) HTTPRequest

+ WithPost func(url string) HTTPRequest

+ WithPut func(url string) HTTPRequest

+ WithQueryParams func(params map[string]string) HTTPRequest

+ WithResult func(result any) HTTPRequest

+ WithURL func(url string) HTTPRequest

+ func NewHTTPRequest() HTTPRequest

+ type HTTPResponse interface

+ Result func() any

+ type NoResult struct

+ type Result = any

+ type RetryCondition func(*http.Response, error) bool

+ func DefaultRetryCondition() RetryCondition

+ type RetryConfig struct

+ Condition RetryCondition

+ Count int

+ TotalRequestTimeout time.Duration

+ WaitTimeMax time.Duration

+ WaitTimeStart time.Duration

+ func DefaultRetry() RetryConfig

+ func TestingRetry() RetryConfig

+ func (c RetryConfig) NewBackoff() backoff.BackOff

+ type RunGroup struct

+ func NewRunGroup(ctx context.Context, sender Sender) *RunGroup

+ func RunGroupWithLimit(ctx context.Context, sender Sender, limit int64) *RunGroup

+ func (g *RunGroup) Add(request Sendable)

+ func (g *RunGroup) RunAndWait() error

+ type Sendable interface

+ SendOrErr func(ctx context.Context, sender Sender) error

+ type Sender interface

+ Send func(ctx context.Context, request HTTPRequest) (rawResponse *http.Response, result any, error error)

+ type Trace struct

+ GotRequest func(request HTTPRequest)

+ HTTPRequestDone func(response *http.Response, err error)

+ HTTPRequestRetry func(attempt int, delay time.Duration)

+ HTTPRequestStart func(request *http.Request)

+ RequestProcessed func(result any, err error)

+ type TraceFactory func() *Trace

+ func DumpTracer(wr io.Writer) TraceFactory

+ func LogTracer(wr io.Writer) TraceFactory

+ type WaitGroup struct

+ func NewWaitGroup(ctx context.Context, sender Sender) *WaitGroup

+ func NewWaitGroupWithLimit(ctx context.Context, sender Sender, limit int64) *WaitGroup

+ func (g *WaitGroup) Send(request Sendable)

+ func (g *WaitGroup) Wait() error