httpmodels

Documentation

Index

• type CreateReq
• type CreateResp
• type DeleteReq
• type EditReq
• type EventsReq
• type EventsResp
• type GetReq
• type GetResp
• type ListNodeTypesResp
• type ListResp
• type PermanentDeleteReq
• type PinReq
• type ResizeReq
• type RestartReq
• type RuntimeVersionsResp
• type StartReq
• type UnpinReq

Types

type CreateReq

type CreateReq struct {
	NumWorkers             int32                   `json:"num_workers,omitempty" url:"num_workers,omitempty"`
	Autoscale              *models.AutoScale       `json:"autoscale,omitempty" url:"autoscale,omitempty"`
	ClusterName            string                  `json:"cluster_name,omitempty" url:"cluster_name,omitempty"`
	SparkVersion           string                  `json:"spark_version,omitempty" url:"spark_version,omitempty"`
	SparkConf              map[string]string       `json:"spark_conf,omitempty" url:"spark_conf,omitempty"`
	NodeTypeID             string                  `json:"node_type_id,omitempty" url:"node_type_id,omitempty"`
	DriverNodeTypeID       string                  `json:"driver_node_type_id,omitempty" url:"driver_node_type_id,omitempty"`
	CustomTags             []models.ClusterTag     `json:"custom_tags,omitempty" url:"custom_tags,omitempty"`
	ClusterLogConf         *models.ClusterLogConf  `json:"cluster_log_conf,omitempty" url:"cluster_log_conf,omitempty"`
	InitScripts            []models.InitScriptInfo `json:"init_scripts,omitempty" url:"init_scripts,omitempty"`
	DockerImage            *models.DockerImage     `json:"docker_image,omitempty" url:"docker_image,omitempty"`
	SparkEnvVars           map[string]string       `json:"spark_env_vars,omitempty" url:"spark_env_vars,omitempty"`
	AutoterminationMinutes int32                   `json:"autotermination_minutes,omitempty" url:"autotermination_minutes,omitempty"`
	InstancePoolID         string                  `json:"instance_pool_id,omitempty" url:"instance_pool_id,omitempty"`
	IdempotencyToken       string                  `json:"idempotency_token,omitempty" url:"idempotency_token,omitempty"`
	ApplyPolicyDefVal      bool                    `json:"apply_policy_default_values,omitempty" url:"apply_policy_default_values,omitempty"`
	EnableLocalDiskEncr    bool                    `json:"enable_local_disk_encryption,omitempty" url:"enable_local_disk_encryption,omitempty"`
}

type CreateResp

type CreateResp struct {
	ClusterID string `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
}

type DeleteReq

type DeleteReq struct {
	ClusterID string `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
}

type EditReq

type EditReq struct {
	NumWorkers             int32                   `json:"num_workers,omitempty" url:"num_workers,omitempty"`
	AutoScale              models.AutoScale        `json:"autoscale,omitempty" url:"autoscale,omitempty"`
	ClusterID              string                  `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
	ClusterName            string                  `json:"cluster_name,omitempty" url:"cluster_name,omitempty"`
	SparkVersion           string                  `json:"spark_version,omitempty" url:"spark_version,omitempty"`
	SparkConf              models.SparkConfPair    `json:"spark_conf,omitempty" url:"spark_conf,omitempty"`
	DockerImage            models.DockerImage      `json:"docker_image,omitempty" url:"docker_image,omitempty"`
	NodeTypeID             string                  `json:"node_type_id,omitempty" url:"node_type_id,omitempty"`
	InstancePoolID         string                  `json:"instance_pool_id,omitempty" url:"instance_pool_id,omitempty"`
	DriverNodeTypeID       string                  `json:"driver_node_type_id,omitempty" url:"driver_node_type_id,omitempty"`
	ClusterLogConf         models.ClusterLogConf   `json:"cluster_log_conf,omitempty" url:"cluster_log_conf,omitempty"`
	InitScripts            []models.InitScriptInfo `json:"init_scripts,omitempty" url:"init_scripts,omitempty"`
	SparkEnvVars           map[string]string       `json:"spark_env_vars,omitempty" url:"spark_env_vars,omitempty"`
	AutoterminationMinutes int32                   `json:"autotermination_minutes,omitempty" url:"autotermination_minutes,omitempty"`
	ApplyPolicyDefVal      bool                    `json:"apply_policy_default_values,omitempty" url:"apply_policy_default_values,omitempty"`
	EnableLocalDiskEncr    bool                    `json:"enable_local_disk_encryption,omitempty" url:"enable_local_disk_encryption,omitempty"`
}

type EventsReq

type EventsReq struct {
	ClusterID  string                    `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
	StartTime  int64                     `json:"start_time,omitempty" url:"start_time,omitempty"`
	EndTime    int64                     `json:"end_time,omitempty" url:"end_time,omitempty"`
	Order      models.ListOrder          `json:"order,omitempty" url:"order,omitempty"`
	EventTypes []models.ClusterEventType `json:"event_types,omitempty" url:"event_types,omitempty"`
	Offset     int64                     `json:"offset,omitempty" url:"offset,omitempty"`
	Limit      int64                     `json:"limit,omitempty" url:"limit,omitempty"`
}

