Versions in this module Expand all Collapse all v1 v1.6.0 Jul 29, 2026 v1.5.2 Mar 19, 2026 Changes in this version + func IsRetryAfter(resp *http.Response) (string, bool) + func WithRequestContextAssociatedData(parent context.Context, data *RequestContextAssociatedData) context.Context + type Client interface + Do func(*http.Request) (*http.Response, error) + type ClientFunc func(*http.Request) (*http.Response, error) + func (f ClientFunc) Do(r *http.Request) (*http.Response, error) + type GotConnInfo struct + IdleTime time.Duration + RemoteAddr string + Reused bool + WasIdle bool + func (ci GotConnInfo) String() string + type HostNameDecoder interface + Decode func(string) string + type HostNameDecoderWithRunner interface + Run func(stop context.Context) (done context.Context) + type LoadBalancerType string + const ExternalLoadBalancerType + const InternalLoadBalancerType + const LocalhostType + const ServiceNetworkType + func ParseStringToLoadBalancerType(input string) LoadBalancerType + type ProtocolType string + const ProtocolHTTP1 + const ProtocolHTTP2 + type RequestContextAssociatedData struct + DNSErr error + GotConnInfo *GotConnInfo + ResponseBody []byte + ResponseBodyReadErr error + RoundTripDuration time.Duration + ShutdownResponse *ShutdownResponse + ShutdownResponseHeaderParseErr error + Source string + func RequestContextAssociatedDataFrom(ctx context.Context) *RequestContextAssociatedData + type RequestResponse struct + Request *http.Request + Response *http.Response + func (rr RequestResponse) ConnectionReused() string + func (rr RequestResponse) Fields() map[string]interface{} + func (rr RequestResponse) GetAuditID() string + func (rr RequestResponse) IsRetryAfter() (string, bool) + func (rr RequestResponse) Protocol() string + func (rr RequestResponse) RetryAfter() string + func (rr RequestResponse) ShutdownInProgress() bool + func (rr RequestResponse) StatusCode() string + func (rr RequestResponse) String() string + type SampleResult struct + Sample *sampler.Sample + func (s SampleResult) AggregateErr() error + func (s SampleResult) Err() error + func (s SampleResult) Error() string + func (s SampleResult) Succeeded() bool + type ShutdownResponse struct + Elapsed time.Duration + Hostname string + ShutdownDelayDuration time.Duration + ShutdownInProgress bool + func (sr ShutdownResponse) Fields() map[string]interface{} + func (sr ShutdownResponse) String() string + type TestDescriptor interface + DisruptionLocator func() monitorapi.Locator + GetConnectionType func() monitorapi.BackendConnectionType + GetLoadBalancerType func() LoadBalancerType + GetProtocol func() ProtocolType + GetTargetServerName func() string + Name func() string + ShutdownLocator func() monitorapi.Locator + type WantEventRecorderAndMonitorRecorder interface + SetEventRecorder func(events.EventRecorder) + SetMonitorRecorder func(monitorRecorder monitorapi.RecorderWriter)