tests

Documentation

Index

• Variables
• func ALSLogCount(suite *suite.ConformanceTestSuite) (int, error)
• func AlmostEquals(actual, expect, offset int) bool
• func BackendMustBeAccepted(t *testing.T, client client.Client, backendName types.NamespacedName)
• func BackendTrafficPolicyMustBeAccepted(t *testing.T, client client.Client, policyName types.NamespacedName, ...)
• func ClientTrafficPolicyMustBeAccepted(t *testing.T, client client.Client, policyName types.NamespacedName, ...)
• func CollectAndDump(t *testing.T, rest *rest.Config)
• func EnvoyExtensionPolicyMustBeAccepted(t *testing.T, client client.Client, policyName types.NamespacedName, ...)
• func EnvoyExtensionPolicyMustFail(t *testing.T, client client.Client, policyName types.NamespacedName, ...)
• func QueryLogCountFromLoki(t *testing.T, c client.Client, keyValues map[string]string, match string) (int, error)
• func QueryTraceFromTempo(t *testing.T, c client.Client, tags map[string]string) (int, error)
• func RetrieveMetric(url string, name string, timeout time.Duration) (*dto.MetricFamily, error)
• func RetrieveMetrics(url string, timeout time.Duration) (map[string]*dto.MetricFamily, error)
• func RetrieveURL(c client.Client, nn types.NamespacedName, port int32, path string) (string, error)
• func ScrapeMetrics(t *testing.T, c client.Client, nn types.NamespacedName, port int32, ...) error
• func SecurityPolicyMustBeAccepted(t *testing.T, client client.Client, policyName types.NamespacedName, ...)
• func SecurityPolicyMustFail(t *testing.T, client client.Client, policyName types.NamespacedName, ...)
• func WaitForLoadBalancerAddress(t *testing.T, client client.Client, timeout time.Duration, ...) (string, error)
• func WaitForPods(t *testing.T, cl client.Client, namespace string, selectors map[string]string, ...)
• type AddressMappings
  • func (a *AddressMappings) DialContext(ctx context.Context, network, addr string) (net.Conn, error)
• type CookieTracker
  • func (c *CookieTracker) RoundTrip(req *http.Request) (*http.Response, error)
• type LoggingRoundTripper
  • func (l LoggingRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)
• type LokiQueryResponse
• type OIDCTestClient
  • func NewOIDCTestClient(opts ...Option) (*OIDCTestClient, error)
  • func (o *OIDCTestClient) Get(url string, followDirection bool) (*http.Response, error)
  • func (o *OIDCTestClient) Login(formData map[string]string) (*http.Response, error)
  • func (o *OIDCTestClient) ParseLoginForm(responseBody io.ReadCloser, formID string) error
  • func (o *OIDCTestClient) Send(req *http.Request, followRedirect bool) (*http.Response, error)
• type Option
  • func WithCustomAddressMappings(mappings map[string]string) Option
  • func WithLoggingOptions(logFunc func(...any), logBody bool) Option

Variables

var PodReady = corev1.PodCondition{Type: corev1.PodReady, Status: corev1.ConditionTrue}

Functions

func ALSLogCount

func ALSLogCount(suite *suite.ConformanceTestSuite) (int, error)

func AlmostEquals

func AlmostEquals(actual, expect, offset int) bool

AlmostEquals We use a solution similar to istio: Given an offset, calculate whether the actual value is within the offset of the expected value

func BackendMustBeAccepted

func BackendMustBeAccepted(t *testing.T, client client.Client, backendName types.NamespacedName)

BackendMustBeAccepted waits for the specified Backend to be accepted.

func BackendTrafficPolicyMustBeAccepted

func BackendTrafficPolicyMustBeAccepted(t *testing.T, client client.Client, policyName types.NamespacedName, controllerName string, ancestorRef gwapiv1a2.ParentReference)

BackendTrafficPolicyMustBeAccepted waits for the specified BackendTrafficPolicy to be accepted.

func ClientTrafficPolicyMustBeAccepted

func ClientTrafficPolicyMustBeAccepted(t *testing.T, client client.Client, policyName types.NamespacedName, controllerName string, ancestorRef gwapiv1a2.ParentReference)

ClientTrafficPolicyMustBeAccepted waits for the specified ClientTrafficPolicy to be accepted.

func CollectAndDump

func CollectAndDump(t *testing.T, rest *rest.Config)

CollectAndDump collects and dumps the cluster data for troubleshooting and log. This function should be call within t.Cleanup.

func EnvoyExtensionPolicyMustBeAccepted

func EnvoyExtensionPolicyMustBeAccepted(t *testing.T, client client.Client, policyName types.NamespacedName, controllerName string, ancestorRef gwapiv1a2.ParentReference)

EnvoyExtensionPolicyMustBeAccepted waits for the specified EnvoyExtensionPolicy to be accepted.

func EnvoyExtensionPolicyMustFail

func EnvoyExtensionPolicyMustFail(
	t *testing.T, client client.Client, policyName types.NamespacedName,
	controllerName string, ancestorRef gwapiv1a2.ParentReference, message string,
)

