framework

Documentation

Index

• Variables
• type Framework
  • func New(restConfig *rest.Config, kubeClient kubernetes.Interface, ...) *Framework
  • func (f *Framework) CleanAdmissionConfigs()
  • func (f *Framework) CleanDormantDatabase()
  • func (f *Framework) CleanRedis()
  • func (f *Framework) CreateNamespace() error
  • func (f *Framework) CreateRedis(obj *api.Redis) error
  • func (f *Framework) CreateRedisVersion(obj *api.RedisVersion) error
  • func (f *Framework) DeleteDormantDatabase(meta metav1.ObjectMeta) error
  • func (f *Framework) DeleteNamespace() error
  • func (f *Framework) DeleteRedis(meta metav1.ObjectMeta) error
  • func (f *Framework) DeleteRedisVersion(meta metav1.ObjectMeta) error
  • func (f *Framework) EventuallyAPIServiceReady() GomegaAsyncAssertion
  • func (f *Framework) EventuallyCRD() GomegaAsyncAssertion
  • func (f *Framework) EventuallyDormantDatabase(meta metav1.ObjectMeta) GomegaAsyncAssertion
  • func (f *Framework) EventuallyDormantDatabaseStatus(meta metav1.ObjectMeta) GomegaAsyncAssertion
  • func (f *Framework) EventuallyGetItem(meta metav1.ObjectMeta, key string) GomegaAsyncAssertion
  • func (f *Framework) EventuallyPVCCount(meta metav1.ObjectMeta) GomegaAsyncAssertion
  • func (f *Framework) EventuallyRedis(meta metav1.ObjectMeta) GomegaAsyncAssertion
  • func (f *Framework) EventuallyRedisConfig(meta metav1.ObjectMeta, config string) GomegaAsyncAssertion
  • func (f *Framework) EventuallyRedisRunning(meta metav1.ObjectMeta) GomegaAsyncAssertion
  • func (f *Framework) EventuallySetItem(meta metav1.ObjectMeta, key, value string) GomegaAsyncAssertion
  • func (f *Framework) EventuallyWipedOut(meta metav1.ObjectMeta) GomegaAsyncAssertion
  • func (f *Framework) GetDatabasePod(meta metav1.ObjectMeta) (*core.Pod, error)
  • func (f *Framework) GetDormantDatabase(meta metav1.ObjectMeta) (*api.DormantDatabase, error)
  • func (f *Framework) GetRedis(meta metav1.ObjectMeta) (*api.Redis, error)
  • func (f *Framework) GetRedisClient(meta metav1.ObjectMeta) (*redis.Client, error)
  • func (f *Framework) Invoke() *Invocation
  • func (f *Framework) Namespace() string
  • func (f *Framework) PatchDormantDatabase(meta metav1.ObjectMeta, ...) (*api.DormantDatabase, error)
  • func (f *Framework) RunOperatorAndServer(config *restclient.Config, kubeconfigPath string, stopCh <-chan struct{})
  • func (f *Framework) TryPatchRedis(meta metav1.ObjectMeta, transform func(*api.Redis) *api.Redis) (*api.Redis, error)
• type Invocation
  • func (f *Invocation) CreateConfigMap(obj *core.ConfigMap) error
  • func (f *Invocation) CreateService(obj *core.Service) error
  • func (f *Invocation) DeleteConfigMap(meta metav1.ObjectMeta) error
  • func (f *Invocation) DeleteService(meta metav1.ObjectMeta) error
  • func (fi *Invocation) ExtClient() cs.Interface
  • func (f *Invocation) GetCustomConfig(configs []string) *core.ConfigMap
  • func (fi *Invocation) GetPod(meta metav1.ObjectMeta) (*core.Pod, error)
  • func (f *Invocation) GetTestService(meta metav1.ObjectMeta) *core.Service
  • func (f *Invocation) Redis() *api.Redis
  • func (i *Invocation) RedisVersion() *api.RedisVersion
  • func (fi *Invocation) RestConfig() *rest.Config

Variables

var (
	DockerRegistry     string
	ExporterTag        string
	SelfHostedOperator bool
	DBVersion          string
)

Types

type Framework

type Framework struct {
	StorageClass string
	// contains filtered or unexported fields
}

func New

func New(
	restConfig *rest.Config,
	kubeClient kubernetes.Interface,
	extClient cs.Interface,
	kaClient ka.Interface,
	storageClass string,
) *Framework

func (*Framework) CleanAdmissionConfigs

func (f *Framework) CleanAdmissionConfigs()

func (*Framework) CleanDormantDatabase

func (f *Framework) CleanDormantDatabase()

func (*Framework) CleanRedis

