Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

framework

package

Go to main page

Versions in this module

v0

v0.13.0-beta.0

May 22, 2020

v0.12.0

May 18, 2020

v0.12.0-rc.3

Apr 25, 2020

v0.12.0-rc.2

Jan 10, 2020

v0.12.0-rc.1

Jan 10, 2020

v0.12.0-rc.0

Jan 10, 2020

v0.11.0

Sep 10, 2019

Changes in this version

+ const ContainerOperator

+ const DefaultEventuallyPollingInterval

+ const DefaultEventuallyTimeout

+ const MINIO_ACCESS_KEY_ID

+ const MINIO_CERTS_MOUNTPATH

+ const MINIO_PRIVATE_KEY_NAME

+ const MINIO_PUBLIC_CRT_NAME

+ const MINIO_SECRET_ACCESS_KEY

+ const MaxRetry

+ const NoRetry

+ const OperatorConfig

+ const OperatorName

+ const OperatorNamespace

+ const StandardStorageClass

+ const TEST_LOCAL_BACKUP_DIR

+ const TestSourceDataMountPath

+ const TestSourceDataVolumeName

+ var KubedTestConfigFileDir = filepath.Join(runtime.GOPath(), "src", "github.com", "appscode", "kubed", "test", "e2e", ...)

+ func APIServerClusterConfig() api.ClusterConfig

+ func ConfigSyncClusterConfig() api.ClusterConfig

+ func DecoratorCleaned(meta metav1.ObjectMeta) error

+ func DeploymentSnapshotSanitized(dpl *apps.Deployment) error

+ func NewLocalBackend(dir string) *store.Backend

+ func NewMinioBackend(bucket, prefix, endpoint, secretName string) *store.Backend

+ func ObjectMetaCleaned(meta metav1.ObjectMeta) error

+ func PodSpecCleaned(spec v1.PodSpec) error

+ func ReadYaml(fileName string) (*apps.Deployment, error)

+ func RecycleBinClusterConfig() api.ClusterConfig

+ func SnapshotterClusterConfig(backend *store.Backend) api.ClusterConfig

+ func Untar(dst string, r io.Reader) error

+ func WebhookReceiver() []api.Receiver

+ type Framework struct

+ CertStore *certstore.CertStore

+ ClientConfig *rest.Config

+ KAClient ka.Interface

+ KubeClient clientset.Interface

+ KubeConfigPath string

+ KubeDBClient kdbcs.Interface

+ KubedClient kcs.Interface

+ Mutex sync.Mutex

+ PromClient pcs.Interface

+ SearchlightClient srch_cs.Interface

+ SelfHostedOperator bool

+ StashClient scs.Interface

+ VoyagerClient vcs.Interface

+ func New(config *rest.Config) *Framework

+ func (f *Framework) CreateDeployment(obj apps.Deployment) (*apps.Deployment, error)

+ func (f *Framework) CreateNamespace(ns *core.Namespace) error

+ func (f *Framework) CreateSecret(obj *core.Secret) (*core.Secret, error)

+ func (f *Framework) DeleteClusterRole(meta metav1.ObjectMeta) error

+ func (f *Framework) DeleteClusterRoleBinding(meta metav1.ObjectMeta) error

+ func (f *Framework) DeleteDeployment(meta metav1.ObjectMeta) error

+ func (f *Framework) DeleteNamespace(name string) error

+ func (f *Framework) DeletePVCForMinioServer(meta metav1.ObjectMeta) error

+ func (f *Framework) DeleteSecret(meta metav1.ObjectMeta) error

+ func (f *Framework) DeleteSecretForMinioServer(meta metav1.ObjectMeta) error

+ func (f *Framework) DeleteServiceForMinioServer(meta metav1.ObjectMeta) error

+ func (f *Framework) EnsureCreatedCRDs() error

+ func (f *Framework) EnsureNamespace() error

+ func (f *Framework) EventuallyAPIServerReady() GomegaAsyncAssertion

+ func (f *Framework) EventuallyNamespaceDeleted(ns string) GomegaAsyncAssertion