EnvoyExtensionPolicyMustFail waits for an EnvoyExtensionPolicy to fail with the specified reason.

func QueryLogCountFromLoki

func QueryLogCountFromLoki(t *testing.T, c client.Client, keyValues map[string]string, match string) (int, error)

QueryLogCountFromLoki queries log count from loki

func QueryTraceFromTempo

func QueryTraceFromTempo(t *testing.T, c client.Client, tags map[string]string) (int, error)

QueryTraceFromTempo queries span count from tempo

func RetrieveMetric

func RetrieveMetric(url string, name string, timeout time.Duration) (*dto.MetricFamily, error)

func RetrieveMetrics

func RetrieveMetrics(url string, timeout time.Duration) (map[string]*dto.MetricFamily, error)

func RetrieveURL

func RetrieveURL(c client.Client, nn types.NamespacedName, port int32, path string) (string, error)

func ScrapeMetrics

func ScrapeMetrics(t *testing.T, c client.Client, nn types.NamespacedName, port int32, path string) error

func SecurityPolicyMustBeAccepted

func SecurityPolicyMustBeAccepted(t *testing.T, client client.Client, policyName types.NamespacedName, controllerName string, ancestorRef gwapiv1a2.ParentReference)

SecurityPolicyMustBeAccepted waits for the specified SecurityPolicy to be accepted.

func SecurityPolicyMustFail

func SecurityPolicyMustFail(
	t *testing.T, client client.Client, policyName types.NamespacedName,
	controllerName string, ancestorRef gwapiv1a2.ParentReference, message string,
)

SecurityPolicyMustFail waits for an SecurityPolicy to fail with the specified reason.

func WaitForLoadBalancerAddress

func WaitForLoadBalancerAddress(t *testing.T, client client.Client, timeout time.Duration, nn types.NamespacedName) (string, error)

func WaitForPods

func WaitForPods(t *testing.T, cl client.Client, namespace string, selectors map[string]string, phase corev1.PodPhase, condition corev1.PodCondition)

WaitForPods waits for the pods in the given namespace and with the given selector to be in the given phase and condition.

Types

type AddressMappings

type AddressMappings struct {
	// contains filtered or unexported fields
}

AddressMappings is a custom dialer that resolves specific host:port to specific target addresses.

func (*AddressMappings) DialContext

func (a *AddressMappings) DialContext(ctx context.Context, network, addr string) (net.Conn, error)

DialContext is a custom dialer that resolves specific host:port to specific target addresses.

type CookieTracker

type CookieTracker struct {
	Delegate http.RoundTripper
	Cookies  map[string]*http.Cookie
}

CookieTracker is a http.RoundTripper that tracks cookies received from the server.

func (*CookieTracker) RoundTrip

func (c *CookieTracker) RoundTrip(req *http.Request) (*http.Response, error)

RoundTrip tracks the cookies received from the server.

type LoggingRoundTripper

type LoggingRoundTripper struct {
	LogFunc  func(...any)
	LogBody  bool
	Delegate http.RoundTripper
}

LoggingRoundTripper is a http.RoundTripper that logs requests and responses.

func (LoggingRoundTripper) RoundTrip

func (l LoggingRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

RoundTrip logs all the requests and responses using the configured settings.

type LokiQueryResponse

type LokiQueryResponse struct {
	Status string `json:"status"`
	Data   struct {
		ResultType string `json:"resultType"`
		Result     []struct {
			Metric interface{}
			Values []interface{} `json:"values"`
		}
	}
}

type OIDCTestClient

type OIDCTestClient struct {
	// contains filtered or unexported fields
}

OIDCTestClient encapsulates a http.Client and keeps track of the state of the OIDC login process.

func NewOIDCTestClient

func NewOIDCTestClient(opts ...Option) (*OIDCTestClient, error)

NewOIDCTestClient creates a new OIDCTestClient.

func (*OIDCTestClient) Get

func (o *OIDCTestClient) Get(url string, followDirection bool) (*http.Response, error)

Get sends a GET request to the specified URL.

func (*OIDCTestClient) Login

func (o *OIDCTestClient) Login(formData map[string]string) (*http.Response, error)

Login logs in to the IdP using the provided credentials.

func (*OIDCTestClient) ParseLoginForm

func (o *OIDCTestClient) ParseLoginForm(responseBody io.ReadCloser, formID string) error

ParseLoginForm parses the HTML response body to get the URL where the login page would post the user-entered credentials.

func (*OIDCTestClient) Send

func (o *OIDCTestClient) Send(req *http.Request, followRedirect bool) (*http.Response, error)

Send sends the specified request.

type Option

type Option func(*OIDCTestClient) error

Option is a functional option for configuring the OIDCTestClient.

func WithCustomAddressMappings

func WithCustomAddressMappings(mappings map[string]string) Option

WithCustomAddressMappings configures the OIDCTestClient to resolve specific host:port to specific target addresses.

func WithLoggingOptions

func WithLoggingOptions(logFunc func(...any), logBody bool) Option

WithLoggingOptions configures the OIDCTestClient to log requests and responses.