func (f *Framework) CleanRedis()

func (*Framework) CreateNamespace

func (f *Framework) CreateNamespace() error

func (*Framework) CreateRedis

func (f *Framework) CreateRedis(obj *api.Redis) error

func (*Framework) CreateRedisVersion

func (f *Framework) CreateRedisVersion(obj *api.RedisVersion) error

func (*Framework) DeleteDormantDatabase

func (f *Framework) DeleteDormantDatabase(meta metav1.ObjectMeta) error

func (*Framework) DeleteNamespace

func (f *Framework) DeleteNamespace() error

func (*Framework) DeleteRedis

func (f *Framework) DeleteRedis(meta metav1.ObjectMeta) error

func (*Framework) DeleteRedisVersion

func (f *Framework) DeleteRedisVersion(meta metav1.ObjectMeta) error

func (*Framework) EventuallyAPIServiceReady

func (f *Framework) EventuallyAPIServiceReady() GomegaAsyncAssertion

func (*Framework) EventuallyCRD

func (f *Framework) EventuallyCRD() GomegaAsyncAssertion

func (*Framework) EventuallyDormantDatabase

func (f *Framework) EventuallyDormantDatabase(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyDormantDatabaseStatus

func (f *Framework) EventuallyDormantDatabaseStatus(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyGetItem

func (f *Framework) EventuallyGetItem(meta metav1.ObjectMeta, key string) GomegaAsyncAssertion

func (*Framework) EventuallyPVCCount

func (f *Framework) EventuallyPVCCount(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyRedis

func (f *Framework) EventuallyRedis(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallyRedisConfig

func (f *Framework) EventuallyRedisConfig(meta metav1.ObjectMeta, config string) GomegaAsyncAssertion

func (*Framework) EventuallyRedisRunning

func (f *Framework) EventuallyRedisRunning(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) EventuallySetItem

func (f *Framework) EventuallySetItem(meta metav1.ObjectMeta, key, value string) GomegaAsyncAssertion

func (*Framework) EventuallyWipedOut

func (f *Framework) EventuallyWipedOut(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Framework) GetDatabasePod

func (f *Framework) GetDatabasePod(meta metav1.ObjectMeta) (*core.Pod, error)

func (*Framework) GetDormantDatabase

func (f *Framework) GetDormantDatabase(meta metav1.ObjectMeta) (*api.DormantDatabase, error)

func (*Framework) GetRedis

func (f *Framework) GetRedis(meta metav1.ObjectMeta) (*api.Redis, error)

func (*Framework) GetRedisClient

func (f *Framework) GetRedisClient(meta metav1.ObjectMeta) (*redis.Client, error)

func (*Framework) Invoke

func (f *Framework) Invoke() *Invocation

func (*Framework) Namespace

func (f *Framework) Namespace() string

func (*Framework) PatchDormantDatabase

func (f *Framework) PatchDormantDatabase(meta metav1.ObjectMeta, transform func(*api.DormantDatabase) *api.DormantDatabase) (*api.DormantDatabase, error)

func (*Framework) RunOperatorAndServer

func (f *Framework) RunOperatorAndServer(config *restclient.Config, kubeconfigPath string, stopCh <-chan struct{})

func (*Framework) TryPatchRedis

func (f *Framework) TryPatchRedis(meta metav1.ObjectMeta, transform func(*api.Redis) *api.Redis) (*api.Redis, error)

type Invocation

type Invocation struct {
	*Framework
	// contains filtered or unexported fields
}

func (*Invocation) CreateConfigMap

func (f *Invocation) CreateConfigMap(obj *core.ConfigMap) error

func (*Invocation) CreateService

func (f *Invocation) CreateService(obj *core.Service) error

func (*Invocation) DeleteConfigMap

func (f *Invocation) DeleteConfigMap(meta metav1.ObjectMeta) error

func (*Invocation) DeleteService

func (f *Invocation) DeleteService(meta metav1.ObjectMeta) error

func (*Invocation) ExtClient

func (fi *Invocation) ExtClient() cs.Interface

func (*Invocation) GetCustomConfig

func (f *Invocation) GetCustomConfig(configs []string) *core.ConfigMap

func (*Invocation) GetPod

func (fi *Invocation) GetPod(meta metav1.ObjectMeta) (*core.Pod, error)

func (*Invocation) GetTestService

func (f *Invocation) GetTestService(meta metav1.ObjectMeta) *core.Service

func (*Invocation) Redis

func (f *Invocation) Redis() *api.Redis

func (*Invocation) RedisVersion

func (i *Invocation) RedisVersion() *api.RedisVersion

func (*Invocation) RestConfig

func (fi *Invocation) RestConfig() *rest.Config