Versions in this module Expand all Collapse all v0 v0.5.3 Jun 7, 2018 Changes in this version + const ClientOperationCode + const ClusterConfigCode + const ClusterIncompleteCode + const ComponentExistsCode + const Defaultname + const EphemeralCode + const ErrorWhileProcessing + const MasterCountMustBeZeroOrOne + const NamedConfigDoesNotExist + const NoCodeAvailable + const NoSuchClusterCode + const SentinelCountValue + const WorkerCountMustBeAtLeastZero + func CheckNoCluster(cluster *SparkCluster) bool + func DeleteCluster(clustername, namespace string, restconfig *rest.Config, app, appstatus string) (string, error) + func ErrorCode(err error) int + func ScaleCluster(name, namespace string, masters, workers int, restconfig *rest.Config) error + type ClusterConfig struct + ExposeWebUI string + MasterCount int + Metrics string + Name string + SparkImage string + SparkMasterConfig string + SparkWorkerConfig string + WorkerCount int + func GetClusterConfig(config *ClusterConfig, restconfig *rest.Config, namespace string) (res ClusterConfig, err error) + func GetDefaultConfig() ClusterConfig + type ClusterError struct + Code int + Msg string + func NewClusterError(msg string, code int) ClusterError + func (e ClusterError) Error() string + type SparkCluster struct + Config ClusterConfig + Ephemeral string + Href string + Image string + MasterCount int + MasterURL string + MasterWebRoute string + MasterWebURL string + Name string + Namespace string + Pods []SparkPod + Status string + WorkerCount int + func CreateCluster(clustername, namespace, sparkimage string, config *ClusterConfig, ...) (SparkCluster, error) + func FindClusters(namespace string, restconfig *rest.Config, app string) ([]SparkCluster, error) + func FindSingleCluster(name, namespace string, restconfig *rest.Config) (SparkCluster, error) + func UpdateCluster(name, namespace string, config *ClusterConfig, restconfig *rest.Config) (SparkCluster, error) + type SparkPod struct + IP string + Status string + Type string
Go to main page