framework

package
v0.7.0-alpha.0 Latest Latest
Warning

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

 Go to latest Published: Jun 8, 2020 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Timeout       = 20 * time.Minute
	RetryInterval = 5 * time.Second
)
View Source 
const (
	GET            = "get"
	LIST           = "list"
	PATCH          = "patch"
	CREATE         = "create"
	UPDATE         = "update"
	USE            = "use"
	POLICY         = "policy"
	Role           = "Role"
	ServiceAccount = "ServiceAccount"
)

Variables

View Source 
var (
	DockerRegistry = "kubedbci"
	DBCatalogName  = "1.5.22"
)

Functions

This section is empty.

Types

type Framework 

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

func New 

func New(
	restConfig *rest.Config,
	kubeClient kubernetes.Interface,
	apiExtKubeClient crd_cs.ApiextensionsV1beta1Interface,
	dbClient cs.Interface,
	kaClient ka.Interface,
	appCatalogClient appcat_cs.AppcatalogV1alpha1Interface,
	storageClass string,
) *Framework

func (*Framework) CheckAppBindingSpec 

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

func (*Framework) CleanMemcached 

func (f *Framework) CleanMemcached()

func (*Framework) CreateMemcached 

func (f *Framework) CreateMemcached(obj *api.Memcached) error

func (*Framework) CreateNamespace 

func (f *Framework) CreateNamespace() error

func (*Framework) CreateRole 

func (f *Framework) CreateRole(obj *rbac.Role) error

func (*Framework) CreateRoleBinding 

func (f *Framework) CreateRoleBinding(obj *rbac.RoleBinding) error

func (*Framework) CreateServiceAccount 

func (f *Framework) CreateServiceAccount(obj *core.ServiceAccount) error

func (*Framework) DeleteMemcached 

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

func (*Framework) DeleteNamespace 

func (f *Framework) DeleteNamespace() error

func (*Framework) EventuallyAppBinding 

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

func (*Framework) EventuallyCRD 

func (f *Framework) EventuallyCRD() GomegaAsyncAssertion

func (*Framework) EventuallyGetItem 

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

func (*Framework) EventuallyMemcached 

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

func (*Framework) EventuallyMemcachedConfigs 

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

func (*Framework) EventuallyMemcachedPhase 

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

func (*Framework) EventuallyMemcachedRunning 

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

func (*Framework) EventuallySetItem 

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

func (*Framework) EvictPodsFromDeployment 

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

func (*Framework) GetDatabasePod 

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

func (*Framework) GetMemcacheClient 

func (f *Framework) GetMemcacheClient(meta metav1.ObjectMeta) (*memcache.Client, error)

func (*Framework) GetMemcached 

func (f *Framework) GetMemcached(meta metav1.ObjectMeta) (*api.Memcached, error)

func (*Framework) Invoke 

func (f *Framework) Invoke() *Invocation

func (*Framework) Namespace 

func (f *Framework) Namespace() string

func (*Framework) PatchMemcached 

func (f *Framework) PatchMemcached(meta metav1.ObjectMeta, transform func(*api.Memcached) *api.Memcached) (*api.Memcached, error)

func (*Framework) PrintDebugHelpers 

func (f *Framework) PrintDebugHelpers()

type Invocation 

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

func (*Invocation) CreateConfigMap 

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

func (*Invocation) DBClient 

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

func (*Invocation) DeleteConfigMap 

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

func (*Invocation) EventuallyConfigSourceVolumeMounted 

func (fi *Invocation) EventuallyConfigSourceVolumeMounted(meta metav1.ObjectMeta) GomegaAsyncAssertion

func (*Invocation) EventuallyWipedOut 

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

func (*Invocation) GetCustomConfig 

func (fi *Invocation) GetCustomConfig(configs []MemcdConfig) *core.ConfigMap

func (*Invocation) GetPod 

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

func (*Invocation) Memcached 

func (fi *Invocation) Memcached() *api.Memcached

func (*Invocation) RestConfig 

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

func (*Invocation) RoleBinding 

func (fi *Invocation) RoleBinding(saName string, roleName string) *rbac.RoleBinding

func (*Invocation) RoleForMemcached 

func (fi *Invocation) RoleForMemcached(meta metav1.ObjectMeta) *rbac.Role

func (*Invocation) RoleForSnapshot 

func (fi *Invocation) RoleForSnapshot(meta metav1.ObjectMeta) *rbac.Role

func (*Invocation) ServiceAccount 

func (fi *Invocation) ServiceAccount() *core.ServiceAccount

type MemcdConfig 

type MemcdConfig struct {
	Name  string
	Value string
	Alias string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.