backend

type Client interface {
	Do(*http.Request) (*http.Response, error)
}

type ClientFunc func(*http.Request) (*http.Response, error)

type GotConnInfo struct {
	// RemoteAddr returns the remote network address, if known.
	RemoteAddr string

	// Reused is whether this connection has been previously
	// used for another HTTP request.
	Reused bool

	// WasIdle is whether this connection was obtained from an
	// idle pool.
	WasIdle bool

	// IdleTime reports how long the connection was previously
	// idle, if WasIdle is true.
	IdleTime time.Duration
}

type HostNameDecoder interface {
	Decode(string) string
}

type HostNameDecoderWithRunner interface {
	HostNameDecoder
	Run(stop context.Context) (done context.Context)
}

type LoadBalancerType string

type ProtocolType string

type RequestContextAssociatedData struct {
	// GotConnInfo is the data obtained from the GotConn client
	// connection trace for this request.
	GotConnInfo *GotConnInfo

	// DNSErr is set if the there was an error during DNS lookup,
	// this is obtained from the DNSDone client connection trace.
	DNSErr error

	// RoundTripDuration is the latency incurred in the
	// round trip for this request.
	RoundTripDuration time.Duration

	// ResponseBody is the stored bytes that was obtained from reading
	// off the body of the response received from the server
	ResponseBody []byte
	// ResponseBodyReadErr is set if any error occurs while reading the
	// body of the response, or while closing the underlying stream.
	ResponseBodyReadErr error

	// ShutdownResponse holds the result of parsing the 'X-OpenShift-Disruption'
	// response header, it will be nil if ShutdownResponseHeaderParseErr is set.
	ShutdownResponse *ShutdownResponse
	// ShutdownResponseHeaderParseErr is set if there was an error parsing the
	// 'X-OpenShift-Disruption' response header
	ShutdownResponseHeaderParseErr error

	// Source contains pod name if incluster monitor is used
	Source string
}

type RequestResponse struct {
	// Request and Response associated with this backend sample.
	// NOTE: the body of the response will have been read and closed
	//  immediately after getting the response from the server.
	// Request may be nil if the sampler fails to create a new request
	// Response may be nil in case the server returned an error
	Request  *http.Request
	Response *http.Response

	// RequestContextAssociatedData holds the data
	// stored in the request context.
	RequestContextAssociatedData
}

type SampleResult struct {
	RequestResponse
	Sample *sampler.Sample
}

type ShutdownResponse struct {
	// ShutdownInProgress is true if a graceful shutdown was in
	// progress when the request was received by the server,
	// otherwise this is false.
	ShutdownInProgress bool

	// ShutdownDelayDuration is the value of the --shutdown-delay-duration
	// server run option in use.
	ShutdownDelayDuration time.Duration

	// Elapsed is the amount of time elapsed since the server has
	// received the TERM signal, if the server is not shutting
	// down then this value is zero.
	Elapsed time.Duration

	// Hostname is the hostname of the apiserver process
	Hostname string
}

type TestDescriptor interface {
	Name() string
	DisruptionLocator() monitorapi.Locator
	ShutdownLocator() monitorapi.Locator
	GetLoadBalancerType() LoadBalancerType
	GetProtocol() ProtocolType
	GetConnectionType() monitorapi.BackendConnectionType
	GetTargetServerName() string
}

type WantEventRecorderAndMonitorRecorder interface {
	SetEventRecorder(events.EventRecorder)
	SetMonitorRecorder(monitorRecorder monitorapi.RecorderWriter)
}