type EventsResp

type EventsResp struct {
	Events     *[]models.ClusterEvent `json:"events,omitempty" url:"events,omitempty"`
	NextPage   EventsReq              `json:"next_page,omitempty" url:"next_page,omitempty"`
	TotalCount int32                  `json:"total_count,omitempty" url:"total_count,omitempty"`
}

type GetReq

type GetReq struct {
	ClusterID string `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
}

type GetResp

type GetResp struct {
	NumWorkers             int32                    `json:"num_workers,omitempty" url:"num_workers,omitempty"`
	AutoScale              models.AutoScale         `json:"autoscale,omitempty" url:"autoscale,omitempty"`
	ClusterID              string                   `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
	CreatorUserName        string                   `json:"creator_user_name,omitempty" url:"creator_user_name,omitempty"`
	Driver                 models.SparkNode         `json:"driver,omitempty" url:"driver,omitempty"`
	Executors              []models.SparkNode       `json:"executors,omitempty" url:"executors,omitempty"`
	SparkContextID         int64                    `json:"spark_context_id,omitempty" url:"spark_context_id,omitempty"`
	JdbcPort               int32                    `json:"jdbc_port,omitempty" url:"jdbc_port,omitempty"`
	ClusterName            string                   `json:"cluster_name,omitempty" url:"cluster_name,omitempty"`
	SparkVersion           string                   `json:"spark_version,omitempty" url:"spark_version,omitempty"`
	SparkConf              models.SparkConfPair     `json:"spark_conf,omitempty" url:"spark_conf,omitempty"`
	NodeTypeID             string                   `json:"node_type_id,omitempty" url:"node_type_id,omitempty"`
	DriverNodeTypeID       string                   `json:"driver_node_type_id,omitempty" url:"driver_node_type_id,omitempty"`
	CustomTags             models.ClusterTag        `json:"custom_tags,omitempty" url:"custom_tags,omitempty"`
	ClusterLogConf         models.ClusterLogConf    `json:"cluster_log_conf,omitempty" url:"cluster_log_conf,omitempty"`
	InitScripts            []models.InitScriptInfo  `json:"init_scripts,omitempty" url:"init_scripts,omitempty"`
	DockerImage            models.DockerImage       `json:"docker_image,omitempty" url:"docker_image,omitempty"`
	SparkEnvVars           map[string]string        `json:"spark_env_vars,omitempty" url:"spark_env_vars,omitempty"`
	AutoterminationMinutes int32                    `json:"autotermination_minutes,omitempty" url:"autotermination_minutes,omitempty"`
	EnableElasticDisk      bool                     `json:"enable_elastic_disk,omitempty" url:"enable_elastic_disk,omitempty"`
	InstancePoolID         string                   `json:"instance_pool_id,omitempty" url:"instance_pool_id,omitempty"`
	State                  models.ClusterState      `json:"state,omitempty" url:"state,omitempty"`
	StateMessage           string                   `json:"state_message,omitempty" url:"state_message,omitempty"`
	StartTime              int64                    `json:"start_time,omitempty" url:"start_time,omitempty"`
	TerminateTime          int64                    `json:"terminate_time,omitempty" url:"terminate_time,omitempty"`
	LastStateLossTime      int64                    `json:"last_state_loss_time,omitempty" url:"last_state_loss_time,omitempty"`
	LastActivityTime       int64                    `json:"last_activity_time,omitempty" url:"last_activity_time,omitempty"`
	ClusterMemoryMb        int64                    `json:"cluster_memory_mb,omitempty" url:"cluster_memory_mb,omitempty"`
	ClusterCores           float32                  `json:"cluster_cores,omitempty" url:"cluster_cores,omitempty"`
	DefaultTags            map[string]string        `json:"default_tags,omitempty" url:"default_tags,omitempty"`
	ClusterLogStatus       models.LogSyncStatus     `json:"cluster_log_status,omitempty" url:"cluster_log_status,omitempty"`
	TerminationReason      models.TerminationReason `json:"termination_reason,omitempty" url:"termination_reason,omitempty"`
}

type ListNodeTypesResp

type ListNodeTypesResp struct {
	NodeTypes []models.NodeType `json:"node_types,omitempty" url:"node_types,omitempty"`
}

type ListResp

type ListResp struct {
	Clusters []models.ClusterInfo
}

type PermanentDeleteReq

type PermanentDeleteReq struct {
	ClusterID string `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
}

type PinReq

type PinReq struct {
	ClusterID string `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
}

type ResizeReq

type ResizeReq struct {
	ClusterID  string           `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
	NumWorkers int32            `json:"num_workers,omitempty" url:"num_workers,omitempty"`
	Autoscale  models.AutoScale `json:"autoscale,omitempty" url:"autoscale,omitempty"`
}

type RestartReq

type RestartReq struct {
	ClusterID string `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
}

type RuntimeVersionsResp

type RuntimeVersionsResp struct {
	Versions []models.SparkVersion `json:"versions,omitempty" url:"versions,omitempty"`
}

type StartReq

type StartReq struct {
	ClusterID string `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
}

type UnpinReq

type UnpinReq struct {
	ClusterID string `json:"cluster_id,omitempty" url:"cluster_id,omitempty"`
}