framework

Documentation

Overview

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

Index

• Constants
• func FleetReadyCount(amount int32) func(fleet *v1alpha1.Fleet) bool
• func PingGameServer(msg, address string) (reply string, err error)
• type Framework
  • func New(kubeconfig, gsimage string, pullSecret string, stressTestLevel int) (*Framework, error)
  • func (f *Framework) CleanUp(ns string) error
  • func (f *Framework) CreateGameServerAndWaitUntilReady(ns string, gs *v1alpha1.GameServer) (*v1alpha1.GameServer, error)
  • func (f *Framework) ListGameServersFromFleet(flt *v1alpha1.Fleet) ([]v1alpha1.GameServer, error)
  • func (f *Framework) WaitForFleetCondition(t *testing.T, flt *v1alpha1.Fleet, condition func(fleet *v1alpha1.Fleet) bool)
  • func (f *Framework) WaitForFleetGameServersCondition(flt *v1alpha1.Fleet, cond func(server v1alpha1.GameServer) bool) error
  • func (f *Framework) WaitForGameServerState(gs *v1alpha1.GameServer, state v1alpha1.GameServerState, timeout time.Duration) (*v1alpha1.GameServer, error)
• type PerfResults
  • func (p *PerfResults) AddSample(d time.Duration)
  • func (p *PerfResults) Report(name string)

Constants

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

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

Functions

func FleetReadyCount

func FleetReadyCount(amount int32) func(fleet *v1alpha1.Fleet) bool

FleetReadyCount returns the ready count in a fleet

func PingGameServer

func PingGameServer(msg, address string) (reply string, err error)

PingGameServer pings a gameserver and returns its reply

Types

type Framework

type Framework struct {
	KubeClient      kubernetes.Interface
	AgonesClient    versioned.Interface
	GameServerImage string
	PullSecret      string
	StressTestLevel int
}

Framework is a testing framework

func New

func New(kubeconfig, gsimage string, pullSecret string, stressTestLevel int) (*Framework, error)

New setups a testing framework using a kubeconfig path and the game server image to use for testing.

func (*Framework) CleanUp

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

CleanUp Delete all Agones resources in a given namespace.

func (*Framework) CreateGameServerAndWaitUntilReady

func (f *Framework) CreateGameServerAndWaitUntilReady(ns string, gs *v1alpha1.GameServer) (*v1alpha1.GameServer, error)

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

func (*Framework) ListGameServersFromFleet

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

ListGameServersFromFleet lists GameServers from a particular fleet

func (*Framework) WaitForFleetCondition

func (f *Framework) WaitForFleetCondition(t *testing.T, flt *v1alpha1.Fleet, condition func(fleet *v1alpha1.Fleet) bool)

WaitForFleetCondition 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) WaitForFleetGameServersCondition

func (f *Framework) WaitForFleetGameServersCondition(flt *v1alpha1.Fleet, cond func(server v1alpha1.GameServer) bool) error

WaitForFleetGameServersCondition wait for all GameServers for a given fleet to match the spec.replicas and match a a condition

func (*Framework) WaitForGameServerState

func (f *Framework) WaitForGameServerState(gs *v1alpha1.GameServer, state v1alpha1.GameServerState,
	timeout time.Duration) (*v1alpha1.GameServer, error)

WaitForGameServerState Waits untils the gameserver reach a given state before the timeout expires

type PerfResults

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

PerfResults aggregates performance test results. The AddSample() method is safe for concurrent use by multiple goroutines.

func (*PerfResults) AddSample

func (p *PerfResults) AddSample(d time.Duration)

AddSample adds a single time measurement.

func (*PerfResults) Report

func (p *PerfResults) Report(name string)

Report outputs performance report to log.