utils

Documentation

Index

• type TestUtil
  • func New(namespaceName string, kubeconfig string, image string, checkpointDir string) (*TestUtil, error)
  • func (f *TestUtil) Cleanup()
  • func (f *TestUtil) CreateCRD() error
  • func (f *TestUtil) CreateFlinkApplication(application *flinkapp.FlinkApplication) error
  • func (f *TestUtil) CreateOperator() error
  • func (f *TestUtil) FlinkAPIGet(app *flinkapp.FlinkApplication, endpoint string) (interface{}, error)
  • func (f *TestUtil) FlinkApps() client.FlinkApplicationInterface
  • func (f *TestUtil) GetFlinkApplication(name string) (*flinkapp.FlinkApplication, error)
  • func (f *TestUtil) GetJobManagerPod() (string, error)
  • func (f *TestUtil) GetLogs(podName string, lines *int64) error
  • func (f *TestUtil) GetTaskManagerPods() ([]string, error)
  • func (f *TestUtil) ReadFlinkApplication(path string) (*flinkapp.FlinkApplication, error)
  • func (f *TestUtil) TailOperatorLogs() error
  • func (f *TestUtil) Update(name string, updateFn func(app *flinkapp.FlinkApplication)) (*flinkapp.FlinkApplication, error)
  • func (f *TestUtil) WaitForAllTasksRunning(name string) error
  • func (f *TestUtil) WaitForPhase(name string, phase flinkapp.FlinkApplicationPhase, ...) error

Types

type TestUtil

type TestUtil struct {
	KubeClient             kubernetes.Interface
	FlinkApplicationClient clientset.Interface
	APIExtensionsClient    apiextensionsClientset.Interface
	Namespace              *v1.Namespace
	Image                  string
	CheckpointDir          string
}

func New

func New(namespaceName string, kubeconfig string, image string, checkpointDir string) (*TestUtil, error)

func (*TestUtil) Cleanup

func (f *TestUtil) Cleanup()

func (*TestUtil) CreateCRD

func (f *TestUtil) CreateCRD() error

func (*TestUtil) CreateFlinkApplication

func (f *TestUtil) CreateFlinkApplication(application *flinkapp.FlinkApplication) error

func (*TestUtil) CreateOperator

func (f *TestUtil) CreateOperator() error

func (*TestUtil) FlinkAPIGet

func (f *TestUtil) FlinkAPIGet(app *flinkapp.FlinkApplication, endpoint string) (interface{}, error)

func (*TestUtil) FlinkApps

func (f *TestUtil) FlinkApps() client.FlinkApplicationInterface

func (*TestUtil) GetFlinkApplication

func (f *TestUtil) GetFlinkApplication(name string) (*flinkapp.FlinkApplication, error)

func (*TestUtil) GetJobManagerPod

func (f *TestUtil) GetJobManagerPod() (string, error)

func (*TestUtil) GetLogs

func (f *TestUtil) GetLogs(podName string, lines *int64) error

func (*TestUtil) GetTaskManagerPods

func (f *TestUtil) GetTaskManagerPods() ([]string, error)

func (*TestUtil) ReadFlinkApplication

func (f *TestUtil) ReadFlinkApplication(path string) (*flinkapp.FlinkApplication, error)

func (*TestUtil) TailOperatorLogs

func (f *TestUtil) TailOperatorLogs() error

func (*TestUtil) Update

func (f *TestUtil) Update(name string, updateFn func(app *flinkapp.FlinkApplication)) (*flinkapp.FlinkApplication, error)

func (*TestUtil) WaitForAllTasksRunning

func (f *TestUtil) WaitForAllTasksRunning(name string) error

func (*TestUtil) WaitForPhase

func (f *TestUtil) WaitForPhase(name string, phase flinkapp.FlinkApplicationPhase, failurePhases ...flinkapp.FlinkApplicationPhase) error