utils

package
v0.0.0-...-398e186 Latest Latest
Warning

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

Go to latest
Published: Jun 9, 2023 License: BSD-3-Clause, Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL