flink

type CreateSavepointResponse struct {
	RequestID string `json:"request-id"`
}

type FlinkRestAPI interface {
	Terminate(jobID string, mode string) error
	CreateSavepoint(jobID string, savepointPath string) (CreateSavepointResponse, error)
	MonitorSavepointCreation(jobID string, requestID string) (MonitorSavepointCreationResponse, error)
	RetrieveJobs() ([]Job, error)
	RunJar(jarID string, entryClass string, jarArgs []string, parallelism int, savepointPath string, allowNonRestoredState bool) error
	UploadJar(filename string) (UploadJarResponse, error)
}

type FlinkRestClient struct {
	BaseURL           string
	BasicAuthUsername string
	BasicAuthPassword string
	Client            *retryablehttp.Client
}

type Job struct {
	ID     string `json:"jid"`
	Name   string `json:"name"`
	Status string `json:"state"`
}

type MonitorSavepointCreationResponse struct {
	Status    SavepointCreationStatus `json:"status"`
	Operation *SavepointOperation     `json:"operation"`
}

type SavepointCreationStatus struct {
	Id string `json:"id"`
}

type SavepointFailureCause struct {
	Class               string `json:"class"`
	StackTrace          string `json:"stack-trace"`
	SerializedThrowable string `json:"serialized-throwable"`
}

type SavepointOperation struct {
	FailureCause *SavepointFailureCause `json:"failure-cause"`
}

type TerminateJobErrorResponse struct {
	ErrInfo string `json:"error"`
}

type UploadJarResponse struct {
	Filename string `json:"filename"`
	Status   string `json:"status"`
}