request

Jun 6, 2023

Changes in this version

type HTTPRequest

+ WithHead func(url string) HTTPRequest

+ WithPatch func(url string) HTTPRequest

May 22, 2023

Changes in this version

+ const APIRequestSpanName

+ func APIRequestTracerFromContext(ctx context.Context) (trace.Tracer, bool)

type HTTPRequest

+ WithURLValue func(url *url.URL) HTTPRequest

May 15, 2023

Changes in this version

+ const RunGroupConcurrencyLimit

+ const WaitGroupConcurrencyLimit

+ 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) (result R, err error)

+ SendOrErr func(ctx context.Context) error

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

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

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

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

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

+ func NewNoOperationAPIRequest(result R) APIRequest[R]

+ 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) (response HTTPResponse, result any, err error)

+ SendOrErr func(ctx context.Context) error

+ WithBaseURL func(baseURL string) HTTPRequest

+ WithBody func(body any) HTTPRequest

+ WithContentType func(contentType 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(func(ctx context.Context, response HTTPResponse, err error) error) HTTPRequest

+ WithOnError func(func(ctx context.Context, response HTTPResponse, err error) error) HTTPRequest

+ WithOnSuccess func(func(ctx context.Context, 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(sender Sender) HTTPRequest

+ type HTTPResponse interface

+ Result func() any

+ type NoResult struct

+ type ParallelAPIRequests []Sendable

+ func Parallel(requests ...Sendable) ParallelAPIRequests

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

+ type ReqDefinitionError struct

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

+ func (v ReqDefinitionError) Unwrap() error

+ type Result = any

+ 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) error

+ func NewReqDefinitionError(err error) Sendable

+ type Sender interface

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

+ type WaitGroup struct

+ func NewWaitGroup(ctx context.Context) *WaitGroup

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

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

+ func (g *WaitGroup) Wait() error