v1

Documentation

Overview

+k8s:deepcopy-gen=package +groupName=radanalytics.io

Copyright The Red Hat Authors. https://radanalytics.io/

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• Variables
• func Resource(resource string) schema.GroupResource
• type ClusterConfig
  • func (in *ClusterConfig) DeepCopy() *ClusterConfig
  • func (in *ClusterConfig) DeepCopyInto(out *ClusterConfig)
• type SparkCluster
  • func (in *SparkCluster) DeepCopy() *SparkCluster
  • func (in *SparkCluster) DeepCopyInto(out *SparkCluster)
  • func (in *SparkCluster) DeepCopyObject() runtime.Object
• type SparkClusterList
  • func (in *SparkClusterList) DeepCopy() *SparkClusterList
  • func (in *SparkClusterList) DeepCopyInto(out *SparkClusterList)
  • func (in *SparkClusterList) DeepCopyObject() runtime.Object
• type SparkClusterSpec
  • func (in *SparkClusterSpec) DeepCopy() *SparkClusterSpec
  • func (in *SparkClusterSpec) DeepCopyInto(out *SparkClusterSpec)
• type SparkClusterStatus
  • func (in *SparkClusterStatus) DeepCopy() *SparkClusterStatus
  • func (in *SparkClusterStatus) DeepCopyInto(out *SparkClusterStatus)
• type SparkPod
  • func (in *SparkPod) DeepCopy() *SparkPod
  • func (in *SparkPod) DeepCopyInto(out *SparkPod)

Constants

const (
	GroupName       = "radanalytics.io"
	SparkListPlural = "sparkclusters"
	FullCRDName     = SparkListPlural + "." + GroupName
)

Variables

var (
	// TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api.
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder runtime.SchemeBuilder

	AddToScheme = localSchemeBuilder.AddToScheme
)

var SchemeGroupVersion = schema.GroupVersion{Group: "radanalytics.io", Version: "v1"}

Functions

func Resource

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type ClusterConfig

type ClusterConfig struct {
	MasterCount       int    `json:"masterCount"`
	WorkerCount       int    `json:"workerCount"`
	Name              string `json:"name"`
	SparkMasterConfig string `json:"sparkMasterConfig"`
	SparkWorkerConfig string `json:"sparkWorkerConfig"`
	SparkImage        string `json:"sparkImage"`
	ExposeWebUI       string `json:"exposeWebUI"`
	Metrics           string `json:"metrics,omitempty"`
}

func (*ClusterConfig) DeepCopy

func (in *ClusterConfig) DeepCopy() *ClusterConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterConfig.

func (*ClusterConfig) DeepCopyInto

func (in *ClusterConfig) DeepCopyInto(out *ClusterConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkCluster

type SparkCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              SparkClusterSpec   `json:"spec"`
	Status            SparkClusterStatus `json:"status,omitempty"`
}

func (*SparkCluster) DeepCopy

func (in *SparkCluster) DeepCopy() *SparkCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkCluster.

func (*SparkCluster) DeepCopyInto

func (in *SparkCluster) DeepCopyInto(out *SparkCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SparkCluster) DeepCopyObject

func (in *SparkCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type SparkClusterList

type SparkClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`
	Items           []SparkCluster `json:"items"`
}

func (*SparkClusterList) DeepCopy

func (in *SparkClusterList) DeepCopy() *SparkClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkClusterList.

func (*SparkClusterList) DeepCopyInto

func (in *SparkClusterList) DeepCopyInto(out *SparkClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SparkClusterList) DeepCopyObject

func (in *SparkClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type SparkClusterSpec

type SparkClusterSpec struct {
	Namespace string `json:"namespace,omitempty"`
	//Name         string `json:"name,omitempty"`
	Href           string `json:"href"`
	Image          string `json:"image"`
	MasterURL      string `json:"masterUrl"`
	MasterWebURL   string `json:"masterWebUrl"`
	MasterWebRoute string `json:"masterWebRoute"`
	Status         string `json:"status"`
	WorkerCount    int    `json:"workerCount"`
	MasterCount    int    `json:"masterCount"`
	Config         ClusterConfig
	Ephemeral      string `json:"ephemeral,omitempty"`
	Pods           []SparkPod
	Alertrules     string `json:"alertrules,omitempty"`
}

TODO: Following same format as ClusterConfig.go in oshinko-cli

func (*SparkClusterSpec) DeepCopy

func (in *SparkClusterSpec) DeepCopy() *SparkClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkClusterSpec.

func (*SparkClusterSpec) DeepCopyInto

func (in *SparkClusterSpec) DeepCopyInto(out *SparkClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkClusterStatus

type SparkClusterStatus struct {
	State   string `json:"state,omitempty"`
	Message string `json:"message,omitempty"`
}

func (*SparkClusterStatus) DeepCopy

func (in *SparkClusterStatus) DeepCopy() *SparkClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkClusterStatus.

func (*SparkClusterStatus) DeepCopyInto

func (in *SparkClusterStatus) DeepCopyInto(out *SparkClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkPod

type SparkPod struct {
	IP     string `json:"ip"`
	Status string `json:"status"`
	Type   string `json:"type"`
}

func (*SparkPod) DeepCopy

func (in *SparkPod) DeepCopy() *SparkPod

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkPod.

func (*SparkPod) DeepCopyInto

func (in *SparkPod) DeepCopyInto(out *SparkPod)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.