dementor

Documentation

Index

• func DeleteProject(sessionId string, dq *DeleteProjectReq) error
• func InitConf() error
• func UnscheduleFlow(sessionId string, req *UnscheduleFlowReq) error
• type AuthenticateReq
• type AuthenticateRes
  • func Authenticate(aq *AuthenticateReq) (*AuthenticateRes, error)
• type CommonConf
• type CreateProjectReq
• type CreateProjectRes
  • func CreateProject(sessionId string, cq *CreateProjectReq) (*CreateProjectRes, error)
• type DeleteProjectReq
• type FetchFlowsProjectReq
• type FetchFlowsProjectRes
  • func FetchFlowsProject(sessionId string, fq *FetchFlowsProjectReq) (*FetchFlowsProjectRes, error)
• type FetchJobsFlowReq
• type FetchJobsFlowRes
  • func FetchJobsFlow(sessionId string, fq *FetchJobsFlowReq) (*FetchJobsFlowRes, error)
• type FetchScheduleReq
• type FetchScheduleRes
  • func FetchSchedule(sessionId string, fq *FetchScheduleReq) (*FetchScheduleRes, error)
• type ScheduleFlowReq
• type ScheduleFlowRes
  • func ScheduleFlow(sessionId string, sq *ScheduleFlowReq) (*ScheduleFlowRes, error)
• type UnscheduleFlowReq
• type UploadProjectZipReq
• type UploadProjectZipRes
  • func UploadProjectZip(sessionId string, uq *UploadProjectZipReq) (*UploadProjectZipRes, error)

Functions

func DeleteProject

func DeleteProject(sessionId string, dq *DeleteProjectReq) error

Delete a project

func InitConf

func InitConf() error

Initialize CommonConf mainly for tests

func UnscheduleFlow

func UnscheduleFlow(sessionId string, req *UnscheduleFlowReq) error

Unschedule a flow

Types

type AuthenticateReq

type AuthenticateReq struct {
	CommonConf
}

type AuthenticateRes

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

func Authenticate

func Authenticate(aq *AuthenticateReq) (*AuthenticateRes, error)

Authenticate with username and password, then obtain session id.

type CommonConf

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

var Config CommonConf

type CreateProjectReq

type CreateProjectReq struct {
	Name        string
	Description string
	CommonConf
}

type CreateProjectRes

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

func CreateProject

func CreateProject(sessionId string, cq *CreateProjectReq) (*CreateProjectRes, error)

Create a project

type DeleteProjectReq

type DeleteProjectReq struct {
	Project string
	CommonConf
}

type FetchFlowsProjectReq

type FetchFlowsProjectReq struct {
	Project string
	CommonConf
}

type FetchFlowsProjectRes

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

func FetchFlowsProject

func FetchFlowsProject(sessionId string, fq *FetchFlowsProjectReq) (*FetchFlowsProjectRes, error)

Fetch flows of a project

type FetchJobsFlowReq

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

type FetchJobsFlowRes

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

func FetchJobsFlow

func FetchJobsFlow(sessionId string, fq *FetchJobsFlowReq) (*FetchJobsFlowRes, error)

Fetch jobs of a flow

type FetchScheduleReq

type FetchScheduleReq struct {
	ProjectId string
	FlowId    string
	CommonConf
}

type FetchScheduleRes

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

func FetchSchedule

func FetchSchedule(sessionId string, fq *FetchScheduleReq) (*FetchScheduleRes, error)

Fetch a schedule of flow

type ScheduleFlowReq

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

type ScheduleFlowRes

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

func ScheduleFlow

func ScheduleFlow(sessionId string, sq *ScheduleFlowReq) (*ScheduleFlowRes, error)

Create project.

type UnscheduleFlowReq

type UnscheduleFlowReq struct {
	ScheduleId string
	CommonConf
}

type UploadProjectZipReq

type UploadProjectZipReq struct {
	Project  string
	FilePath string
	CommonConf
}

type UploadProjectZipRes

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

func UploadProjectZip

func UploadProjectZip(sessionId string, uq *UploadProjectZipReq) (*UploadProjectZipRes, error)

Upload a project zip file