test

Documentation

Index

• Constants
• Variables
• func Backend(name string, port networkingv1.ServiceBackendPort) *networkingv1.IngressBackend
• func CheckEvent(recorder *record.FakeRecorder, expected string, shouldMatch bool) error
• func CreateAndInsertNodes(gce *gce.Cloud, nodeNames []string, zoneName string) ([]*api_v1.Node, error)
• func DecodeIngress(data []byte) (*networkingv1.Ingress, error)
• func Float64ToPtr(val float64) *float64
• func GCEInstanceExists(name string, g *gce.Cloud) (bool, error)
• func Int64ToPtr(val int64) *int64
• func NewBackendConfig(name types.NamespacedName, spec backendconfig.BackendConfigSpec) *backendconfig.BackendConfig
• func NewIngress(name types.NamespacedName, spec networkingv1.IngressSpec) *networkingv1.Ingress
• func NewL4ILBService(onlyLocal bool, port int) *api_v1.Service
• func NewService(name types.NamespacedName, spec api_v1.ServiceSpec) *api_v1.Service
• type FakeRecorderSource
  • func (_ *FakeRecorderSource) Recorder(ns string) record.EventRecorder
• type FlagSaver
  • func NewFlagSaver() FlagSaver
  • func (s *FlagSaver) Reset(key flag, flagPointer *bool)
  • func (s *FlagSaver) Save(key flag, flagPointer *bool)
• type L4ILBErrorMetricInfo
  • func GetL4ILBErrorMetric(t *testing.T) *L4ILBErrorMetricInfo
  • func (old *L4ILBErrorMetricInfo) ValidateDiff(new, expect *L4ILBErrorMetricInfo, t *testing.T)
• type L4ILBLatencyMetricInfo
  • func GetL4LatencyMetric(t *testing.T) *L4ILBLatencyMetricInfo
  • func (old *L4ILBLatencyMetricInfo) ValidateDiff(new, expect *L4ILBLatencyMetricInfo, t *testing.T)

Constants

const (
	FinalizerAddFlag          = flag("enable-finalizer-add")
	FinalizerRemoveFlag       = flag("enable-finalizer-remove")
	EnableV2FrontendNamerFlag = flag("enable-v2-frontend-namer")
)

Variables

var (
	FrontendConfig = &frontendconfigv1beta1.FrontendConfig{
		ObjectMeta: meta_v1.ObjectMeta{
			Name:      "config-test",
			Namespace: "test",
		},
	}

	IngressWithoutFrontendConfig = &v1.Ingress{
		ObjectMeta: meta_v1.ObjectMeta{
			Name:      "ing-no-config",
			Namespace: "test",
		},
	}

	IngressWithFrontendConfig = &v1.Ingress{
		ObjectMeta: meta_v1.ObjectMeta{
			Name:      "ing-with-config",
			Namespace: "test",
			Annotations: map[string]string{
				annotations.FrontendConfigKey: "config-test",
			},
		},
	}

	IngressWithFrontendConfigOtherNamespace = &v1.Ingress{
		ObjectMeta: meta_v1.ObjectMeta{
			Name:      "ing-with-config",
			Namespace: "other-namespace",
			Annotations: map[string]string{
				annotations.FrontendConfigKey: "config-test",
			},
		},
	}

	IngressWithOtherFrontendConfig = &v1.Ingress{
		ObjectMeta: meta_v1.ObjectMeta{
			Name:      "ing-with-config",
			Namespace: "test",
			Annotations: map[string]string{
				annotations.FrontendConfigKey: "other-config",
			},
		},
	}
)

The below vars are used for sharing unit testing types with multiple packages.

var (
	BackendPort      = networkingv1.ServiceBackendPort{Number: 80}
	DefaultBeSvcPort = utils.ServicePort{
		ID:       utils.ServicePortID{Service: types.NamespacedName{Namespace: "system", Name: "default"}, Port: BackendPort},
		NodePort: 30000,
		Protocol: annotations.ProtocolHTTP,
	}
)

Functions

func Backend

func Backend(name string, port networkingv1.ServiceBackendPort) *networkingv1.IngressBackend

Backend returns an IngressBackend with the given service name/port.

func CheckEvent

func CheckEvent(recorder *record.FakeRecorder, expected string, shouldMatch bool) error

