tests

package
v1.5.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 12, 2026 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ClusterTrustBundleFeature features.FeatureName = "ClusterTrustBundle"

	ConformanceInfraNamespace = "gateway-conformance-infra"

	AllNamespacesGateway = "all-namespaces"
)

Variables

View Source 
var (
	IPFamily      = os.Getenv("IP_FAMILY")
	DeployProfile = os.Getenv("KUBE_DEPLOY_PROFILE")

	SameNamespaceGateway    = types.NamespacedName{Name: "same-namespace", Namespace: ConformanceInfraNamespace}
	SameNamespaceGatewayRef = k8sutils.NewGatewayRef(SameNamespaceGateway)

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

Functions

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 added in v1.1.1 

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 BackendTrafficPolicyMustFail added in v1.2.0 

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

BackendTrafficPolicyMustFail waits for an BackendTrafficPolicy to fail with the specified reason.

func ClientTrafficPolicyMustBeAccepted added in v1.1.0 

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 added in v1.1.0 

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 ContentEncoding added in v1.4.0 

func ContentEncoding(compressorType egv1a1.CompressorType) string

func CreateBackend added in v1.3.0 

func CreateBackend(c client.Client, nn types.NamespacedName, clusterIP string, port int32) error

func DeleteBackend added in v1.3.0 

func DeleteBackend(c client.Client, nn types.NamespacedName) error

func EnabledClusterTrustBundle added in v1.5.0 

func EnabledClusterTrustBundle() bool

TODO: remove this when the min version EG supported is v1.33

func EnvoyExtensionPolicyMustBeAccepted added in v1.1.0 

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 added in v1.1.0 

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 ExpectEnvoyProxyDeploymentCount added in v1.4.0 

func ExpectEnvoyProxyDeploymentCount(t *testing.T, suite *suite.ConformanceTestSuite, gwNN types.NamespacedName, expectedNs string, expectedCount int)

func ExpectEnvoyProxyHPACount added in v1.4.0 

func ExpectEnvoyProxyHPACount(t *testing.T, suite *suite.ConformanceTestSuite, gwNN types.NamespacedName, expectedNs string, expectedCount int)

func ExpectRequestTimeout added in v1.4.0 

func ExpectRequestTimeout(t *testing.T, suite *suite.ConformanceTestSuite, gwAddr, path, query string, exceptedStatusCode int)

func GetGatewayResourceNamespace added in v1.4.0 

func GetGatewayResourceNamespace() string

func GetService added in v1.3.0 

func GetService(c client.Client, nn types.NamespacedName) (*corev1.Service, error)

func IsGatewayNamespaceMode added in v1.4.0 

func IsGatewayNamespaceMode() bool

func OverLimitCount added in v1.2.0 

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

func QueryLogCountFromLoki added in v1.1.0 

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

QueryLogCountFromLoki queries log count from loki

func RetrieveMetric added in v1.1.0 

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

func RetrieveMetrics added in v1.1.0 

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

func RetrieveURL added in v1.1.0 

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

func ScrapeMetrics added in v1.1.0 

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

ScrapeMetrics TODO: use QueryPrometheus from test/e2e/tests/promql.go instead

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 added in v1.1.0 

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 ServiceHost added in v1.4.0 

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

func WaitForLoadBalancerAddress added in v1.1.0 

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.

func XDSNameSchemeV2 added in v1.5.0 

func XDSNameSchemeV2() bool

TODO(zhaohuabing) remove this after the feature flag is removed.

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 added in v1.1.0 

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.