framework

Documentation

Index

• Variables
• func BuildAndSetClients() kclient.Client
• func CreateRedisClusterConfigMapFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error
• func CreateRedisClusterFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error
• func CreateRedisNodeServiceAccountFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error
• func Failf(format string, args ...interface{})
• func GetConfigUpdateEventFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error
• func IsPodDisruptionBudgetCreatedFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error
• func IsPodSpecUpdatedFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster, imageTag string) func() error
• func IsRedisClusterStartedFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error
• func LogAndReturnErrorf(format string, args ...interface{}) error
• func Logf(format string, args ...interface{})
• func NewRedisCluster(name, namespace, tag string, nbPrimary, replication int32) *rapi.RedisCluster
• func UpdateConfigRedisClusterFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster, ...) func() error
• func UpdateRedisClusterConfigMapFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster, ...) func() error
• func UpdateRedisClusterFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error
• func ZonesBalancedFunc(kubeClient kclient.Client, redisCluster *rapi.RedisCluster) func() error
• type Framework
  • func NewFramework() (*Framework, error)

Variables

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