CheckEvent watches for events in the given FakeRecorder and checks if it matches the given string. It will be used in the l4 firewall XPN tests once TestEnsureLoadBalancerDeletedSucceedsOnXPN and others are uncommented.

func CreateAndInsertNodes

func CreateAndInsertNodes(gce *gce.Cloud, nodeNames []string, zoneName string) ([]*api_v1.Node, error)

CreateAndInsertNodes adds the given nodeNames in the given zone as GCE instances, so they can be looked up in tests.

func DecodeIngress

func DecodeIngress(data []byte) (*networkingv1.Ingress, error)

DecodeIngress deserializes an Ingress object.

func Float64ToPtr

func Float64ToPtr(val float64) *float64

Float64ToPtr returns float ptr for given float.

func GCEInstanceExists

func GCEInstanceExists(name string, g *gce.Cloud) (bool, error)

GCEInstanceExists returns if a given instance name exists.

func Int64ToPtr

func Int64ToPtr(val int64) *int64

Int64ToPtr returns int ptr for given int.

func NewBackendConfig

func NewBackendConfig(name types.NamespacedName, spec backendconfig.BackendConfigSpec) *backendconfig.BackendConfig

NewBackendConfig returns a BackendConfig with the given spec.

func NewIngress

func NewIngress(name types.NamespacedName, spec networkingv1.IngressSpec) *networkingv1.Ingress

NewIngress returns an Ingress with the given spec.

func NewL4ILBService

func NewL4ILBService(onlyLocal bool, port int) *api_v1.Service

NewL4ILBService creates a Service of type LoadBalancer with the Internal annotation.

func NewService

func NewService(name types.NamespacedName, spec api_v1.ServiceSpec) *api_v1.Service

NewService returns a Service with the given spec.

Types

type FakeRecorderSource

type FakeRecorderSource struct{}

func (*FakeRecorderSource) Recorder

func (_ *FakeRecorderSource) Recorder(ns string) record.EventRecorder

type FlagSaver

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

FlagSaver is an utility type to capture the value of a flag and reset back to the saved value.

func NewFlagSaver

func NewFlagSaver() FlagSaver

NewFlagSaver returns a flag saver by initializing the map.

func (*FlagSaver) Reset

func (s *FlagSaver) Reset(key flag, flagPointer *bool)

Reset resets the value of given flag to a previously saved value. This does nothing if the flag value was not captured.

func (*FlagSaver) Save

func (s *FlagSaver) Save(key flag, flagPointer *bool)

Save captures the value of given flag.

type L4ILBErrorMetricInfo

type L4ILBErrorMetricInfo struct {
	ByGCEResource map[string]uint64
	ByErrorType   map[string]uint64
}

L4ILBErrorMetricInfo holds the state of the l4_ilb_sync_error_count metric.

func GetL4ILBErrorMetric

func GetL4ILBErrorMetric(t *testing.T) *L4ILBErrorMetricInfo

GetL4ILBErrorMetric gets the current state of the l4_ilb_sync_error_count metric.

func (*L4ILBErrorMetricInfo) ValidateDiff

func (old *L4ILBErrorMetricInfo) ValidateDiff(new, expect *L4ILBErrorMetricInfo, t *testing.T)

ValidateDiff ensures that the diff between the old and the new metric is as expected. The test uses diff rather than absolute values since the metrics are cumulative of all test cases.

type L4ILBLatencyMetricInfo

type L4ILBLatencyMetricInfo struct {
	CreateCount       uint64
	DeleteCount       uint64
	UpdateCount       uint64
	UpperBoundSeconds float64
	// contains filtered or unexported fields
}

L4LatencyMetricInfo holds the state of the l4_ilb_sync_duration_seconds metric.

func GetL4LatencyMetric

func GetL4LatencyMetric(t *testing.T) *L4ILBLatencyMetricInfo

GetL4LatencyMetric gets the current state of the l4_ilb_sync_duration_seconds metric.

func (*L4ILBLatencyMetricInfo) ValidateDiff

func (old *L4ILBLatencyMetricInfo) ValidateDiff(new, expect *L4ILBLatencyMetricInfo, t *testing.T)

ValidateDiff ensures that the diff between the old and the new metric is as expected. The test uses diff rather than absolute values since the metrics are cumulative of all test cases.