framework

package
v0.0.0-...-a9bd9a2 Latest Latest
Warning

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

Go to latest
Published: Oct 11, 2023 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var FrameworkContext frameworkContextType

FrameworkContext stores the framework context

Functions

func BuildAndSetClients

func BuildAndSetClients() kclient.Client

BuildAndSetClients builds and initializes RedisCluster and kube client

func CreateRedisClusterConfigMapFunc

func CreateRedisClusterConfigMapFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error

CreateRedisClusterConfigMapFunc returns a func to create the RedisCluster server configuration config map

func CreateRedisClusterFunc

func CreateRedisClusterFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error

CreateRedisClusterFunc returns the func to create a RedisCluster

func CreateRedisNodeServiceAccountFunc

func CreateRedisNodeServiceAccountFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error

CreateRedisNodeServiceAccountFunc returns the func to create the service account associated with the redis node

func Failf

func Failf(format string, args ...interface{})

Failf reports a failure in the current e2e

func GetConfigUpdateEventFunc

func GetConfigUpdateEventFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error

GetConfigUpdateEventFunc returns a func to get the UpdateConfig event associated with the RedisCluster

func IsPodDisruptionBudgetCreatedFunc

func IsPodDisruptionBudgetCreatedFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error

IsPodDisruptionBudgetCreatedFunc returns the func that checks if the PodDisruptionBudget associated with the RedisCluster has been created properly.

func IsPodSpecUpdatedFunc

func IsPodSpecUpdatedFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster, imageTag string) func() error

IsPodSpecUpdatedFunc checks if all RedisCluster pods have the new PodSpec

func IsRedisClusterStartedFunc

func IsRedisClusterStartedFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error

IsRedisClusterStartedFunc returns the func that checks whether the RedisCluster is started and configured properly

func LogAndReturnErrorf

func LogAndReturnErrorf(format string, args ...interface{}) error

LogAndReturnErrorf logs and return an error

func Logf

func Logf(format string, args ...interface{})

Logf logs in e2e framework

func NewRedisCluster

func NewRedisCluster(name, namespace, tag string, nbPrimary, replication int32) *rapi.RedisCluster

NewRedisCluster builds and returns a new RedisCluster instance

func UpdateConfigRedisClusterFunc

func UpdateConfigRedisClusterFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster, nbPrimary, replicas *int32) func() error

UpdateConfigRedisClusterFunc returns the func to update the RedisCluster configuration

func UpdateRedisClusterConfigMapFunc

func UpdateRedisClusterConfigMapFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster, config map[string]string) func() error

UpdateRedisClusterConfigMapFunc returns a func to update the RedisCluster server configuration config map data

func UpdateRedisClusterFunc

func UpdateRedisClusterFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error

UpdateRedisClusterFunc returns the func to update a RedisCluster

func ZonesBalancedFunc

func ZonesBalancedFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error

ZonesBalancedFunc checks if a RedisCluster's node zones are balanced

Types

type Framework

type Framework struct {
	KubeConfig *rest.Config
}

Framework stores necessary info to run e2e

func NewFramework

func NewFramework() (*Framework, error)

NewFramework creates and initializes the Framework struct

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL