Documentation ¶
Overview ¶
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright The KubeDB Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
- Constants
- Variables
- type Framework
- func (f *Framework) CheckAppBindingSpec(meta metav1.ObjectMeta) error
- func (f *Framework) CheckSecret(secret *core.Secret) error
- func (f *Framework) CleanElasticsearch()
- func (f *Framework) CreateBackupConfiguration(backupCfg *stashv1beta1.BackupConfiguration) error
- func (f *Framework) CreateElasticsearch(obj *api.Elasticsearch) error
- func (f *Framework) CreateNamespace() error
- func (f *Framework) CreateRepository(repo *stashV1alpha1.Repository) error
- func (f *Framework) CreateRestoreSession(restoreSession *stashv1beta1.RestoreSession) error
- func (f *Framework) CreateRole(obj *rbac.Role) error
- func (f *Framework) CreateRoleBinding(obj *rbac.RoleBinding) error
- func (f *Framework) CreateSecret(obj *core.Secret) error
- func (f *Framework) CreateServiceAccount(obj *core.ServiceAccount) error
- func (f *Framework) DeleteBackupConfiguration(meta metav1.ObjectMeta) error
- func (f *Framework) DeleteElasticsearch(meta metav1.ObjectMeta) error
- func (f *Framework) DeleteNamespace() error
- func (f *Framework) DeleteRepository(meta metav1.ObjectMeta) error
- func (f Framework) DeleteRestoreSession(meta metav1.ObjectMeta) error
- func (f *Framework) DeleteSecret(meta metav1.ObjectMeta) error
- func (f *Framework) EventuallyAppBinding(meta metav1.ObjectMeta) GomegaAsyncAssertion
- func (f *Framework) EventuallyCRD() GomegaAsyncAssertion
- func (f *Framework) EventuallyDBSecretCount(meta metav1.ObjectMeta) GomegaAsyncAssertion
- func (f *Framework) EventuallyElasticsearch(meta metav1.ObjectMeta) GomegaAsyncAssertion
- func (f *Framework) EventuallyElasticsearchClientReady(meta metav1.ObjectMeta) GomegaAsyncAssertion
- func (f *Framework) EventuallyElasticsearchIndicesCount(client es.ESClient) GomegaAsyncAssertion
- func (f *Framework) EventuallyElasticsearchPhase(meta metav1.ObjectMeta) GomegaAsyncAssertion
- func (f *Framework) EventuallyElasticsearchRunning(meta metav1.ObjectMeta) GomegaAsyncAssertion
- func (f *Framework) EventuallyPVCCount(meta metav1.ObjectMeta) GomegaAsyncAssertion
- func (f *Framework) EventuallyRestoreSessionPhase(meta metav1.ObjectMeta) GomegaAsyncAssertion
- func (f *Framework) EventuallySnapshotInRepository(meta metav1.ObjectMeta) GomegaAsyncAssertion
- func (f *Framework) EventuallyWipedOut(meta metav1.ObjectMeta) GomegaAsyncAssertion
- func (f *Framework) EvictPodsFromStatefulSet(meta metav1.ObjectMeta) error
- func (f *Framework) FoundStashCRDs() bool
- func (f *Framework) GetClientPodName(elasticsearch *api.Elasticsearch) string
- func (f *Framework) GetElasticClient(meta metav1.ObjectMeta) (es.ESClient, error)
- func (f *Framework) GetElasticsearch(meta metav1.ObjectMeta) (*api.Elasticsearch, error)
- func (f *Framework) IndicesCount(obj *api.Elasticsearch, indicesCount int) int
- func (f *Framework) Invoke() *Invocation
- func (f *Framework) Namespace() string
- func (f *Framework) PatchElasticsearch(meta metav1.ObjectMeta, transform func(*api.Elasticsearch) *api.Elasticsearch) (*api.Elasticsearch, error)
- func (f *Framework) PauseBackupConfiguration(meta metav1.ObjectMeta) error
- func (f *Framework) PrintDebugHelpers()
- func (f *Framework) Repository(dbMeta metav1.ObjectMeta) *stashV1alpha1.Repository
- func (f *Framework) UpdateSecret(meta metav1.ObjectMeta, transformer func(core.Secret) core.Secret) error
- type Invocation
- func (i *Invocation) BackupConfiguration(dbMeta metav1.ObjectMeta, repo *stashV1alpha1.Repository) *stashv1beta1.BackupConfiguration
- func (i *Invocation) CombinedElasticsearch() *api.Elasticsearch
- func (f *Invocation) CreateConfigMap(obj *core.ConfigMap) error
- func (f *Invocation) CreatePersistentVolumeClaim(pvc *core.PersistentVolumeClaim) error
- func (i *Invocation) DedicatedElasticsearch() *api.Elasticsearch
- func (f *Invocation) DeleteConfigMap(meta metav1.ObjectMeta) error
- func (f *Invocation) DeletePersistentVolumeClaim(meta metav1.ObjectMeta) error
- func (fi *Invocation) ExtClient() cs.Interface
- func (f *Invocation) GetClientConfig(elasticsearch *v1alpha12.Elasticsearch) string
- func (f *Invocation) GetCommonConfig(elasticsearch *v1alpha12.Elasticsearch) string
- func (f *Invocation) GetCustomConfig() *core.ConfigMap
- func (f *Invocation) GetDataConfig(elasticsearch *v1alpha12.Elasticsearch) string
- func (f *Invocation) GetMasterConfig(elasticsearch *v1alpha12.Elasticsearch) string
- func (f *Invocation) GetPersistentVolumeClaim() *core.PersistentVolumeClaim
- func (f *Invocation) IsUsingProvidedConfig(elasticsearch *v1alpha12.Elasticsearch, nodeInfo []es.NodeInfo) bool
- func (fi *Invocation) KubeClient() kubernetes.Interface
- func (i *Invocation) PatchSecretForRestic(secret *core.Secret) *core.Secret
- func (fi *Invocation) RestConfig() *rest.Config
- func (i *Invocation) RestoreSession(dbMeta metav1.ObjectMeta, repo *stashV1alpha1.Repository) *stashv1beta1.RestoreSession
- func (i *Invocation) RoleBinding(saName string, roleName string) *rbac.RoleBinding
- func (i *Invocation) RoleForElasticsearch(meta metav1.ObjectMeta) *rbac.Role
- func (i *Invocation) RoleForSnapshot(meta metav1.ObjectMeta) *rbac.Role
- func (i *Invocation) SecretForAzureBackend() *core.Secret
- func (i *Invocation) SecretForDatabaseAuthentication(es *api.Elasticsearch, mangedByKubeDB bool) *core.Secret
- func (i *Invocation) SecretForGCSBackend() *core.Secret
- func (i *Invocation) SecretForLocalBackend() *core.Secret
- func (i *Invocation) SecretForS3Backend() *core.Secret
- func (i *Invocation) SecretForSwiftBackend() *core.Secret
- func (i *Invocation) ServiceAccount() *core.ServiceAccount
Constants ¶
const ( GET = "get" LIST = "list" PATCH = "patch" CREATE = "create" UPDATE = "update" USE = "use" POLICY = "policy" Role = "Role" ServiceAccount = "ServiceAccount" )
Variables ¶
var ( JobPvcStorageSize = "2Gi" DBPvcStorageSize = "1Gi" )
var ( DockerRegistry = "kubedbci" DBCatalogName = "7.3.2" )
var ( CustomSecretSuffix = "custom-secret" CustomUsername = "username1234567890" CustomPassword = "password0987654321" AdminUser = "admin" KeyAdminUserName = "ADMIN_USERNAME" KeyAdminPassword = "ADMIN_PASSWORD" ReadAllUser = "readall" KeyReadAllUserName = "READALL_USERNAME" KeyReadAllPassword = "READALL_PASSWORD" ExporterSecretPath = "/var/run/secrets/kubedb.com/" )
Functions ¶
This section is empty.
Types ¶
type Framework ¶
type Framework struct { Tunnel *portforward.Tunnel StorageClass string // contains filtered or unexported fields }
func (*Framework) CheckAppBindingSpec ¶
func (f *Framework) CheckAppBindingSpec(meta metav1.ObjectMeta) error
func (*Framework) CleanElasticsearch ¶
func (f *Framework) CleanElasticsearch()
func (*Framework) CreateBackupConfiguration ¶
func (f *Framework) CreateBackupConfiguration(backupCfg *stashv1beta1.BackupConfiguration) error
func (*Framework) CreateElasticsearch ¶
func (f *Framework) CreateElasticsearch(obj *api.Elasticsearch) error
func (*Framework) CreateNamespace ¶
func (*Framework) CreateRepository ¶
func (f *Framework) CreateRepository(repo *stashV1alpha1.Repository) error
func (*Framework) CreateRestoreSession ¶
func (f *Framework) CreateRestoreSession(restoreSession *stashv1beta1.RestoreSession) error
func (*Framework) CreateRoleBinding ¶
func (f *Framework) CreateRoleBinding(obj *rbac.RoleBinding) error
func (*Framework) CreateSecret ¶
TODO: Add more methods for Swift, Backblaze B2, Rest server backend.
func (*Framework) CreateServiceAccount ¶
func (f *Framework) CreateServiceAccount(obj *core.ServiceAccount) error
func (*Framework) DeleteBackupConfiguration ¶
func (f *Framework) DeleteBackupConfiguration(meta metav1.ObjectMeta) error
func (*Framework) DeleteElasticsearch ¶
func (f *Framework) DeleteElasticsearch(meta metav1.ObjectMeta) error
func (*Framework) DeleteNamespace ¶
func (*Framework) DeleteRepository ¶
func (f *Framework) DeleteRepository(meta metav1.ObjectMeta) error
func (Framework) DeleteRestoreSession ¶
func (f Framework) DeleteRestoreSession(meta metav1.ObjectMeta) error
func (*Framework) DeleteSecret ¶
func (f *Framework) DeleteSecret(meta metav1.ObjectMeta) error
func (*Framework) EventuallyAppBinding ¶
func (f *Framework) EventuallyAppBinding(meta metav1.ObjectMeta) GomegaAsyncAssertion
func (*Framework) EventuallyCRD ¶
func (f *Framework) EventuallyCRD() GomegaAsyncAssertion
func (*Framework) EventuallyDBSecretCount ¶
func (f *Framework) EventuallyDBSecretCount(meta metav1.ObjectMeta) GomegaAsyncAssertion
func (*Framework) EventuallyElasticsearch ¶
func (f *Framework) EventuallyElasticsearch(meta metav1.ObjectMeta) GomegaAsyncAssertion
func (*Framework) EventuallyElasticsearchClientReady ¶
func (f *Framework) EventuallyElasticsearchClientReady(meta metav1.ObjectMeta) GomegaAsyncAssertion
func (*Framework) EventuallyElasticsearchIndicesCount ¶
func (*Framework) EventuallyElasticsearchPhase ¶
func (f *Framework) EventuallyElasticsearchPhase(meta metav1.ObjectMeta) GomegaAsyncAssertion
func (*Framework) EventuallyElasticsearchRunning ¶
func (f *Framework) EventuallyElasticsearchRunning(meta metav1.ObjectMeta) GomegaAsyncAssertion
func (*Framework) EventuallyPVCCount ¶
func (f *Framework) EventuallyPVCCount(meta metav1.ObjectMeta) GomegaAsyncAssertion
func (*Framework) EventuallyRestoreSessionPhase ¶
func (f *Framework) EventuallyRestoreSessionPhase(meta metav1.ObjectMeta) GomegaAsyncAssertion
func (*Framework) EventuallySnapshotInRepository ¶
func (f *Framework) EventuallySnapshotInRepository(meta metav1.ObjectMeta) GomegaAsyncAssertion
func (*Framework) EventuallyWipedOut ¶
func (f *Framework) EventuallyWipedOut(meta metav1.ObjectMeta) GomegaAsyncAssertion
func (*Framework) EvictPodsFromStatefulSet ¶
func (f *Framework) EvictPodsFromStatefulSet(meta metav1.ObjectMeta) error
func (*Framework) FoundStashCRDs ¶
func (*Framework) GetClientPodName ¶
func (f *Framework) GetClientPodName(elasticsearch *api.Elasticsearch) string
func (*Framework) GetElasticClient ¶
func (*Framework) GetElasticsearch ¶
func (f *Framework) GetElasticsearch(meta metav1.ObjectMeta) (*api.Elasticsearch, error)
func (*Framework) IndicesCount ¶
func (f *Framework) IndicesCount(obj *api.Elasticsearch, indicesCount int) int
func (*Framework) Invoke ¶
func (f *Framework) Invoke() *Invocation
func (*Framework) PatchElasticsearch ¶
func (f *Framework) PatchElasticsearch(meta metav1.ObjectMeta, transform func(*api.Elasticsearch) *api.Elasticsearch) (*api.Elasticsearch, error)
func (*Framework) PauseBackupConfiguration ¶
func (f *Framework) PauseBackupConfiguration(meta metav1.ObjectMeta) error
func (*Framework) PrintDebugHelpers ¶
func (f *Framework) PrintDebugHelpers()
func (*Framework) Repository ¶
func (f *Framework) Repository(dbMeta metav1.ObjectMeta) *stashV1alpha1.Repository
func (*Framework) UpdateSecret ¶
type Invocation ¶
type Invocation struct { *Framework // contains filtered or unexported fields }
func (*Invocation) BackupConfiguration ¶
func (i *Invocation) BackupConfiguration(dbMeta metav1.ObjectMeta, repo *stashV1alpha1.Repository) *stashv1beta1.BackupConfiguration
func (*Invocation) CombinedElasticsearch ¶
func (i *Invocation) CombinedElasticsearch() *api.Elasticsearch
func (*Invocation) CreateConfigMap ¶
func (f *Invocation) CreateConfigMap(obj *core.ConfigMap) error
func (*Invocation) CreatePersistentVolumeClaim ¶
func (f *Invocation) CreatePersistentVolumeClaim(pvc *core.PersistentVolumeClaim) error
func (*Invocation) DedicatedElasticsearch ¶
func (i *Invocation) DedicatedElasticsearch() *api.Elasticsearch
func (*Invocation) DeleteConfigMap ¶
func (f *Invocation) DeleteConfigMap(meta metav1.ObjectMeta) error
func (*Invocation) DeletePersistentVolumeClaim ¶
func (f *Invocation) DeletePersistentVolumeClaim(meta metav1.ObjectMeta) error
func (*Invocation) ExtClient ¶
func (fi *Invocation) ExtClient() cs.Interface
func (*Invocation) GetClientConfig ¶
func (f *Invocation) GetClientConfig(elasticsearch *v1alpha12.Elasticsearch) string
func (*Invocation) GetCommonConfig ¶
func (f *Invocation) GetCommonConfig(elasticsearch *v1alpha12.Elasticsearch) string
func (*Invocation) GetCustomConfig ¶
func (f *Invocation) GetCustomConfig() *core.ConfigMap
func (*Invocation) GetDataConfig ¶
func (f *Invocation) GetDataConfig(elasticsearch *v1alpha12.Elasticsearch) string
func (*Invocation) GetMasterConfig ¶
func (f *Invocation) GetMasterConfig(elasticsearch *v1alpha12.Elasticsearch) string
func (*Invocation) GetPersistentVolumeClaim ¶
func (f *Invocation) GetPersistentVolumeClaim() *core.PersistentVolumeClaim
func (*Invocation) IsUsingProvidedConfig ¶
func (f *Invocation) IsUsingProvidedConfig(elasticsearch *v1alpha12.Elasticsearch, nodeInfo []es.NodeInfo) bool
func (*Invocation) KubeClient ¶
func (fi *Invocation) KubeClient() kubernetes.Interface
func (*Invocation) PatchSecretForRestic ¶
func (i *Invocation) PatchSecretForRestic(secret *core.Secret) *core.Secret
func (*Invocation) RestConfig ¶
func (fi *Invocation) RestConfig() *rest.Config
func (*Invocation) RestoreSession ¶
func (i *Invocation) RestoreSession(dbMeta metav1.ObjectMeta, repo *stashV1alpha1.Repository) *stashv1beta1.RestoreSession
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) SecretForAzureBackend ¶
func (i *Invocation) SecretForAzureBackend() *core.Secret
func (*Invocation) SecretForDatabaseAuthentication ¶
func (i *Invocation) SecretForDatabaseAuthentication(es *api.Elasticsearch, mangedByKubeDB bool) *core.Secret
func (*Invocation) SecretForGCSBackend ¶
func (i *Invocation) SecretForGCSBackend() *core.Secret
func (*Invocation) SecretForLocalBackend ¶
func (i *Invocation) SecretForLocalBackend() *core.Secret
func (*Invocation) SecretForS3Backend ¶
func (i *Invocation) SecretForS3Backend() *core.Secret
func (*Invocation) SecretForSwiftBackend ¶
func (i *Invocation) SecretForSwiftBackend() *core.Secret
func (*Invocation) ServiceAccount ¶
func (i *Invocation) ServiceAccount() *core.ServiceAccount