framework

package
v0.6.0-rc.1 Latest Latest
Warning

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

 Go to latest Published: Oct 7, 2019 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Index

Constants

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"
	SelfHostedOperator = true
	DBCatalogName      = "1.5.4-v1"
)

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) CleanAdmissionConfigs 

func (f *Framework) CleanAdmissionConfigs()

func (*Framework) CleanDormantDatabase 

func (f *Framework) CleanDormantDatabase()

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) DeleteDormantDatabase 

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

func (*Framework) DeleteMemcached 

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

func (*Framework) DeleteNamespace 

func (f *Framework) DeleteNamespace() error

func (*Framework) EventuallyAPIServiceReady 

func (f *Framework) EventuallyAPIServiceReady() GomegaAsyncAssertion

func (*Framework) EventuallyAppBinding 

func (f *Framework) EventuallyAppBinding(meta metav1.ObjectMeta) 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) EventuallyMemcached 

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

func (*Framework) EventuallyMemcachedConfigs 

func (f *Framework) EventuallyMemcachedConfigs(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) EventuallyWipedOut 

func (f *Framework) EventuallyWipedOut(meta metav1.ObjectMeta) 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) GetDormantDatabase 

func (f *Framework) GetDormantDatabase(meta metav1.ObjectMeta) (*api.DormantDatabase, 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) 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) TryPatchMemcached 

func (f *Framework) TryPatchMemcached(meta metav1.ObjectMeta, transform func(*api.Memcached) *api.Memcached) (*api.Memcached, 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) DBClient 

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

func (*Invocation) DeleteConfigMap 

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

func (*Invocation) EventuallyConfigSourceVolumeMounted 

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

func (*Invocation) GetCustomConfig 

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

func (*Invocation) GetPod 

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

func (*Invocation) Memcached 

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

func (*Invocation) RestConfig 

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

func (*Invocation) RoleBinding 

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

func (*Invocation) RoleForElasticsearch 

func (i *Invocation) RoleForElasticsearch(meta metav1.ObjectMeta) *rbac.Role

func (*Invocation) RoleForSnapshot 

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

func (*Invocation) ServiceAccount 

func (i *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.