httpmodels

Documentation

Index

• type CreateReq
• type CreateResp
• type DeleteReq
• type GetReq
• type GetResp
• type ListResp
• type ResetReq
• type RunNowReq
• type RunNowResp
• type RunsCancelReq
• type RunsDeleteReq
• type RunsExportReq
• type RunsExportResp
• type RunsGetOutputReq
• type RunsGetOutputResp
• type RunsGetReq
• type RunsGetResp
• type RunsListReq
• type RunsListResp
• type RunsSubmitReq
• type RunsSubmitResp
• type UpdateReq

Types

type CreateReq

type CreateReq struct {
	ExistingCluster        string                        `json:"run_id,omitempty" url:"run_id,omitempty"`
	NewCluster             *models.NewCluster            `json:"new_cluster,omitempty" url:"new_cluster,omitempty"`
	NotebookTask           *models.NotebookTask          `json:"notebook_task,omitempty" url:"notebook_task,omitempty"`
	SparkJarTask           *models.SparkJarTask          `json:"spark_jar_task,omitempty" url:"spark_jar_task,omitempty"`
	SparkPythonTask        *models.SparkPythonTask       `json:"spark_python_task,omitempty" url:"spark_python_task,omitempty"`
	SparkSubmitTask        *models.SparkSubmitTask       `json:"spark_submit_task,omitempty" url:"spark_submit_task,omitempty"`
	Name                   string                        `json:"name,omitempty" url:"name,omitempty"`
	Libraries              *[]libraryModels.Library      `json:"libraries,omitempty" url:"libraries,omitempty"`
	EmailNotifications     *models.JobEmailNotifications `json:"email_notifications,omitempty" url:"email_notifications,omitempty"`
	TimeoutSeconds         int32                         `json:"timeout_seconds,omitempty" url:"timeout_seconds,omitempty"`
	MaxRetries             int32                         `json:"max_retries,omitempty" url:"max_retries,omitempty"`
	MinRetryIntervalMillis int32                         `json:"min_retry_interval_millis,omitempty" url:"min_retry_interval_millis,omitempty"`
	RetryOnTimeout         bool                          `json:"retry_on_timeout,omitempty" url:"retry_on_timeout,omitempty"`
	Schedule               *models.CronSchedule          `json:"schedule,omitempty" url:"schedule,omitempty"`
	MaxConcurrentRuns      int32                         `json:"max_concurrent_runs,omitempty" url:"max_concurrent_runs,omitempty"`
}

type CreateResp

type CreateResp struct {
	JobID int64 `json:"job_id,omitempty" url:"job_id,omitempty"`
}

type DeleteReq

type DeleteReq struct {
	JobID int64 `json:"job_id,omitempty" url:"job_id,omitempty"`
}

type GetReq

type GetReq struct {
	JobID int64 `json:"job_id,omitempty" url:"job_id,omitempty"`
}

type GetResp

type GetResp struct {
	JobID            int64               `json:"job_id,omitempty" url:"job_id,omitempty"`
	CreateorUserName string              `json:"creator_user_name,omitempty" url:"creator_user_name,omitempty"`
	Settings         *models.JobSettings `json:"settings,omitempty" url:"settings,omitempty"`
	CreatedTime      int64               `json:"created_time,omitempty" url:"created_time,omitempty"`
}

type ListResp

type ListResp struct {
	Jobs *[]models.Job `json:"jobs,omitempty" url:"jobs,omitempty"`
}

type ResetReq

type ResetReq struct {
	JobID       int64               `json:"job_id,omitempty" url:"job_id,omitempty"`
	NewSettings *models.JobSettings `json:"new_settings,omitempty" url:"new_settings,omitempty"`
}

type RunNowReq

type RunNowReq struct {
	JobID             int64              `json:"job_id,omitempty" url:"job_id,omitempty"`
	JarParams         *[]string          `json:"jar_params,omitempty" url:"jar_params,omitempty"`
	NotebookParams    *map[string]string `json:"notebook_params,omitempty" url:"notebook_params,omitempty"`
	PythonParams      *[]string          `json:"python_params,omitempty" url:"python_params,omitempty"`
	SparkSubmitParams *[]string          `json:"spark_submit_params,omitempty" url:"spark_submit_params,omitempty"`
}

type RunNowResp

type RunNowResp struct {
	RunID       int64 `json:"run_id,omitempty" url:"run_id,omitempty"`
	NumberInJob int64 `json:"number_in_job,omitempty" url:"number_in_job,omitempty"`
}

type RunsCancelReq

type RunsCancelReq struct {
	RunID int64 `json:"run_id,omitempty" url:"run_id,omitempty"`
}

type RunsDeleteReq

type RunsDeleteReq struct {
	RunID int64 `json:"run_id,omitempty" url:"run_id,omitempty"`
}

type RunsExportReq

type RunsExportReq struct {
	RunID         int64                `json:"run_id,omitempty" url:"run_id,omitempty"`
	ViewsToExport models.ViewsToExport `json:"views_to_export,omitempty" url:"views_to_export,omitempty"`
}

type RunsExportResp

type RunsExportResp struct {
	Views *[]models.ViewItem `json:"views,omitempty" url:"views,omitempty"`
}

type RunsGetOutputReq

