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.1.4

Nov 5, 2020

v0.1.3

Jul 1, 2019

v0.1.2

Jun 18, 2019

v0.1.1

May 16, 2019

v0.1.0

May 7, 2019

Changes in this version

+ var CustomResourceDefinitionTypeMeta = metav1.TypeMeta

+ var SparkTestImage = ""

+ var SparkTestNamespace = ""

+ var SparkTestServiceAccount = ""

+ func CreateClusterRole(kubeClient kubernetes.Interface, relativePath string) error

+ func CreateClusterRoleBinding(kubeClient kubernetes.Interface, relativePath string) (finalizerFn, error)

+ func CreateConfigMap(kubeClient kubernetes.Interface, name string, namespace string) (*v1.ConfigMap, error)

+ func CreateDeployment(kubeClient kubernetes.Interface, namespace string, d *appsv1.Deployment) error

+ func CreateJob(kubeClient kubernetes.Interface, namespace string, job *batchv1.Job) error

+ func CreateNamespace(kubeClient kubernetes.Interface, name string) (*v1.Namespace, error)

+ func CreateRole(kubeClient kubernetes.Interface, ns string, relativePath string) error

+ func CreateRoleBinding(kubeClient kubernetes.Interface, ns string, relativePath string) (finalizerFn, error)

+ func CreateService(kubeClient kubernetes.Interface, ns string, relativePath string) (finalizerFn, error)

+ func CreateServiceAccount(kubeClient kubernetes.Interface, namespace string, relativPath string) (finalizerFn, error)

+ func CreateSparkApplication(crdclientset crdclientset.Interface, namespace string, ...) error

+ func DeleteClusterRole(kubeClient kubernetes.Interface, relativePath string) error

+ func DeleteClusterRoleBinding(kubeClient kubernetes.Interface, relativePath string) error

+ func DeleteConfigMap(kubeClient kubernetes.Interface, name string, namespace string) error

+ func DeleteDeployment(kubeClient kubernetes.Interface, namespace, name string) error

+ func DeleteJob(kubeClient kubernetes.Interface, namespace, name string) error

+ func DeleteNamespace(kubeClient kubernetes.Interface, name string) error

+ func DeleteRole(kubeClient kubernetes.Interface, ns string, relativePath string) error

+ func DeleteRoleBinding(kubeClient kubernetes.Interface, ns string, relativePath string) error

+ func DeleteService(kubeClient kubernetes.Interface, name string, namespace string) error

+ func DeleteServiceAccount(kubeClient kubernetes.Interface, namespace string, relativPath string) error

+ func DeleteSparkApplication(crdclientset crdclientset.Interface, namespace, name string) error

+ func GetLogs(kubeClient kubernetes.Interface, namespace string, ...) (string, error)

+ func GetSparkApplication(crdclientset crdclientset.Interface, namespace, name string) (*v1beta1.SparkApplication, error)

+ func MakeDeployment(pathToYaml string) (*appsv1.Deployment, error)

+ func MakeJob(pathToYaml string) (*batchv1.Job, error)

+ func MakeSparkApplicationFromYaml(pathToYaml string) (*v1beta1.SparkApplication, error)

+ func PathToOSFile(relativPath string) (*os.File, error)

+ func PodRunningAndReady(pod v1.Pod) (bool, error)

+ func ProxyGetPod(kubeClient kubernetes.Interface, namespace string, podName string, port string, ...) *rest.Request

+ func UpdateSparkApplication(crdclientset crdclientset.Interface, namespace string, ...) error

+ func WaitForHTTPSuccessStatusCode(timeout time.Duration, url string) error

+ func WaitForPodsReady(kubeClient kubernetes.Interface, namespace string, timeout time.Duration, ...) error

+ func WaitForPodsRunImage(kubeClient kubernetes.Interface, namespace string, expectedReplicas int, ...) error

+ func WaitForServiceReady(kubeClient kubernetes.Interface, namespace string, serviceName string) error

+ func WaitUntilDeploymentGone(kubeClient kubernetes.Interface, namespace, name string, timeout time.Duration) error

+ func WaitUntilJobCompleted(kubeClient kubernetes.Interface, namespace, name string, timeout time.Duration) error

+ type Framework struct

+ DefaultTimeout time.Duration

+ KubeClient kubernetes.Interface

+ MasterHost string

+ Namespace *v1.Namespace

+ OperatorPod *v1.Pod

+ SparkApplicationClient crdclientset.Interface

+ func New(ns, sparkNs, kubeconfig, opImage string, opImagePullPolicy string) (*Framework, error)

+ func (f *Framework) NewTestCtx(t *testing.T) TestCtx

+ func (f *Framework) Setup(sparkNs, opImage string, opImagePullPolicy string) error

+ func (f *Framework) Teardown() error

+ type TestCtx struct

+ ID string

+ func (ctx *TestCtx) AddFinalizerFn(fn finalizerFn)

+ func (ctx *TestCtx) Cleanup(t *testing.T)

+ func (ctx *TestCtx) CreateNamespace(t *testing.T, kubeClient kubernetes.Interface) string

+ func (ctx *TestCtx) GetObjID() string