flink

package
v1.5.0 Latest Latest
Warning

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

Go to latest
Published: Jan 6, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Flink struct {
	// contains filtered or unexported fields
}

Flink API, please refer: https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/rest_api.html

func (*Flink) Cancel

func (f *Flink) Cancel(ctx context.Context, spec interface{}) (interface{}, error)

func (*Flink) CapacityInfo

func (f *Flink) CapacityInfo() apistructs.CapacityInfoData

func (*Flink) CleanUpBeforeDelete

func (*Flink) CleanUpBeforeDelete()

func (*Flink) Create

func (f *Flink) Create(ctx context.Context, specObj interface{}) (interface{}, error)

func (*Flink) Destroy

func (f *Flink) Destroy(ctx context.Context, specObj interface{}) error

Flink does not provide a job deletion API, and temporarily uses the cancellation API used on the Flink UI

func (*Flink) Inspect

func (f *Flink) Inspect(ctx context.Context, specObj interface{}) (interface{}, error)

func (*Flink) JobVolumeCreate

func (*Flink) JobVolumeCreate(ctx context.Context, spec interface{}) (string, error)

func (*Flink) KillPod

func (*Flink) KillPod(podname string) error

func (*Flink) Kind

func (f *Flink) Kind() executortypes.Kind

func (*Flink) Name

func (f *Flink) Name() executortypes.Name

func (*Flink) Precheck

func (f *Flink) Precheck(ctx context.Context, specObj interface{}) (apistructs.ServiceGroupPrecheckData, error)

func (*Flink) Remove

func (f *Flink) Remove(ctx context.Context, specObj interface{}) error

func (*Flink) ResourceInfo

func (f *Flink) ResourceInfo(brief bool) (apistructs.ClusterResourceInfoData, error)

func (*Flink) Scale added in v1.0.1

func (f *Flink) Scale(ctx context.Context, spec interface{}) (interface{}, error)

func (*Flink) SetNodeLabels

func (f *Flink) SetNodeLabels(setting executortypes.NodeLabelSetting, hosts []string, labels map[string]string) error

func (*Flink) Status

func (f *Flink) Status(ctx context.Context, specObj interface{}) (apistructs.StatusDesc, error)

func (*Flink) Update

func (f *Flink) Update(ctx context.Context, specObj interface{}) (interface{}, error)

type FlinkCreateRequest

type FlinkCreateRequest struct {
	EntryClass  string `json:"entryClass"`
	ProgramArgs string `json:"programArgs"`
}

type FlinkCreateResponse

type FlinkCreateResponse struct {
	JobId string `json:"jobid"`
}

type FlinkGetResponse

type FlinkGetResponse struct {
	Name        string `json:"name"`
	State       string `json:"state"`
	StartTime   int64  `json:"start-time"`
	CurrentTime int64  `json:"now"`
	EndTime     int64  `json:"end-time"`
}

Jump to

Keyboard shortcuts

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