type RunsGetOutputReq struct {
	RunID int64 `json:"run_id,omitempty" url:"run_id,omitempty"`
}

type RunsGetOutputResp

type RunsGetOutputResp struct {
	NotebookOutput models.NotebookOutput `json:"notebook_output,omitempty" url:"notebook_output,omitempty"`
	Error          string                `json:"error,omitempty" url:"error,omitempty"`
	Metadata       models.Run            `json:"metadata,omitempty" url:"metadata,omitempty"`
}

type RunsGetReq

type RunsGetReq struct {
	RunID int64 `json:"run_id,omitempty" url:"run_id,omitempty"`
}

type RunsGetResp

type RunsGetResp struct {
	JobID                int64                  `json:"job_id,omitempty" url:"job_id,omitempty"`
	RunID                int64                  `json:"run_id,omitempty" url:"run_id,omitempty"`
	NumberInJob          int64                  `json:"number_in_job,omitempty" url:"number_in_job,omitempty"`
	OriginalAttemptRunID int64                  `json:"original_attempt_run_id,omitempty" url:"original_attempt_run_id,omitempty"`
	State                models.RunState        `json:"state,omitempty" url:"state,omitempty"`
	Schedule             models.CronSchedule    `json:"schedule,omitempty" url:"schedule,omitempty"`
	Task                 *models.JobTask        `json:"task,omitempty" url:"task,omitempty"`
	ClusterSpec          *models.ClusterSpec    `json:"cluster_spec,omitempty" url:"cluster_spec,omitempty"`
	ClusterInstance      models.ClusterInstance `json:"cluster_instance,omitempty" url:"cluster_instance,omitempty"`
	OverridingParameters *models.RunParameters  `json:"overriding_parameters,omitempty" url:"overriding_parameters,omitempty"`
	StartTime            int64                  `json:"start_time,omitempty" url:"start_time,omitempty"`
	EndTime              int64                  `json:"end_time,omitempty" url:"end_time,omitempty"`
	SetupDuration        int64                  `json:"setup_duration,omitempty" url:"setup_duration,omitempty"`
	ExecutionDuration    int64                  `json:"execution_duration,omitempty" url:"execution_duration,omitempty"`
	CleanupDuration      int64                  `json:"cleanup_duration,omitempty" url:"cleanup_duration,omitempty"`
	Trigger              models.TriggerType     `json:"trigger,omitempty" url:"trigger,omitempty"`
	CreatorUserName      string                 `json:"creator_user_name,omitempty" url:"creator_user_name,omitempty"`
	RunPageURL           string                 `json:"run_page_url,omitempty" url:"run_page_url,omitempty"`
}

type RunsListReq

type RunsListReq struct {
	ActiveOnly    bool   `json:"active_only,omitempty" url:"active_only,omitempty"`
	CompletedOnly bool   `json:"completed_only,omitempty" url:"completed_only,omitempty"`
	JobID         int64  `json:"job_id,omitempty" url:"job_id,omitempty"`
	Offset        int32  `json:"offset,omitempty" url:"offset"`
	Limit         int32  `json:"limit,omitempty" url:"limit"`
	RunType       string `json:"run_type,omitempty" url:"run_type,omitempty"`
}

type RunsListResp

type RunsListResp struct {
	Runs    *[]models.Run `json:"runs,omitempty" url:"runs,omitempty"`
	HasMore bool          `json:"has_more,omitempty" url:"has_more,omitempty"`
}

type RunsSubmitReq

type RunsSubmitReq struct {
	ExistingCluster  string                   `json:"run_id,omitempty" url:"run_id,omitempty"`
	NewCluster       *models.NewCluster       `json:"new_cluster,omitempty" url:"new_cluster,omitempty"`
	NotebookTask     *models.NotebookTask     `json:"notebook_task,omitempty" url:"notebook_task,omitempty"`
	SparkJarTask     *models.SparkJarTask     `json:"spark_jar_task,omitempty" url:"spark_jar_task,omitempty"`
	SparkPythonTask  *models.SparkPythonTask  `json:"spark_python_task,omitempty" url:"spark_python_task,omitempty"`
	SparkSubmitTask  *models.SparkSubmitTask  `json:"spark_submit_task,omitempty" url:"spark_submit_task,omitempty"`
	RunName          string                   `json:"run_name,omitempty" url:"run_name,omitempty"`
	Libraries        *[]libraryModels.Library `json:"libraries,omitempty" url:"libraries,omitempty"`
	TimeoutSeconds   int32                    `json:"timeout_seconds,omitempty" url:"timeout_seconds,omitempty"`
	IdempotencyToken string                   `json:"idempotency_token,omitempty" url:"idempotency_token,omitempty"`
}

type RunsSubmitResp

type RunsSubmitResp struct {
	RunID int64 `json:"run_id,omitempty" url:"run_id,omitempty"`
}

type UpdateReq

type UpdateReq struct {
	JobID          int64               `json:"job_id,omitempty" url:"job_id,omitempty"`
	NewSettings    *models.JobSettings `json:"new_settings,omitempty" url:"new_settings,omitempty"`
	FieldsToRemove *[]string           `json:"fields_to_remove,omitempty" url:"fields_to_remove,omitempty"`
}