Documentation
¶
Overview ¶
Go imports
Go imports ¶
package v2 contains API Schema definitions for the v2 API group +kubebuilder:object:generate=true +groupName=tango.tango-controls.org
Index ¶
- Variables
- type DatabaseDS
- func (dds *DatabaseDS) ConvertFrom(srcRaw conversion.Hub) error
- func (src *DatabaseDS) ConvertTo(dstRaw conversion.Hub) error
- func (in *DatabaseDS) DeepCopy() *DatabaseDS
- func (in *DatabaseDS) DeepCopyInto(out *DatabaseDS)
- func (in *DatabaseDS) DeepCopyObject() runtime.Object
- func (r *DatabaseDS) Default()
- func (r *DatabaseDS) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *DatabaseDS) ValidateCreate() error
- func (r *DatabaseDS) ValidateDelete() error
- func (r *DatabaseDS) ValidateUpdate(old runtime.Object) error
- type DatabaseDSCustomDefaulter
- type DatabaseDSCustomValidator
- func (in *DatabaseDSCustomValidator) DeepCopy() *DatabaseDSCustomValidator
- func (in *DatabaseDSCustomValidator) DeepCopyInto(out *DatabaseDSCustomValidator)
- func (v *DatabaseDSCustomValidator) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
- func (v *DatabaseDSCustomValidator) ValidateDelete(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
- func (v *DatabaseDSCustomValidator) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)
- type DatabaseDSList
- type DatabaseDSResources
- type DatabaseDSSpec
- type DatabaseDSStatus
- type Device
- type DeviceServer
- func (dds *DeviceServer) ConvertFrom(srcRaw conversion.Hub) error
- func (src *DeviceServer) ConvertTo(dstRaw conversion.Hub) error
- func (in *DeviceServer) DeepCopy() *DeviceServer
- func (in *DeviceServer) DeepCopyInto(out *DeviceServer)
- func (in *DeviceServer) DeepCopyObject() runtime.Object
- func (r *DeviceServer) Default()
- func (r *DeviceServer) SetupWebhookWithManager(mgr ctrl.Manager) error
- func (r *DeviceServer) ValidateCreate() error
- func (r *DeviceServer) ValidateDelete() error
- func (r *DeviceServer) ValidateUpdate(old runtime.Object) error
- type DeviceServerCustomDefaulter
- type DeviceServerCustomValidator
- func (in *DeviceServerCustomValidator) DeepCopy() *DeviceServerCustomValidator
- func (in *DeviceServerCustomValidator) DeepCopyInto(out *DeviceServerCustomValidator)
- func (v *DeviceServerCustomValidator) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
- func (v *DeviceServerCustomValidator) ValidateDelete(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
- func (v *DeviceServerCustomValidator) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)
- type DeviceServerList
- type DeviceServerSpec
- type DeviceServerStatus
- type LB
- type Ports
- type Resources
Constants ¶
This section is empty.
Variables ¶
var (
// GroupVersion is group version used to register these objects
GroupVersion = schema.GroupVersion{Group: "tango.tango-controls.org", Version: "v2"}
// 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 DatabaseDS ¶
type DatabaseDS struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec DatabaseDSSpec `json:"spec,omitempty"`
Status DatabaseDSStatus `json:"status,omitempty"`
}
DatabaseDS is the Schema for the databaseds API +kubebuilder:object:root=true +versionName=v1 +kubebuilder:storageversion +kubebuilder:subresource:status +kubebuilder:resource:path="databaseds" +kubebuilder:printcolumn:name="Components",type="integer",JSONPath=".status.replicas",description="The number of Components Requested in the DatabaseDS",priority=0 +kubebuilder:printcolumn:name="Succeeded",type="integer",JSONPath=".status.succeeded",description="The number of Components Launched in the DatabaseDS",priority=0 +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="The number of Components Requested in the DatabaseDS",priority=0 +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state",description="Status of the DatabaseDS",priority=0 +kubebuilder:printcolumn:name="TangoDB",type="string",JSONPath=".status.tangodb",description=" TangoDB details of the DatabaseDS",priority=1 +kubebuilder:printcolumn:name="DS",type="string",JSONPath=".status.ds",description=" DS details of the DatabaseDS",priority=1 +kubebuilder:printcolumn:name="Resources",type="string",JSONPath=".status.resources",description=" Resource details of the DatabaseDS",priority=1
func (*DatabaseDS) ConvertFrom ¶
func (dds *DatabaseDS) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from the Hub version (v1) to this version.
func (*DatabaseDS) ConvertTo ¶
func (src *DatabaseDS) ConvertTo(dstRaw conversion.Hub) error
ConvertTo is expected to modify its argument to contain the converted object. Most of the conversion is straightforward copying, except for converting our changed field.
ConvertTo converts this DatabaseDS to the Hub version (v1).
func (*DatabaseDS) DeepCopy ¶
func (in *DatabaseDS) DeepCopy() *DatabaseDS
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseDS.
func (*DatabaseDS) DeepCopyInto ¶
func (in *DatabaseDS) DeepCopyInto(out *DatabaseDS)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DatabaseDS) DeepCopyObject ¶
func (in *DatabaseDS) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*DatabaseDS) Default ¶
func (r *DatabaseDS) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*DatabaseDS) SetupWebhookWithManager ¶
func (r *DatabaseDS) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*DatabaseDS) ValidateCreate ¶
func (r *DatabaseDS) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*DatabaseDS) ValidateDelete ¶
func (r *DatabaseDS) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*DatabaseDS) ValidateUpdate ¶
func (r *DatabaseDS) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
type DatabaseDSCustomDefaulter ¶
type DatabaseDSCustomDefaulter struct {
}
func (*DatabaseDSCustomDefaulter) DeepCopy ¶
func (in *DatabaseDSCustomDefaulter) DeepCopy() *DatabaseDSCustomDefaulter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseDSCustomDefaulter.
func (*DatabaseDSCustomDefaulter) DeepCopyInto ¶
func (in *DatabaseDSCustomDefaulter) DeepCopyInto(out *DatabaseDSCustomDefaulter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DatabaseDSCustomValidator ¶
type DatabaseDSCustomValidator struct {
}
func (*DatabaseDSCustomValidator) DeepCopy ¶
func (in *DatabaseDSCustomValidator) DeepCopy() *DatabaseDSCustomValidator
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseDSCustomValidator.
func (*DatabaseDSCustomValidator) DeepCopyInto ¶
func (in *DatabaseDSCustomValidator) DeepCopyInto(out *DatabaseDSCustomValidator)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DatabaseDSCustomValidator) ValidateCreate ¶
func (v *DatabaseDSCustomValidator) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
ValidateCreate implements webhook.CustomValidator so a webhook will be registered for the type CronJob.
func (*DatabaseDSCustomValidator) ValidateDelete ¶
func (v *DatabaseDSCustomValidator) ValidateDelete(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
ValidateDelete implements webhook.CustomValidator so a webhook will be registered for the type CronJob.
func (*DatabaseDSCustomValidator) ValidateUpdate ¶
func (v *DatabaseDSCustomValidator) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)
ValidateUpdate implements webhook.CustomValidator so a webhook will be registered for the type CronJob.
type DatabaseDSList ¶
type DatabaseDSList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []DatabaseDS `json:"items"`
}
DatabaseDSList contains a list of DatabaseDS
func (*DatabaseDSList) DeepCopy ¶
func (in *DatabaseDSList) DeepCopy() *DatabaseDSList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseDSList.
func (*DatabaseDSList) DeepCopyInto ¶
func (in *DatabaseDSList) DeepCopyInto(out *DatabaseDSList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DatabaseDSList) DeepCopyObject ¶
func (in *DatabaseDSList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type DatabaseDSResources ¶
type DatabaseDSResources struct {
TangoDB Resources `json:"tangodb,omitempty"`
DatabaseDS Resources `json:"databaseds,omitempty"`
}
func (*DatabaseDSResources) DeepCopy ¶
func (in *DatabaseDSResources) DeepCopy() *DatabaseDSResources
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseDSResources.
func (*DatabaseDSResources) DeepCopyInto ¶
func (in *DatabaseDSResources) DeepCopyInto(out *DatabaseDSResources)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DatabaseDSSpec ¶
type DatabaseDSSpec struct {
// Enable Load Balancer for external access to DatabaseDS
// +optional
EnableLoadBalancer bool `json:"enableLoadBalancer,omitempty"`
// Disable Network Policies
// +optional
DisablePolicies bool `json:"disablepolicies,omitempty"`
// Enable the creation of a PV for the DatabaseDS
// +optional
UsePV bool `json:"usePV,omitempty"`
// DatabaseDS resource name that is the Tango DatabaseDS the DS will run as: optional, defaults to Name
DatabaseDS string `json:"databaseds,omitempty"`
// Source image to deploy DatabaseDS from - default: artefact.skao.int/ska-tango-images-tango-databaseds-alpine:0.3.0, registry.gitlab.com/tango-controls/docker/tango-db:5.16
DDSImage string `json:"dsimage,omitempty"`
// DatabaseDS TC config that get's loaded at DS boot - FQ file name, HTTP URL, or full config body .json: optional
Config string `json:"config,omitempty"`
// Source image to deploy Tango DB from - default: artefact.skao.int/ska-tango-images-tango-db:10.4.14, registry.gitlab.com/tango-controls/docker/mysql:5.16-mysql-8-1
DBImage string `json:"dbimage,omitempty"`
// Kubernetes cluster domain default cluster.local
//+kubebuilder:default=cluster.local
//+optional
ClusterDomain string `json:"clusterDomain,omitempty"`
// Pull Policy for image - default: IfNotPresent
//+optional
ImagePullPolicy string `json:"imagePullPolicy,omitempty"`
// OmniOrb Port default 10000
//+kubebuilder:validation:Minimum=0
//+kubebuilder:default=10000
//+optional
Port int32 `json:"orbport,omitempty"`
// Tango DB DB name - default: tango
DBDb string `json:"dbdb,omitempty"`
// Tango DB Root Password - default: secret
DBRootPw string `json:"dbrootpw,omitempty"`
// Tango DB User - default: tango
DBUser string `json:"dbuser,omitempty"`
// Tango DB User Password - default: tango
DBPassword string `json:"dbpassword,omitempty"`
//TangoDB StorageClass - default: standard
//+optional
TangoDBStorageClass string `json:"tangoDBStorageClass,omitempty"`
// Specifies the Volumes.
//+optional
Volumes []corev1.Volume `json:"volumes,omitempty"`
// Specifies the VolumeMounts.
//+optional
VolumeMounts []corev1.VolumeMount `json:"volumeMounts,omitempty"`
// Specifies the Environment variables.
//+optional
Env []corev1.EnvVar `json:"env,omitempty"`
// Specifies the Pull Secrets.
//+optional
PullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
// Specifies the NodeSelector configuration.
//+optional
NodeSelector map[string]string `json:"nodeSelector,omitempty"`
// Specifies the Affinity configuration.
//+optional
Affinity *corev1.Affinity `json:"affinity,omitempty"`
// Specifies the Toleration configuration.
//+optional
Tolerations []corev1.Toleration `json:"tolerations,omitempty"`
// Specifies the Environment variables.
//+optional
Resources *corev1.ResourceRequirements `json:"resources,omitempty"`
}
DatabaseDSSpec defines the desired state of DatabaseDS
func (*DatabaseDSSpec) DeepCopy ¶
func (in *DatabaseDSSpec) DeepCopy() *DatabaseDSSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseDSSpec.
func (*DatabaseDSSpec) DeepCopyInto ¶
func (in *DatabaseDSSpec) DeepCopyInto(out *DatabaseDSSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DatabaseDSStatus ¶
type DatabaseDSStatus struct {
// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
// Important: Run "make" to regenerate code after modifying this file
Replicas int32 `json:"replicas"`
Succeeded int32 `json:"succeeded"`
State string `json:"state"`
Resources DatabaseDSResources `json:"resources"`
TangoDB string `json:"tangodb"`
DS string `json:"ds"`
}
DatabaseDSStatus defines the observed state of DatabaseDS
func (*DatabaseDSStatus) DeepCopy ¶
func (in *DatabaseDSStatus) DeepCopy() *DatabaseDSStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseDSStatus.
func (*DatabaseDSStatus) DeepCopyInto ¶
func (in *DatabaseDSStatus) DeepCopyInto(out *DatabaseDSStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Device ¶
type Device struct {
// Name of the device
Name string `json:"name"`
// Ping, in milliseconds of the device
Ping int32 `json:"ping"`
// State of the device (Command: State())
State string `json:"state"`
// Status of the device (Command: Status())
Status string `json:"status"`
// Class of the device (Command: Status())
Class string `json:"class"`
// Retrieval time of this information
RetTime metav1.Time `json:"retTime"`
}
Describe the device inside a DeviceServer
func (*Device) DeepCopy ¶
func (in *Device) DeepCopy() *Device
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Device.
func (*Device) DeepCopyInto ¶
func (in *Device) DeepCopyInto(out *Device)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeviceServer ¶
type DeviceServer struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec DeviceServerSpec `json:"spec,omitempty"`
Status DeviceServerStatus `json:"status,omitempty"`
}
DeviceServer is the Schema for the deviceservers API +kubebuilder:object:root=true +kubebuilder:subresource:status +versionName=v1 +kubebuilder:storageversion +kubebuilder:printcolumn:name="Components",type="integer",JSONPath=".status.replicas",description="The number of Components Requested in the DeviceServer",priority=0 +kubebuilder:printcolumn:name="Succeeded",type="integer",JSONPath=".status.succeeded",description="The number of Components Launched in the DeviceServer",priority=0 +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp",description="The number of Components Requested in the DeviceServer",priority=0 +kubebuilder:printcolumn:name="State",type="string",JSONPath=".status.state",description="Status of the DeviceServer",priority=0 +kubebuilder:printcolumn:name="Resources",type="string",JSONPath=".status.resources",description=" Resource details of the DeviceServer",priority=1
func (*DeviceServer) ConvertFrom ¶
func (dds *DeviceServer) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from the Hub version (v1) to this version.
func (*DeviceServer) ConvertTo ¶
func (src *DeviceServer) ConvertTo(dstRaw conversion.Hub) error
ConvertTo is expected to modify its argument to contain the converted object. Most of the conversion is straightforward copying, except for converting our changed field.
ConvertTo converts this DatabaseDS to the Hub version (v1).
func (*DeviceServer) DeepCopy ¶
func (in *DeviceServer) DeepCopy() *DeviceServer
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceServer.
func (*DeviceServer) DeepCopyInto ¶
func (in *DeviceServer) DeepCopyInto(out *DeviceServer)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DeviceServer) DeepCopyObject ¶
func (in *DeviceServer) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*DeviceServer) Default ¶
func (r *DeviceServer) Default()
Default implements webhook.Defaulter so a webhook will be registered for the type
func (*DeviceServer) SetupWebhookWithManager ¶
func (r *DeviceServer) SetupWebhookWithManager(mgr ctrl.Manager) error
func (*DeviceServer) ValidateCreate ¶
func (r *DeviceServer) ValidateCreate() error
ValidateCreate implements webhook.Validator so a webhook will be registered for the type
func (*DeviceServer) ValidateDelete ¶
func (r *DeviceServer) ValidateDelete() error
ValidateDelete implements webhook.Validator so a webhook will be registered for the type
func (*DeviceServer) ValidateUpdate ¶
func (r *DeviceServer) ValidateUpdate(old runtime.Object) error
ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
type DeviceServerCustomDefaulter ¶
type DeviceServerCustomDefaulter struct {
}
func (*DeviceServerCustomDefaulter) DeepCopy ¶
func (in *DeviceServerCustomDefaulter) DeepCopy() *DeviceServerCustomDefaulter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceServerCustomDefaulter.
func (*DeviceServerCustomDefaulter) DeepCopyInto ¶
func (in *DeviceServerCustomDefaulter) DeepCopyInto(out *DeviceServerCustomDefaulter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeviceServerCustomValidator ¶
type DeviceServerCustomValidator struct {
}
func (*DeviceServerCustomValidator) DeepCopy ¶
func (in *DeviceServerCustomValidator) DeepCopy() *DeviceServerCustomValidator
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceServerCustomValidator.
func (*DeviceServerCustomValidator) DeepCopyInto ¶
func (in *DeviceServerCustomValidator) DeepCopyInto(out *DeviceServerCustomValidator)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DeviceServerCustomValidator) ValidateCreate ¶
func (v *DeviceServerCustomValidator) ValidateCreate(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
ValidateCreate implements webhook.CustomValidator so a webhook will be registered for the type CronJob.
func (*DeviceServerCustomValidator) ValidateDelete ¶
func (v *DeviceServerCustomValidator) ValidateDelete(ctx context.Context, obj runtime.Object) (admission.Warnings, error)
ValidateDelete implements webhook.CustomValidator so a webhook will be registered for the type CronJob.
func (*DeviceServerCustomValidator) ValidateUpdate ¶
func (v *DeviceServerCustomValidator) ValidateUpdate(ctx context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)
ValidateUpdate implements webhook.CustomValidator so a webhook will be registered for the type CronJob.
type DeviceServerList ¶
type DeviceServerList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []DeviceServer `json:"items"`
}
DeviceServerList contains a list of DeviceServer
func (*DeviceServerList) DeepCopy ¶
func (in *DeviceServerList) DeepCopy() *DeviceServerList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceServerList.
func (*DeviceServerList) DeepCopyInto ¶
func (in *DeviceServerList) DeepCopyInto(out *DeviceServerList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DeviceServerList) DeepCopyObject ¶
func (in *DeviceServerList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type DeviceServerSpec ¶
type DeviceServerSpec struct {
// Disable Network Policies
//+optional
DisablePolicies bool `json:"disablepolicies,omitempty"`
// DeviceServer databaseds resource name that is the Tango DatabaseDS the DeviceServer will run against: mandatory
DatabaseDS string `json:"databaseds"`
// External DeviceServer DNS name or IP address - must be supplied if ExternalDeviceServer is set
// Make the deviceServer an external device only - this will only deploy the Service type ExternalName and pass DS config to TangoDB
// +optional
ExternalDeviceServer string `json:"externalDeviceServer,omitempty"`
// Enable Load Balancer for external access to DatabaseDS
// +optional
EnableLoadBalancer bool `json:"enableLoadBalancer,omitempty"`
// Specify Direct Connection to TANGO_HOST in DatabaseDS config option
//+optional
DirectConnection bool `json:"directConnection,omitempty"`
// DeviceServer config for this job - FQ file name, HTTP URL, or full config body .json: mandatory
Config string `json:"config"`
// DeviceServer name: mandatory
DSName string `json:"dsname"`
// DeviceServer script for this job - FQ file name or full script body either .py or .ipynb: mandatory
//+optional
Script string `json:"script"`
// DeviceServer script for this job - FQ file name or full script body either .py or .ipynb: mandatory
//+optional
Command string `json:"command"`
// DeviceServer lifecycle PostStart
//+optional
PostStart string `json:"postStart"`
// DeviceServer lifecycle PreStop
//+optional
PreStop string `json:"preStop"`
// Arguments to pass to app boot - default:
Args string `json:"args,omitempty"`
// Source image to deploy cluster from - default: artefact.skao.int/ska-tango-images-tango-pytango-alpine:0.3.1
Image string `json:"image,omitempty"`
// Pull Policy for image - default: IfNotPresent
//+optional
ImagePullPolicy string `json:"imagePullPolicy,omitempty"`
// Specifies the DeviceServers that must be started before this one.
//+optional
DependsOn []string `json:"dependsOn,omitempty"`
// OmniOrb IP default false
//+kubebuilder:default=false
//+optional
LegacyCompatibility bool `json:"legacycompatibility,omitempty"`
// OmniOrb Port default 45450
//+kubebuilder:validation:Minimum=0
//+kubebuilder:default=45450
//+optional
OrbPort int32 `json:"orbport,omitempty"`
// ZMQ Heartbeat Port default 45460
//+kubebuilder:validation:Minimum=0
//+kubebuilder:default=45460
//+optional
HeartbeatPort int32 `json:"heartbeatport,omitempty"`
// Kubernetes cluster domain default cluster.local
//+kubebuilder:default=cluster.local
//+optional
ClusterDomain string `json:"clusterDomain,omitempty"`
// ZMQ Event Port default 45470
//+kubebuilder:validation:Minimum=0
//+kubebuilder:default=45470
//+optional
EventPort int32 `json:"eventport,omitempty"`
// Specifies the Volumes.
//+optional
Volumes []corev1.Volume `json:"volumes,omitempty"`
// Specifies the VolumeMounts.
//+optional
VolumeMounts []corev1.VolumeMount `json:"volumeMounts,omitempty"`
// Specifies the Environment variables.
//+optional
Env []corev1.EnvVar `json:"env,omitempty"`
// Specifies the Pull Secrets.
//+optional
PullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
// Specifies the NodeSelector configuration.
//+optional
NodeSelector map[string]string `json:"nodeSelector,omitempty"`
// Specifies the Affinity configuration.
//+optional
Affinity *corev1.Affinity `json:"affinity,omitempty"`
// Specifies the Toleration configuration.
//+optional
Tolerations []corev1.Toleration `json:"tolerations,omitempty"`
// Specifies the Environment variables.
//+optional
Resources *corev1.ResourceRequirements `json:"resources,omitempty"`
}
DeviceServerSpec defines the desired state of DeviceServer
func (*DeviceServerSpec) DeepCopy ¶
func (in *DeviceServerSpec) DeepCopy() *DeviceServerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceServerSpec.
func (*DeviceServerSpec) DeepCopyInto ¶
func (in *DeviceServerSpec) DeepCopyInto(out *DeviceServerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeviceServerStatus ¶
type DeviceServerStatus struct {
// Replicas number of the statefulset
Replicas int32 `json:"replicas"`
// Succeeded number of the statefulset
Succeeded int32 `json:"succeeded"`
// Number of devices available in the DeviceServer
DeviceCount int32 `json:"devicecount,omitempty"`
// Number of devices answering to the State() command
DeviceReadyCount int32 `json:"devicereadycount,omitempty"`
// Devices list
Devices []Device `json:"devices,omitempty"`
// State of the DeviceServer
State string `json:"state"`
// Resources of the DeviceServer
Resources Resources `json:"resources,omitempty"`
}
DeviceServerStatus defines the observed state of DeviceServer
func (*DeviceServerStatus) DeepCopy ¶
func (in *DeviceServerStatus) DeepCopy() *DeviceServerStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeviceServerStatus.
func (*DeviceServerStatus) DeepCopyInto ¶
func (in *DeviceServerStatus) DeepCopyInto(out *DeviceServerStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LB ¶
type LB struct {
IP string `json:"ip,omitempty"`
}
Describe a LB Ip assigned
func (*LB) DeepCopy ¶
func (in *LB) DeepCopy() *LB
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LB.
func (*LB) DeepCopyInto ¶
func (in *LB) DeepCopyInto(out *LB)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Ports ¶
type Ports struct {
Name string `json:"name,omitempty"`
Port int32 `json:"port,omitempty"`
}
Describe a container port (name and number)
func (*Ports) DeepCopy ¶
func (in *Ports) DeepCopy() *Ports
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Ports.
func (*Ports) DeepCopyInto ¶
func (in *Ports) DeepCopyInto(out *Ports)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Resources ¶
type Resources struct {
// Service Name available
ServiceName string `json:"dsservice,omitempty"`
// Service Type available
ServiceType string `json:"servicetype,omitempty"`
// ClusterIP assigned
ClusterIP string `json:"clusterip,omitempty"`
// Ports allocated
Ports []Ports `json:"ports,omitempty"`
// Load balancer allocated
Lbs []LB `json:"lbs,omitempty"`
}
Describe the resources allocated per DeviceServer
func (*Resources) DeepCopy ¶
func (in *Resources) DeepCopy() *Resources
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Resources.
func (*Resources) DeepCopyInto ¶
func (in *Resources) DeepCopyInto(out *Resources)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.