framework

package
v1.57.0 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2026 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Overview

Package framework is a package helping setting up end-to-end testing across a Kubernetes cluster.

Index

Constants

View Source 
const (
	AutoCleanupLabelKey   = "agones.dev/e2e-test-auto-cleanup"
	AutoCleanupLabelValue = "true"
)

special labels that can be put on pods to trigger automatic cleanup.

Variables

View Source 
var NamespaceLabel = map[string]string{"owner": "e2e-test"}

NamespaceLabel is the label that is put on all namespaces that are created for e2e tests.

Functions

func FleetReadyCount added in v0.5.0 

func FleetReadyCount(amount int32) func(*logrus.Entry, *agonesv1.Fleet) bool

FleetReadyCount returns the ready count in a fleet

func GetAllocation added in v0.12.0 

func GetAllocation(f *agonesv1.Fleet) *allocationv1.GameServerAllocation

GetAllocation returns a GameServerAllocation that is looking for a Ready GameServer from this fleet.

func ParseTestFlags added in v1.6.0 

func ParseTestFlags() error

ParseTestFlags Parses go test flags separately because pflag package ignores flags with '-test.' prefix Related issues: https://github.com/spf13/pflag/issues/63 https://github.com/spf13/pflag/issues/238

func SendGameServerTCP added in v1.9.0 

func SendGameServerTCP(gs *agonesv1.GameServer, msg string) (string, error)

SendGameServerTCP sends a message to a gameserver and returns its reply finds the first tcp port from the spec to send the message to, returns error if no Ports were allocated

func SendGameServerTCPToPort added in v1.9.0 

func SendGameServerTCPToPort(gs *agonesv1.GameServer, portName string, msg string) (string, error)

SendGameServerTCPToPort sends a message to a gameserver at the named port and returns its reply returns error if no Ports were allocated or a port of the specified name doesn't exist

func SendTCP added in v1.9.0 

func SendTCP(address, msg string) (string, error)

SendTCP sends a message to an address, and returns its reply if it returns one in 30 seconds

func TestLogger added in v1.19.0 

func TestLogger(t *testing.T) *logrus.Entry

TestLogger returns the standard logger for helper functions.

Types

type Framework 

type Framework struct {
	KubeClient      kubernetes.Interface
	AgonesClient    versioned.Interface
	GameServerImage string
	PullSecret      string
	StressTestLevel int
	PerfOutputDir   string
	Version         string
	Namespace       string
	CloudProduct    string
	WaitForState    time.Duration // default time to wait for state changes, may change based on cloud product.
}

Framework is a testing framework

func NewFromFlags added in v1.4.0 

func NewFromFlags() (*Framework, error)

NewFromFlags sets up the testing framework with the standard command line flags.

func (*Framework) AssertFleetCondition added in v1.1.0 

func (f *Framework) AssertFleetCondition(t *testing.T, flt *agonesv1.Fleet, condition func(*logrus.Entry, *agonesv1.Fleet) bool)

AssertFleetCondition waits for the Fleet to be in a specific condition or fails the test if the condition can't be met in 5 minutes.

func (*Framework) CleanUp 

func (f *Framework) CleanUp(ns string) error

CleanUp Delete all Agones resources in a given namespace.

func (*Framework) CreateAndApplyAllocation added in v0.12.0 

func (f *Framework) CreateAndApplyAllocation(t *testing.T, flt *agonesv1.Fleet) *allocationv1.GameServerAllocation

CreateAndApplyAllocation creates and applies an Allocation to a Fleet

func (*Framework) CreateGameServerAndWaitUntilReady 

func (f *Framework) CreateGameServerAndWaitUntilReady(t *testing.T, ns string, gs *agonesv1.GameServer) (*agonesv1.GameServer, error)

CreateGameServerAndWaitUntilReady Creates a GameServer and wait for its state to become ready.

func (*Framework) CreateNamespace added in v1.1.0 

func (f *Framework) CreateNamespace(namespace string) error

CreateNamespace creates a namespace and a service account in the test cluster

func (*Framework) CycleAllocations added in v1.22.0 

func (f *Framework) CycleAllocations(ctx context.Context, t *testing.T, flt *agonesv1.Fleet, period time.Duration, allocDuration time.Duration)

CycleAllocations repeatedly Allocates a GameServer in the Fleet (if one is available), once every specified period. Each Allocated GameServer gets deleted allocDuration after it was Allocated. GameServers will continue to be Allocated until a message is passed to the done channel.

func (*Framework) DefaultGameServer added in v1.4.0 

func (f *Framework) DefaultGameServer(namespace string) *agonesv1.GameServer

DefaultGameServer provides a default GameServer fixture, based on parameters passed to the Test Framework.

func (*Framework) DeleteNamespace added in v1.1.0 

func (f *Framework) DeleteNamespace(namespace string) error

DeleteNamespace deletes a namespace from the test cluster

func (*Framework) ListGameServersFromFleet added in v0.5.0 

func (f *Framework) ListGameServersFromFleet(flt *agonesv1.Fleet) ([]agonesv1.GameServer, error)

ListGameServersFromFleet lists GameServers from a particular fleet

func (*Framework) LogEvents added in v1.19.0 

func (f *Framework) LogEvents(t *testing.T, log *logrus.Entry, namespace string, objOrRef k8sruntime.Object)

LogEvents logs all the events for a given Kubernetes objects. Useful for debugging why something went wrong.

func (*Framework) LogPodContainers added in v1.53.0 

func (f *Framework) LogPodContainers(t *testing.T, pod *corev1.Pod)

LogPodContainers takes a Pod as an argument and attempts to output the current and previous logs from each container in that Pod It uses the framework's KubeClient to retrieve the logs and outputs them using the provided logger.

func (*Framework) NewStatsCollector added in v0.9.0 

func (f *Framework) NewStatsCollector(name, version string) *StatsCollector

NewStatsCollector returns new instance of statistics collector, which can be used to emit performance statistics for load tests and stress tests.

func (*Framework) ScaleFleet added in v1.32.0 

func (f *