+ func (f *Framework) Invoke() *Invocation

+ func (f *Framework) KubeConfigSecret(config *api.ClusterConfig, meta metav1.ObjectMeta) (*core.Secret, error)

+ func (f *Framework) Namespace() string

+ func (f *Framework) NewKubedOptions() *server.KubedOptions

+ func (f *Framework) NewKubedServer() (*srvr.KubedServer, error)

+ func (f *Framework) NewKubedServerOptions() *options.RecommendedOptions

+ func (f *Framework) NewNamespace(name string) *core.Namespace

+ func (f *Framework) RunKubed(stopCh chan struct{}, clusterConfig api.ClusterConfig) error

+ type Invocation struct

+ func (f *Invocation) APIService(service *core.Service) *apireg.APIService

+ func (f *Invocation) App() string

+ func (f *Invocation) BusyboxContainerWithBadCommand() core.Container

+ func (f *Invocation) CreateBucketIfNotExist(backend store.Backend) error

+ func (f *Invocation) CreateConfigMap(configMap *core.ConfigMap) (*core.ConfigMap, error)

+ func (f *Invocation) CreatePod(pod *core.Pod) (*core.Pod, error)

+ func (f *Invocation) DeleteAPIService()

+ func (f *Invocation) DeleteAllConfigmaps()

+ func (f *Invocation) DeleteAllSecrets()

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

+ func (f *Invocation) DeleteNamespaceForContext(kubeConfigPath string, context string)

+ func (f *Invocation) DeletePersistentVolumeClaim(meta metav1.ObjectMeta) error

+ func (f *Invocation) DeletePod(meta metav1.ObjectMeta) error

+ func (f *Invocation) EnsureNamespaceForContext(kubeConfigPath string, context string)

+ func (f *Invocation) EventForwarderClusterConfig() api.ClusterConfig

+ func (f *Invocation) EventuallyBackupSnapshot(backend store.Backend) GomegaAsyncAssertion

+ func (f *Invocation) EventuallyConfigMapNotSynced(source *core.ConfigMap) GomegaAsyncAssertion

+ func (f *Invocation) EventuallyConfigMapSynced(source *core.ConfigMap) GomegaAsyncAssertion

+ func (f *Invocation) EventuallyConfigMapSyncedToNamespace(source *core.ConfigMap, namespace string) GomegaAsyncAssertion

+ func (f *Invocation) EventuallyNotifiedToWebhookServer(requests *[]*http.Request, expetedSubstr string) GomegaAsyncAssertion

+ func (f *Invocation) EventuallyNumOfConfigmaps(namespace string) GomegaAsyncAssertion

+ func (f *Invocation) EventuallyNumOfConfigmapsForClient(client kubernetes.Interface, namespace string) GomegaAsyncAssertion

+ func (f *Invocation) EventuallyNumOfConfigmapsForContext(kubeConfigPath string, context string) GomegaAsyncAssertion

+ func (f *Invocation) EventuallyNumOfSecrets(namespace string) GomegaAsyncAssertion

+ func (f *Invocation) EventuallyNumOfSecretsForClient(client kubernetes.Interface, namespace string) GomegaAsyncAssertion

+ func (f *Invocation) EventuallyNumOfSecretsForContext(kubeConfigPath string, context string) GomegaAsyncAssertion

+ func (f *Invocation) EventuallyReverseIndex(path string) GomegaAsyncAssertion

+ func (f *Invocation) EventuallySecretNotSynced(source *core.Secret) GomegaAsyncAssertion

+ func (f *Invocation) EventuallySecretSynced(source *core.Secret) GomegaAsyncAssertion

+ func (f *Invocation) EventuallySecretSyncedToNamespace(source *core.Secret, namespace string) GomegaAsyncAssertion

+ func (f *Invocation) EventuallySyncedConfigMapsDeleted(source *core.ConfigMap) GomegaAsyncAssertion

+ func (f *Invocation) EventuallySyncedConfigMapsUpdated(source *core.ConfigMap) GomegaAsyncAssertion

