operations

type Deploy struct {
	RemoteFilename        string
	APIToken              string
	LocalFilename         string
	EntryClass            string
	Parallelism           int
	ProgramArgs           []string
	SavepointDir          string
	SavepointPath         string
	AllowNonRestoredState bool
}

type Operator interface {
	Deploy(d Deploy) error
	Update(u UpdateJob) error
	RetrieveJobs() ([]flink.Job, error)
	Terminate(t TerminateJob) error
}

type RealOperator struct {
	Filesystem   afero.Fs
	FlinkRestAPI flink.FlinkRestAPI
}

type TerminateJob struct {
	JobNameBase string
	Mode        string
}

type UpdateJob struct {
	JobNameBase           string
	LocalFilename         string
	RemoteFilename        string
	APIToken              string
	EntryClass            string
	Parallelism           int
	ProgramArgs           []string
	SavepointDir          string
	AllowNonRestoredState bool
	Deploy                bool
	MaxSavepointDuration  int
}