flink

Documentation

Index

• type Flink
  • func (f *Flink) Cancel(ctx context.Context, spec interface{}) (interface{}, error)
  • func (f *Flink) CapacityInfo() apistructs.CapacityInfoData
  • func (*Flink) CleanUpBeforeDelete()
  • func (f *Flink) Create(ctx context.Context, specObj interface{}) (interface{}, error)
  • func (f *Flink) Destroy(ctx context.Context, specObj interface{}) error
  • func (f *Flink) Inspect(ctx context.Context, specObj interface{}) (interface{}, error)
  • func (*Flink) JobVolumeCreate(ctx context.Context, spec interface{}) (string, error)
  • func (*Flink) KillPod(podname string) error
  • func (f *Flink) Kind() executortypes.Kind
  • func (f *Flink) Name() executortypes.Name
  • func (f *Flink) Precheck(ctx context.Context, specObj interface{}) (apistructs.ServiceGroupPrecheckData, error)
  • func (f *Flink) Remove(ctx context.Context, specObj interface{}) error
  • func (f *Flink) ResourceInfo(brief bool) (apistructs.ClusterResourceInfoData, error)
  • func (f *Flink) SetNodeLabels(setting executortypes.NodeLabelSetting, hosts []string, ...) error
  • func (f *Flink) Status(ctx context.Context, specObj interface{}) (apistructs.StatusDesc, error)
  • func (f *Flink) Update(ctx context.Context, specObj interface{}) (interface{}, error)
• type FlinkCreateRequest
• type FlinkCreateResponse
• type FlinkGetResponse

Types

type Flink

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) 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"`
}