+ func (f *Invocation) EventuallySyncedSecretsDeleted(source *core.Secret) GomegaAsyncAssertion

+ func (f *Invocation) EventuallySyncedSecretsUpdated(source *core.Secret) GomegaAsyncAssertion

+ func (f *Invocation) GetItems(backend store.Backend) []stow.Item

+ func (f *Invocation) GetLocation(backend store.Backend) (stow.Location, error)

+ func (f *Invocation) ListSnapshotInsideOperatorPod() string

+ func (f *Invocation) LocalEndPointForWebhook(service *core.Service) *core.Endpoints

+ func (f *Invocation) LocalEndPoints(service *core.Service) *core.Endpoints

+ func (f *Invocation) MakeDirInsideOperatorPod(dir string) error

+ func (f *Invocation) NewConfigMap() *core.ConfigMap

+ func (f *Invocation) NewNamespaceWithLabel() *core.Namespace

+ func (f *Invocation) NewPersistentVolumeClaim() *core.PersistentVolumeClaim

+ func (f *Invocation) NewPod() *core.Pod

+ func (f *Invocation) NewSecret() *core.Secret

+ func (f *Invocation) NumberOfNameSpace() int

+ func (f *Invocation) ReadConfigMapFromRecycleBin(recycleBinLocation string, cm *core.ConfigMap) (*core.ConfigMap, error)

+ func (f *Invocation) RegisterAPIService() (err error)

+ func (f *Invocation) RestartKubedOperator(config *api.ClusterConfig) error

+ func (f *Invocation) RunWebhookServer(stopCh <-chan os.Signal, requests *[]*http.Request)

+ func (f *Invocation) SecretForMinioBackend(includeCert bool) core.Secret

+ func (f *Invocation) ServiceForAPIService() *core.Service

+ func (f *Invocation) ServiceForWebhook() *core.Service

+ func (f *Invocation) WaitUntilPodTerminated(meta metav1.ObjectMeta) error

+ func (f *Invocation) WaitUntilSecretCreated(meta metav1.ObjectMeta) error

+ func (f *Invocation) WaitUntilSecretDeleted(meta metav1.ObjectMeta) error

+ func (fi *Invocation) CreateDeploymentForMinioServer(obj apps.Deployment) error

+ func (fi *Invocation) CreateMinioServer(tls bool, ips []net.IP) (string, error)

+ func (fi *Invocation) CreatePersistentVolumeClaim(obj core.PersistentVolumeClaim) error

+ func (fi *Invocation) CreateServiceForMinioServer(obj core.Service) (*core.Service, error)

+ func (fi *Invocation) DeleteDeploymentForMinioServer(meta metav1.ObjectMeta) error

+ func (fi *Invocation) DeleteEndpoints(meta metav1.ObjectMeta) error

+ func (fi *Invocation) DeleteMinioServer()

+ func (fi *Invocation) DeleteService(meta metav1.ObjectMeta) error

+ func (fi *Invocation) Deployment() *apps.Deployment

+ func (fi *Invocation) DeploymentForMinioServer() apps.Deployment

+ func (fi *Invocation) MinioServerSANs(ips []net.IP) cert.AltNames

+ func (fi *Invocation) MinioServiceAddres() string

+ func (fi *Invocation) OperatorPod() (*core.Pod, error)

+ func (fi *Invocation) PVCForMinioServer() core.PersistentVolumeClaim

+ func (fi *Invocation) PodTemplate() core.PodTemplateSpec

+ func (fi *Invocation) RemoveFromOperatorPod(dir string) error

+ func (fi *Invocation) RemoveSecretVolumeMount(containers []core.Container) []core.Container

+ func (fi *Invocation) SecretForMinioServer(ips []net.IP) core.Secret

+ func (fi *Invocation) SecretForWebhookNotifier() *core.Secret

+ func (fi *Invocation) ServiceForMinioServer() core.Service

+ func (fi *Invocation) WaitUntilDeploymentReady(meta metav1.ObjectMeta) error

+ func (fi *Invocation) WaitUntilDeploymentTerminated(meta metav1.ObjectMeta) error