dementor

type AuthenticateReq struct {
	CommonConf
}

type AuthenticateRes struct {
	SessionId string `json:"session.id"`
	Status    string `json:"status"`
}

type CommonConf struct {
	Url      string `short:"u" long:"url" description:"Azkaban URL" env:"DEM_URL" default:"http://localhost:80/" envconfig:"DEM_URL"`
	UserName string `short:"U" long:"username" description:"Username" env:"DEM_USERNAME" default:"azkaban" envconfig:"DEM_USERNAME"`
	Password string `short:"P" long:"password" description:"Password" env:"DEM_PASSWORD" default:"azkaban" envconfig:"DEM_PASSWORD"`
}

type CreateProjectReq struct {
	Name        string
	Description string
	CommonConf
}

type CreateProjectRes struct {
	Status string `json:"status"`
	Path   string `json:"path"`
	Action string `json:"action"`
}

type DeleteProjectReq struct {
	Project string
	CommonConf
}

type FetchFlowsProjectReq struct {
	Project string
	CommonConf
}

type FetchFlowsProjectRes struct {
	Project   string `json:"project"`
	ProjectId string `json:"projectId"`
	Flows     []struct {
		FlowId string `json:"flowId"`
	} `json:"flows"`
}

type FetchJobsFlowReq struct {
	Project string // The project name to be fetched
	Flow    string // The flow id to be fetched
	CommonConf
}

type FetchJobsFlowRes struct {
	Project   string `json:"project"`
	ProjectId string `json:"projectId"`
	Flow      string `json:"flow"`
	Nodes     []struct {
		Id   string   `json:"id"`
		Type string   `json:"type"`
		In   []string `json:"in"` // Job ids that this job is directory depending upon
	} `json:"nodes"`
}

type FetchScheduleReq struct {
	ProjectId string
	FlowId    string
	CommonConf
}

type FetchScheduleRes struct {
	CronExpression string `json:"cronExpression"`
	ScheduleId     string `json:"scheduleId"`
	SubmitUser     string `json:"submitUser"`
}

type ScheduleFlowReq struct {
	ProjectName    string
	Flow           string
	CronExpression string
	CommonConf
}

type ScheduleFlowRes struct {
	ScheduleId int64 `json:"scheduleId"`
}

type UnscheduleFlowReq struct {
	ScheduleId string
	CommonConf
}

type UploadProjectZipReq struct {
	Project  string
	FilePath string
	CommonConf
}

type UploadProjectZipRes struct {
	Error     string `json:"error"`
	ProjectId string `json:"projectId"`
	Version   string `json:"version"`
}