Documentation
¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the alluxio.com v1alpha1 API group +kubebuilder:object:generate=true +groupName=k8s-operator.alluxio.com
Index ¶
- Variables
- type AlluxioCluster
- type AlluxioClusterList
- type AlluxioClusterSpec
- type AlluxioClusterStatus
- type AlluxioMonitorSpec
- type ClusterPhase
- type ConsoleSinkSpec
- type ControllerPluginSpec
- type ControllerSpec
- type CpuMemSpec
- type CsvSinkSpec
- type Dataset
- type DatasetConf
- type DatasetList
- type DatasetPhase
- type DatasetSpec
- type DatasetStatus
- type DriverRegistrarSpec
- type FuseSpec
- type GraphiteSinkSpec
- type HostAlias
- type JmxSinkSpec
- type JournalSpec
- type Load
- type LoadList
- type LoadPhase
- type LoadSpec
- type LoadStatus
- type MasterSpec
- type MetastoreSpec
- type MetricsSpec
- type MountSpec
- type NodePluginSpec
- type NodeServerSpec
- type PagestoreSpec
- type ProbeSpec
- type PrometheusMetricsServletSpec
- type ProvisionerSpec
- type ProxySpec
- type ResourcesSpec
- type Slf4jSinkSpec
- type Toleration
- type Unload
- type UnloadList
- type UnloadPhase
- type UnloadSpec
- type UnloadStatus
- type Update
- type UpdateList
- type UpdatePhase
- type UpdateSpec
- type UpdateStatus
- type WorkerSpec
Constants ¶
This section is empty.
Variables ¶
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "k8s-operator.alluxio.com", Version: "v1alpha1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme )
Functions ¶
This section is empty.
Types ¶
type AlluxioCluster ¶
type AlluxioCluster struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec AlluxioClusterSpec `json:"spec,omitempty"`
Status AlluxioClusterStatus `json:"status,omitempty"`
}
AlluxioCluster is the Schema for the alluxioclusters API
func (*AlluxioCluster) DeepCopy ¶
func (in *AlluxioCluster) DeepCopy() *AlluxioCluster
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AlluxioCluster.
func (*AlluxioCluster) DeepCopyInto ¶
func (in *AlluxioCluster) DeepCopyInto(out *AlluxioCluster)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AlluxioCluster) DeepCopyObject ¶
func (in *AlluxioCluster) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type AlluxioClusterList ¶
type AlluxioClusterList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []AlluxioCluster `json:"items"`
}
AlluxioClusterList contains a list of AlluxioCluster. Operator wouldn't work without this list.
func (*AlluxioClusterList) DeepCopy ¶
func (in *AlluxioClusterList) DeepCopy() *AlluxioClusterList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AlluxioClusterList.
func (*AlluxioClusterList) DeepCopyInto ¶
func (in *AlluxioClusterList) DeepCopyInto(out *AlluxioClusterList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AlluxioClusterList) DeepCopyObject ¶
func (in *AlluxioClusterList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type AlluxioClusterSpec ¶
type AlluxioClusterSpec struct {
NameOverride string `json:"nameOverride,omitempty" yaml:"nemOverride,omitempty"`
Dataset string `json:"dataset" yaml:"dataset"`
Image string `json:"image,omitempty" yaml:"image,omitempty"`
ImageTag string `json:"imageTag,omitempty" yaml:"imageTag,omitempty"`
ImagePullPolicy string `json:"imagePullPolicy,omitempty" yaml:"imagePullPolicy,omitempty"`
ImagePullSecrets []string `json:"imagePullSecrets,omitempty" yaml:"imagePullSecrets,omitempty"`
User *int `json:"user,omitempty" yaml:"user,omitempty"`
Group *int `json:"group,omitempty" yaml:"group,omitempty"`
FsGroup string `json:"fsGroup,omitempty" yaml:"fsGroup,omitempty"`
HostNetwork bool `json:"hostNetwork,omitempty" yaml:"hostNetwork,omitempty"`
DnsPolicy string `json:"dnsPolicy,omitempty" yaml:"dnsPolicy,omitempty"`
ServiceAccountName string `json:"serviceAccountName,omitempty" yaml:"serviceAccountName,omitempty"`
HostAliases []HostAlias `json:"hostAliases,omitempty" yaml:"hostAliases,omitempty"`
NodeSelector map[string]string `json:"nodeSelector,omitempty" yaml:"nodeSelector,omitempty"`
Tolerations []Toleration `json:"tolerations,omitempty" yaml:"tolerations,omitempty"`
Properties map[string]string `json:"properties,omitempty" yaml:"properties,omitempty"`
JvmOptions []string `json:"jvmOptions,omitempty" yaml:"jvmOptions,omitempty"`
PvcMounts MountSpec `json:"pvcMounts,omitempty" yaml:"pvcMounts,omitempty"`
ConfigMaps MountSpec `json:"configMaps,omitempty" yaml:"configMaps,omitempty"`
Secrets MountSpec `json:"secrets,omitempty" yaml:"secrets,omitempty"`
Master MasterSpec `json:"master,omitempty" yaml:"master,omitempty"`
Journal JournalSpec `json:"journal,omitempty" yaml:"journal,omitempty"`
Worker WorkerSpec `json:"worker,omitempty" yaml:"worker,omitempty"`
Pagestore PagestoreSpec `json:"pagestore,omitempty" yaml:"pagestore,omitempty"`
Metastore MetastoreSpec `json:"metastore,omitempty" yaml:"metastore,omitempty"`
Proxy ProxySpec `json:"proxy,omitempty" yaml:"proxy,omitempty"`
Fuse FuseSpec `json:"fuse,omitempty" yaml:"fuse,omitempty"`
Metrics MetricsSpec `json:"metrics,omitempty" yaml:"metrics,omitempty"`
AlluxioMonitor AlluxioMonitorSpec `json:"alluxio-monitor,omitempty" yaml:"alluxio-monitor,omitempty"`
}
AlluxioClusterSpec defines the desired state of AlluxioCluster
func (*AlluxioClusterSpec) DeepCopy ¶
func (in *AlluxioClusterSpec) DeepCopy() *AlluxioClusterSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AlluxioClusterSpec.
func (*AlluxioClusterSpec) DeepCopyInto ¶
func (in *AlluxioClusterSpec) DeepCopyInto(out *AlluxioClusterSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AlluxioClusterStatus ¶
type AlluxioClusterStatus struct {
Phase ClusterPhase `json:"phase"`
}
AlluxioClusterStatus defines the observed state of AlluxioCluster
func (*AlluxioClusterStatus) DeepCopy ¶
func (in *AlluxioClusterStatus) DeepCopy() *AlluxioClusterStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AlluxioClusterStatus.
func (*AlluxioClusterStatus) DeepCopyInto ¶
func (in *AlluxioClusterStatus) DeepCopyInto(out *AlluxioClusterStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AlluxioMonitorSpec ¶ added in v1.0.1
type AlluxioMonitorSpec struct {
Enabled bool `json:"enabled,omitempty" yaml:"enabled,omitempty"`
}
func (*AlluxioMonitorSpec) DeepCopy ¶ added in v1.0.1
func (in *AlluxioMonitorSpec) DeepCopy() *AlluxioMonitorSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AlluxioMonitorSpec.
func (*AlluxioMonitorSpec) DeepCopyInto ¶ added in v1.0.1
func (in *AlluxioMonitorSpec) DeepCopyInto(out *AlluxioMonitorSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterPhase ¶
type ClusterPhase string
const ( ClusterPhaseNone ClusterPhase = "" ClusterPhaseCreatingOrUpdating ClusterPhase = "Creating/Updating" ClusterPhasePending ClusterPhase = "Pending" ClusterPhaseReady ClusterPhase = "Ready" )
type ConsoleSinkSpec ¶
type ConsoleSinkSpec struct {
Enabled bool `json:"enabled,omitempty" yaml:"enabled,omitempty"`
Period int `json:"period,omitempty" yaml:"period,omitempty"`
Unit string `json:"unit,omitempty" yaml:"unit,omitempty"`
}
func (*ConsoleSinkSpec) DeepCopy ¶
func (in *ConsoleSinkSpec) DeepCopy() *ConsoleSinkSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConsoleSinkSpec.
func (*ConsoleSinkSpec) DeepCopyInto ¶
func (in *ConsoleSinkSpec) DeepCopyInto(out *ConsoleSinkSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ControllerPluginSpec ¶
type ControllerPluginSpec struct {
Controller ControllerSpec `json:"controller,omitempty" yaml:"controller,omitempty"`
Provisioner ProvisionerSpec `json:"provisioner,omitempty" yaml:"provisioner,omitempty"`
}
func (*ControllerPluginSpec) DeepCopy ¶
func (in *ControllerPluginSpec) DeepCopy() *ControllerPluginSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ControllerPluginSpec.
func (*ControllerPluginSpec) DeepCopyInto ¶
func (in *ControllerPluginSpec) DeepCopyInto(out *ControllerPluginSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ControllerSpec ¶
type ControllerSpec struct {
Image string `json:"image,omitempty" yaml:"image,omitempty"`
ImageTag string `json:"imageTag,omitempty" yaml:"imageTag,omitempty"`
Resources ResourcesSpec `json:"resources,omitempty" yaml:"resources,omitempty"`
}
func (*ControllerSpec) DeepCopy ¶
func (in *ControllerSpec) DeepCopy() *ControllerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ControllerSpec.
func (*ControllerSpec) DeepCopyInto ¶
func (in *ControllerSpec) DeepCopyInto(out *ControllerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CpuMemSpec ¶
type CpuMemSpec struct {
Cpu string `json:"cpu,omitempty" yaml:"cpu,omitempty"`
Memory string `json:"memory,omitempty" yaml:"memory,omitempty"`
}
func (*CpuMemSpec) DeepCopy ¶
func (in *CpuMemSpec) DeepCopy() *CpuMemSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CpuMemSpec.
func (*CpuMemSpec) DeepCopyInto ¶
func (in *CpuMemSpec) DeepCopyInto(out *CpuMemSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CsvSinkSpec ¶
type CsvSinkSpec struct {
Directory string `json:"directory,omitempty" yaml:"directory,omitempty"`
Enabled bool `json:"enabled,omitempty" yaml:"enabled,omitempty"`
Period int `json:"period,omitempty" yaml:"period,omitempty"`
Unit string `json:"unit,omitempty" yaml:"unit,omitempty"`
}
func (*CsvSinkSpec) DeepCopy ¶
func (in *CsvSinkSpec) DeepCopy() *CsvSinkSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CsvSinkSpec.
func (*CsvSinkSpec) DeepCopyInto ¶
func (in *CsvSinkSpec) DeepCopyInto(out *CsvSinkSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Dataset ¶
type Dataset struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec DatasetSpec `json:"spec,omitempty"`
Status DatasetStatus `json:"status,omitempty"`
}
Dataset is the Schema for the datasets API
func (*Dataset) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Dataset.
func (*Dataset) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Dataset) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type DatasetConf ¶
type DatasetConf struct {
Path string `json:"path" yaml:"path"`
Credentials map[string]string `json:"credentials,omitemptty" yaml:"credentials,omitempty"`
}
func (*DatasetConf) DeepCopy ¶
func (in *DatasetConf) DeepCopy() *DatasetConf
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatasetConf.
func (*DatasetConf) DeepCopyInto ¶
func (in *DatasetConf) DeepCopyInto(out *DatasetConf)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DatasetList ¶
type DatasetList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []Dataset `json:"items"`
}
DatasetList contains a list of Dataset. Operator wouldn't work without this list.
func (*DatasetList) DeepCopy ¶
func (in *DatasetList) DeepCopy() *DatasetList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatasetList.
func (*DatasetList) DeepCopyInto ¶
func (in *DatasetList) DeepCopyInto(out *DatasetList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DatasetList) DeepCopyObject ¶
func (in *DatasetList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type DatasetPhase ¶
type DatasetPhase string
const ( DatasetPhaseNotExist DatasetPhase = "non-exist" DatasetPhaseNone DatasetPhase = "" DatasetPhasePending DatasetPhase = "Pending" DatasetPhaseBounding DatasetPhase = "Bounding" DatasetPhaseReady DatasetPhase = "Ready" )
type DatasetSpec ¶
type DatasetSpec struct {
Dataset DatasetConf `json:"dataset" yaml:"dataset"`
}
func (*DatasetSpec) DeepCopy ¶
func (in *DatasetSpec) DeepCopy() *DatasetSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatasetSpec.
func (*DatasetSpec) DeepCopyInto ¶
func (in *DatasetSpec) DeepCopyInto(out *DatasetSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DatasetStatus ¶
type DatasetStatus struct {
BoundedAlluxioCluster string `json:"boundedAlluxioCluster"`
Phase DatasetPhase `json:"phase"`
}
func (*DatasetStatus) DeepCopy ¶
func (in *DatasetStatus) DeepCopy() *DatasetStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatasetStatus.
func (*DatasetStatus) DeepCopyInto ¶
func (in *DatasetStatus) DeepCopyInto(out *DatasetStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DriverRegistrarSpec ¶
type DriverRegistrarSpec struct {
Image string `json:"image,omitempty" yaml:"image,omitempty"`
Resources ResourcesSpec `json:"resources,omitempty" yaml:"resources,omitempty"`
}
func (*DriverRegistrarSpec) DeepCopy ¶
func (in *DriverRegistrarSpec) DeepCopy() *DriverRegistrarSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DriverRegistrarSpec.
func (*DriverRegistrarSpec) DeepCopyInto ¶
func (in *DriverRegistrarSpec) DeepCopyInto(out *DriverRegistrarSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type FuseSpec ¶
type FuseSpec struct {
Affinity corev1.Affinity `json:"affinity,omitempty" yaml:"affinity,omitempty"`
Enabled bool `json:"enabled,omitempty" yaml:"enabled,omitempty"`
Env map[string]string `json:"env,omitempty" yaml:"env,omitempty"`
Group *int `json:"group,omitempty" yaml:"group,omitempty"`
JvmOptions []string `json:"jvmOptions,omitempty" yaml:"jvmOptions,omitempty"`
MountOptions []string `json:"mountOptions,omitempty" yaml:"mountOptions,omitempty"`
NodeSelector map[string]string `json:"nodeSelector,omitempty" yaml:"nodeSelector,omitempty"`
PodAnnotations map[string]string `json:"podAnnotations,omitempty" yaml:"podAnnotations,omitempty"`
Resources ResourcesSpec `json:"resources,omitempty" yaml:"resources,omitempty"`
Tolerations []Toleration `json:"tolerations,omitempty" yaml:"tolerations,omitempty"`
User *int `json:"user,omitempty" yaml:"user,omitempty"`
}
func (*FuseSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FuseSpec.
func (*FuseSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type GraphiteSinkSpec ¶
type GraphiteSinkSpec struct {
Enabled bool `json:"enabled,omitempty" yaml:"enabled,omitempty"`
Hostname string `json:"hostname,omitempty" yaml:"hostname,omitempty"`
Period int `json:"period,omitempty" yaml:"period,omitempty"`
Port int `json:"port,omitempty" yaml:"port,omitempty"`
Prefix string `json:"prefix,omitempty" yaml:"prefix,omitempty"`
Unit string `json:"unit,omitempty" yaml:"unit,omitempty"`
}
func (*GraphiteSinkSpec) DeepCopy ¶
func (in *GraphiteSinkSpec) DeepCopy() *GraphiteSinkSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GraphiteSinkSpec.
func (*GraphiteSinkSpec) DeepCopyInto ¶
func (in *GraphiteSinkSpec) DeepCopyInto(out *GraphiteSinkSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type HostAlias ¶
type HostAlias struct {
Ip string `json:"ip" yaml:"ip"`
Hostnames []string `json:"hostnames" yaml:"hostnames"`
}
func (*HostAlias) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HostAlias.
func (*HostAlias) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JmxSinkSpec ¶
type JmxSinkSpec struct {
Enabled bool `json:"enabled,omitempty" yaml:"enabled,omitempty"`
Domain string `json:"domain,omitempty" yaml:"domain,omitempty"`
}
func (*JmxSinkSpec) DeepCopy ¶
func (in *JmxSinkSpec) DeepCopy() *JmxSinkSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JmxSinkSpec.
func (*JmxSinkSpec) DeepCopyInto ¶
func (in *JmxSinkSpec) DeepCopyInto(out *JmxSinkSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JournalSpec ¶
type JournalSpec struct {
HostPath string `json:"hostPath,omitempty" yaml:"hostPath,omitempty"`
RunFormat bool `json:"runFormat,omitempty" yaml:"runFormat,omitempty"`
Size string `json:"size,omitempty" yaml:"size,omitempty"`
StorageClass string `json:"storageClass,omitempty" yaml:"storageClass,omitempty"`
Type string `json:"type,omitempty" yaml:"type,omitempty"`
}
func (*JournalSpec) DeepCopy ¶
func (in *JournalSpec) DeepCopy() *JournalSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JournalSpec.
func (*JournalSpec) DeepCopyInto ¶
func (in *JournalSpec) DeepCopyInto(out *JournalSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Load ¶
type Load struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec LoadSpec `json:"spec,omitempty"`
Status LoadStatus `json:"status,omitempty"`
}
Load is the Schema for the loads API
func (*Load) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Load.
func (*Load) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Load) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type LoadList ¶
type LoadList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []Load `json:"items"`
}
LoadList contains a list of Load. Operator wouldn't work without this list.
func (*LoadList) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoadList.
func (*LoadList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*LoadList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type LoadSpec ¶
func (*LoadSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoadSpec.
func (*LoadSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LoadStatus ¶
type LoadStatus struct {
Phase LoadPhase `json:"phase"`
}
LoadStatus defines the observed state of Load
func (*LoadStatus) DeepCopy ¶
func (in *LoadStatus) DeepCopy() *LoadStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoadStatus.
func (*LoadStatus) DeepCopyInto ¶
func (in *LoadStatus) DeepCopyInto(out *LoadStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MasterSpec ¶
type MasterSpec struct {
Affinity corev1.Affinity `json:"affinity,omitempty" yaml:"affinity,omitempty"`
Count int `json:"count,omitempty" yaml:"count,omitempty"`
Enabled bool `json:"enabled,omitempty" yaml:"enabled,omitempty"`
Env map[string]string `json:"env,omitempty" yaml:"env,omitempty"`
JvmOptions []string `json:"jvmOptions,omitempty" yaml:"jvmOptions,omitempty"`
LivenessProbe ProbeSpec `json:"livenessProbe,omitempty" yaml:"livenessProbe,omitempty"`
NodeSelector map[string]string `json:"nodeSelector,omitempty" yaml:"nodeSelector,omitempty"`
PodAnnotations map[string]string `json:"podAnnotations,omitempty" yaml:"podAnnotations,omitempty"`
Ports map[string]int `json:"ports,omitempty" yaml:"port,omitempty"`
ReadinessProbe ProbeSpec `json:"readinessProbe,omitempty" yaml:"readinessProbe,omitempty"`
Resources ResourcesSpec `json:"resources,omitempty" yaml:"resources,omitempty"`
StartupProbe ProbeSpec `json:"startupProbe,omitempty" yaml:"startupProbe,omitempty"`
Tolerations []Toleration `json:"tolerations,omitempty" yaml:"tolerations,omitempty"`
}
func (*MasterSpec) DeepCopy ¶
func (in *MasterSpec) DeepCopy() *MasterSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MasterSpec.
func (*MasterSpec) DeepCopyInto ¶
func (in *MasterSpec) DeepCopyInto(out *MasterSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MetastoreSpec ¶
type MetastoreSpec struct {
Enabled bool `json:"enabled,omitempty" yaml:"enabled,omitempty"`
Size string `json:"size,omitempty" yaml:"size,omitempty"`
StorageClass string `json:"storageClass,omitempty" yaml:"storageClass,omitempty"`
}
func (*MetastoreSpec) DeepCopy ¶
func (in *MetastoreSpec) DeepCopy() *MetastoreSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetastoreSpec.
func (*MetastoreSpec) DeepCopyInto ¶
func (in *MetastoreSpec) DeepCopyInto(out *MetastoreSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MetricsSpec ¶
type MetricsSpec struct {
ConsoleSink ConsoleSinkSpec `json:"consoleSink,omitempty" yaml:"consoleSink,omitempty"`
CsvSink CsvSinkSpec `json:"csvSink,omitempty" yaml:"csvSink,omitempty"`
GraphiteSink GraphiteSinkSpec `json:"graphiteSink,omitempty" yaml:"graphiteSink,omitempty"`
JmxSink JmxSinkSpec `json:"jmxSink,omitempty" yaml:"jmxSink,omitempty"`
PrometheusMetricsServlet PrometheusMetricsServletSpec `json:"prometheusMetricsServlet,omitempty" yaml:"prometheusMetricsServlet,omitempty"`
Slf4jSink Slf4jSinkSpec `json:"slf4jSink,omitempty" yaml:"slf4jSink,omitempty"`
}
func (*MetricsSpec) DeepCopy ¶
func (in *MetricsSpec) DeepCopy() *MetricsSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetricsSpec.
func (*MetricsSpec) DeepCopyInto ¶
func (in *MetricsSpec) DeepCopyInto(out *MetricsSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MountSpec ¶
type MountSpec struct {
Master map[string]string `json:"master,omitempty" yaml:"master,omitempty"`
Worker map[string]string `json:"worker,omitempty" yaml:"worker,omitempty"`
Fuse map[string]string `json:"fuse,omitempty" yaml:"fuse,omitempty"`
Proxy map[string]string `json:"proxy,omitempty" yaml:"proxy,omitempty"`
}
func (*MountSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MountSpec.
func (*MountSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NodePluginSpec ¶
type NodePluginSpec struct {
DriverRegistrar DriverRegistrarSpec `json:"driverRegistrar,omitempty" yaml:"driverRegistrar,omitempty"`
NodeServer NodeServerSpec `json:"nodeserver,omitempty" yaml:"nodeserver,omitempty"`
}
func (*NodePluginSpec) DeepCopy ¶
func (in *NodePluginSpec) DeepCopy() *NodePluginSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodePluginSpec.
func (*NodePluginSpec) DeepCopyInto ¶
func (in *NodePluginSpec) DeepCopyInto(out *NodePluginSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NodeServerSpec ¶
type NodeServerSpec struct {
Image string `json:"image,omitempty" yaml:"image,omitempty"`
ImageTag string `json:"imageTag,omitempty" yaml:"imageTag,omitempty"`
Resources ResourcesSpec `json:"resources,omitempty" yaml:"resources,omitempty"`
}
func (*NodeServerSpec) DeepCopy ¶
func (in *NodeServerSpec) DeepCopy() *NodeServerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeServerSpec.
func (*NodeServerSpec) DeepCopyInto ¶
func (in *NodeServerSpec) DeepCopyInto(out *NodeServerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PagestoreSpec ¶
type PagestoreSpec struct {
HostPath string `json:"hostPath,omitempty" yaml:"hostPath,omitempty"`
MemoryBacked bool `json:"memoryBacked,omitempty" yaml:"memoryBacked,omitempty"`
Quota string `json:"quota,omitempty" yaml:"quota,omitempty"`
StorageClass string `json:"storageClass,omitempty" yaml:"storageClass,omitempty"`
Type string `json:"type,omitempty" yaml:"type,omitempty"`
}
func (*PagestoreSpec) DeepCopy ¶
func (in *PagestoreSpec) DeepCopy() *PagestoreSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PagestoreSpec.
func (*PagestoreSpec) DeepCopyInto ¶
func (in *PagestoreSpec) DeepCopyInto(out *PagestoreSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ProbeSpec ¶
type ProbeSpec struct {
FailureThreshold int `json:"failureThreshold,omitempty" yaml:"failureThreshold,omitempty"`
InitialDelaySeconds int `json:"initialDelaySeconds,omitempty" yaml:"initialDelaySeconds,omitempty"`
PeriodSeconds int `json:"periodSeconds,omitempty" yaml:"periodSeconds,omitempty"`
SuccessThreshold int `json:"successThreshold,omitempty" yaml:"successThreshold,omitempty"`
TimeoutSeconds int `json:"timeoutSeconds,omitempty" yaml:"timeoutSeconds,omitempty"`
}
func (*ProbeSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProbeSpec.
func (*ProbeSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PrometheusMetricsServletSpec ¶
type PrometheusMetricsServletSpec struct {
Enabled bool `json:"enabled,omitempty" yaml:"enabled,omitempty"`
PodAnnotations map[string]string `json:"podAnnotations,omitempty" yaml:"podAnnotations,omitempty"`
}
func (*PrometheusMetricsServletSpec) DeepCopy ¶
func (in *PrometheusMetricsServletSpec) DeepCopy() *PrometheusMetricsServletSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrometheusMetricsServletSpec.
func (*PrometheusMetricsServletSpec) DeepCopyInto ¶
func (in *PrometheusMetricsServletSpec) DeepCopyInto(out *PrometheusMetricsServletSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ProvisionerSpec ¶
type ProvisionerSpec struct {
Image string `json:"image,omitempty" yaml:"image,omitempty"`
Resources ResourcesSpec `json:"resources,omitempty" yaml:"resources,omitempty"`
}
func (*ProvisionerSpec) DeepCopy ¶
func (in *ProvisionerSpec) DeepCopy() *ProvisionerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProvisionerSpec.
func (*ProvisionerSpec) DeepCopyInto ¶
func (in *ProvisionerSpec) DeepCopyInto(out *ProvisionerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ProxySpec ¶
type ProxySpec struct {
Affinity corev1.Affinity `json:"affinity,omitempty" yaml:"affinity,omitempty"`
Enabled bool `json:"enabled,omitempty" yaml:"enabled,omitempty"`
Env map[string]string `json:"env,omitempty" yaml:"env,omitempty"`
JvmOptions []string `json:"jvmOptions,omitempty" yaml:"jvmOptions,omitempty"`
NodeSelector map[string]string `json:"nodeSelector,omitempty" yaml:"nodeSelector,omitempty"`
PodAnnotations map[string]string `json:"podAnnotations,omitempty" yaml:"podAnnotations,omitempty"`
Ports map[string]int `json:"ports,omitempty" yaml:"ports,omitempty"`
Resources ResourcesSpec `json:"resources,omitempty" yaml:"resources,omitempty"`
Tolerations []Toleration `json:"tolerations,omitempty" yaml:"tolerations,omitempty"`
}
func (*ProxySpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProxySpec.
func (*ProxySpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ResourcesSpec ¶
type ResourcesSpec struct {
Limits CpuMemSpec `json:"limits,omitempty" yaml:"limits,omitempty"`
Requests CpuMemSpec `json:"requests,omitempty" yaml:"requests,omitempty"`
}
func (*ResourcesSpec) DeepCopy ¶
func (in *ResourcesSpec) DeepCopy() *ResourcesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourcesSpec.
func (*ResourcesSpec) DeepCopyInto ¶
func (in *ResourcesSpec) DeepCopyInto(out *ResourcesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Slf4jSinkSpec ¶
type Slf4jSinkSpec struct {
Enabled bool `json:"enabled,omitempty" yaml:"enabled,omitempty"`
FilterClass string `json:"filterClass,omitempty" yaml:"filterClass,omitempty"`
FilterRegex string `json:"filterRegex,omitempty" yaml:"filterRegex,omitempty"`
Period int `json:"period,omitempty" yaml:"period,omitempty"`
Unit string `json:"unit,omitempty" yaml:"unit,omitempty"`
}
func (*Slf4jSinkSpec) DeepCopy ¶
func (in *Slf4jSinkSpec) DeepCopy() *Slf4jSinkSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Slf4jSinkSpec.
func (*Slf4jSinkSpec) DeepCopyInto ¶
func (in *Slf4jSinkSpec) DeepCopyInto(out *Slf4jSinkSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Toleration ¶
type Toleration struct {
Key string `json:"key" yaml:"key"`
Operator string `json:"operator" yaml:"operator"`
Value string `json:"value" yaml:"value"`
Effect string `json:"effect" yaml:"effect"`
}
func (*Toleration) DeepCopy ¶
func (in *Toleration) DeepCopy() *Toleration
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Toleration.
func (*Toleration) DeepCopyInto ¶
func (in *Toleration) DeepCopyInto(out *Toleration)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Unload ¶ added in v1.0.1
type Unload struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec UnloadSpec `json:"spec,omitempty"`
Status UnloadStatus `json:"status,omitempty"`
}
Unload is the Schema for the Unloads API
func (*Unload) DeepCopy ¶ added in v1.0.1
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Unload.
func (*Unload) DeepCopyInto ¶ added in v1.0.1
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Unload) DeepCopyObject ¶ added in v1.0.1
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type UnloadList ¶ added in v1.0.1
type UnloadList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []Unload `json:"items"`
}
UnloadList contains a list of Unload. Operator wouldn't work without this list.
func (*UnloadList) DeepCopy ¶ added in v1.0.1
func (in *UnloadList) DeepCopy() *UnloadList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UnloadList.
func (*UnloadList) DeepCopyInto ¶ added in v1.0.1
func (in *UnloadList) DeepCopyInto(out *UnloadList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*UnloadList) DeepCopyObject ¶ added in v1.0.1
func (in *UnloadList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type UnloadPhase ¶ added in v1.0.1
type UnloadPhase string
const ( UnloadPhaseNone UnloadPhase = "" UnloadPhaseNotExist UnloadPhase = "Data not exist" UnloadPhaseUnLoaded UnloadPhase = "Unloaded" )
type UnloadSpec ¶ added in v1.0.1
type UnloadSpec struct {
Dataset string `json:"dataset"`
}
func (*UnloadSpec) DeepCopy ¶ added in v1.0.1
func (in *UnloadSpec) DeepCopy() *UnloadSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UnloadSpec.
func (*UnloadSpec) DeepCopyInto ¶ added in v1.0.1
func (in *UnloadSpec) DeepCopyInto(out *UnloadSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type UnloadStatus ¶ added in v1.0.1
type UnloadStatus struct {
Phase UnloadPhase `json:"phase"`
}
UnloadStatus defines the observed state of Unload
func (*UnloadStatus) DeepCopy ¶ added in v1.0.1
func (in *UnloadStatus) DeepCopy() *UnloadStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UnloadStatus.
func (*UnloadStatus) DeepCopyInto ¶ added in v1.0.1
func (in *UnloadStatus) DeepCopyInto(out *UnloadStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Update ¶ added in v1.0.1
type Update struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec UpdateSpec `json:"spec,omitempty"`
Status UpdateStatus `json:"status,omitempty"`
}
Update is the Schema for the updates API
func (*Update) DeepCopy ¶ added in v1.0.1
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Update.
func (*Update) DeepCopyInto ¶ added in v1.0.1
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Update) DeepCopyObject ¶ added in v1.0.1
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type UpdateList ¶ added in v1.0.1
type UpdateList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []Update `json:"items"`
}
UpdateList contains a list of Update. Operator wouldn't work without this list.
func (*UpdateList) DeepCopy ¶ added in v1.0.1
func (in *UpdateList) DeepCopy() *UpdateList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdateList.
func (*UpdateList) DeepCopyInto ¶ added in v1.0.1
func (in *UpdateList) DeepCopyInto(out *UpdateList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*UpdateList) DeepCopyObject ¶ added in v1.0.1
func (in *UpdateList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type UpdatePhase ¶ added in v1.0.1
type UpdatePhase string
const ( UpdatePhaseNone UpdatePhase = "" UpdatePhaseWaiting UpdatePhase = "Waiting for data to be ready" UpdatePhaseUpdating UpdatePhase = "Updating" UpdatePhaseUpdated UpdatePhase = "Updated" UpdatePhaseFailed UpdatePhase = "Failed" )
type UpdateSpec ¶ added in v1.0.1
func (*UpdateSpec) DeepCopy ¶ added in v1.0.1
func (in *UpdateSpec) DeepCopy() *UpdateSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdateSpec.
func (*UpdateSpec) DeepCopyInto ¶ added in v1.0.1
func (in *UpdateSpec) DeepCopyInto(out *UpdateSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type UpdateStatus ¶ added in v1.0.1
type UpdateStatus struct {
Phase UpdatePhase `json:"phase"`
}
UpdateStatus defines the observed state of Update
func (*UpdateStatus) DeepCopy ¶ added in v1.0.1
func (in *UpdateStatus) DeepCopy() *UpdateStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdateStatus.
func (*UpdateStatus) DeepCopyInto ¶ added in v1.0.1
func (in *UpdateStatus) DeepCopyInto(out *UpdateStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type WorkerSpec ¶
type WorkerSpec struct {
Affinity corev1.Affinity `json:"affinity,omitempty" yaml:"affinity,omitempty"`
Count int `json:"count,omitempty" yaml:"count,omitempty"`
Env map[string]string `json:"env,omitempty" yaml:"env,omitempty"`
JvmOptions []string `json:"jvmOptions,omitempty" yaml:"jvmOptions,omitempty"`
LimitOneWorkerPerPod bool `json:"limitOneWorkerPerPod,omitempty" yaml:"limitOneWorkerPerPod,omitempty"`
LivenessProbe ProbeSpec `json:"livenessProbe,omitempty" yaml:"livenessProbe,omitempty"`
NodeSelector map[string]string `json:"nodeSelector,omitempty" yaml:"nodeSelector,omitempty"`
PodAnnotations map[string]string `json:"podAnnotations,omitempty" yaml:"podAnnotations,omitempty"`
Ports map[string]int `json:"ports,omitempty" yaml:"ports,omitempty"`
ReadinessProbe ProbeSpec `json:"readinessProbe,omitempty" yaml:"readinessProbe,omitempty"`
Resources ResourcesSpec `json:"resources,omitempty" yaml:"resources,omitempty"`
StartupProbe ProbeSpec `json:"startupProbe,omitempty" yaml:"startupProbe,omitempty"`
Tolerations []Toleration `json:"tolerations,omitempty" yaml:"tolerations,omitempty"`
}
func (*WorkerSpec) DeepCopy ¶
func (in *WorkerSpec) DeepCopy() *WorkerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkerSpec.
func (*WorkerSpec) DeepCopyInto ¶
func (in *WorkerSpec) DeepCopyInto(out *WorkerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.