Versions in this module Expand all Collapse all v0 v0.0.3 Apr 15, 2022 v0.0.1 Apr 15, 2022 Changes in this version + func DefaultErrorRetryChecker(err error) (bool, error) + func DefaultResponseRetryChecker(resp *Response) (bool, error) + func IsStatusOK(resp *Response) (bool, error) + func ResolveEndpoint(ctx context.Context, kubeClientset kubernetes.Interface, domain string, ...) (string, func(string) string, error) + type ErrorRetryChecker func(e error) (retry bool, err error) + type RequestOption func(*http.Request) + func WithHeader(header http.Header) RequestOption + type Response struct + Body []byte + Header http.Header + Status string + StatusCode int + func (r *Response) String() string + type ResponseChecker func(resp *Response) (done bool, err error) + func IsOneOfStatusCodes(codes ...int) ResponseChecker + func MatchesAllBodies(all ...string) ResponseChecker + func MatchesAllOf(checkers ...ResponseChecker) ResponseChecker + func MatchesBody(expected string) ResponseChecker + type ResponseRetryChecker func(resp *Response) (retry bool, err error) + type SpoofingClient struct + Client *http.Client + Logf logging.FormatLogger + RequestInterval time.Duration + RequestTimeout time.Duration + func New(ctx context.Context, kubeClientset kubernetes.Interface, ...) (*SpoofingClient, error) + func (sc *SpoofingClient) Check(req *http.Request, inState ResponseChecker, checkers ...interface{}) (*Response, error) + func (sc *SpoofingClient) CheckEndpointState(ctx context.Context, url *url.URL, inState ResponseChecker, desc string, ...) (*Response, error) + func (sc *SpoofingClient) Do(req *http.Request, errorRetryCheckers ...interface{}) (*Response, error) + func (sc *SpoofingClient) Poll(req *http.Request, inState ResponseChecker, checkers ...interface{}) (*Response, error) + func (sc *SpoofingClient) WaitForEndpointState(ctx context.Context, url *url.URL, inState ResponseChecker, desc string, ...) (*Response, error) + type TransportOption func(transport *http.Transport) *http.Transport