v1alpha1

package
v0.0.2-rc-8f9a619 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 13, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the install v1alpha1 API group +kubebuilder:object:generate=true +groupName=install.armadaproject.io

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "install.armadaproject.io", 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

func ConvertRawExtensionToYaml 

func ConvertRawExtensionToYaml(config runtime.RawExtension) (string, error)

ConvertRawExtensionToYaml converts a RawExtension input to Yaml

Types

type AdditionalClusterRoleBinding 

type AdditionalClusterRoleBinding struct {
	NameSuffix      string `json:"nameSuffix"`
	ClusterRoleName string `json:"clusterRoleName"`
}

func (*AdditionalClusterRoleBinding) DeepCopy 

func (in *AdditionalClusterRoleBinding) DeepCopy() *AdditionalClusterRoleBinding

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

func (*AdditionalClusterRoleBinding) DeepCopyInto 

func (in *AdditionalClusterRoleBinding) DeepCopyInto(out *AdditionalClusterRoleBinding)

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

type ArmadaServer 

type ArmadaServer struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ArmadaServerSpec   `json:"spec,omitempty"`
	Status ArmadaServerStatus `json:"status,omitempty"`
}

ArmadaServer is the Schema for the Armada Server API

func (*ArmadaServer) DeepCopy 

func (in *ArmadaServer) DeepCopy() *ArmadaServer

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

func (*ArmadaServer) DeepCopyInto 

func (in *ArmadaServer) DeepCopyInto(out *ArmadaServer)

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

func (*ArmadaServer) DeepCopyObject 

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

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

func (*ArmadaServer) Default 

func (r *ArmadaServer) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*ArmadaServer) SetupWebhookWithManager 

func (r *ArmadaServer) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*ArmadaServer) ValidateCreate 

func (r *ArmadaServer) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*ArmadaServer) ValidateDelete 

func (r *ArmadaServer) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*ArmadaServer) ValidateUpdate 

func (r *ArmadaServer) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type ArmadaServerList 

type ArmadaServerList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ArmadaServer `json:"items"`
}

ArmadaServerList contains a list of ArmadaServer

func (*ArmadaServerList) DeepCopy 

func (in *ArmadaServerList) DeepCopy() *ArmadaServerList

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

func (*ArmadaServerList) DeepCopyInto 

func (in *ArmadaServerList) DeepCopyInto(out *ArmadaServerList)

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

func (*ArmadaServerList) DeepCopyObject 

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

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

type ArmadaServerSpec 

type ArmadaServerSpec struct {
	CommonSpecBase `json:""`

	// Replicas is the number of replicated instances for ArmadaServer
	Replicas int32 `json:"replicas,omitempty"`
	// NodeSelector restricts the ArmadaServer pod to run on nodes matching the configured selectors
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
	// Ingress defines labels and annotations for the Ingress controller of Armada Server
	Ingress *IngressConfig `json:"ingress,omitempty"`
	// An array of host names to build ingress rules for
	HostNames []string `json:"hostNames,omitempty"`
	// Who is issuing certificates for CA
	ClusterIssuer string `json:"clusterIssuer"`
	// Run Pulsar Init Jobs On Startup
	PulsarInit bool `json:"pulsarInit,omitempty"`
}

ArmadaServerSpec defines the desired state of ArmadaServer

func (*ArmadaServerSpec) DeepCopy 

func (in *ArmadaServerSpec) DeepCopy() *ArmadaServerSpec

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

func (*ArmadaServerSpec) DeepCopyInto 

func (in *ArmadaServerSpec) DeepCopyInto(out *ArmadaServerSpec)

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

type ArmadaServerStatus 

type ArmadaServerStatus struct{}

ArmadaServerStatus defines the observed state of ArmadaServer

func (*ArmadaServerStatus) DeepCopy 

func (in *ArmadaServerStatus) DeepCopy() *ArmadaServerStatus

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

func (*ArmadaServerStatus) DeepCopyInto 

func (in *ArmadaServerStatus) DeepCopyInto(out *ArmadaServerStatus)

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

type Binoculars 

type Binoculars struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   BinocularsSpec   `json:"spec,omitempty"`
	Status BinocularsStatus `json:"status,omitempty"`
}

Binoculars is the Schema for the binoculars API

func (*Binoculars) DeepCopy 

func (in *Binoculars) DeepCopy() *Binoculars

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

func (*Binoculars) DeepCopyInto 

func (in *Binoculars) DeepCopyInto(out *Binoculars)

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

func (*Binoculars) DeepCopyObject 

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

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

func (*Binoculars) Default 

func (r *Binoculars) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Binoculars) SetupWebhookWithManager 

func (r *Binoculars) SetupWebhookWithManager(mgr ctrl.Manager) error

type BinocularsList 

type BinocularsList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Binoculars `json:"items"`
}

BinocularsList contains a list of Binoculars

func (*BinocularsList) DeepCopy 

func (in *BinocularsList) DeepCopy() *BinocularsList

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

func (*BinocularsList) DeepCopyInto 

func (in *BinocularsList) DeepCopyInto(out *BinocularsList)

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

func (*BinocularsList) DeepCopyObject 

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

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

type BinocularsSpec 

type BinocularsSpec struct {
	CommonSpecBase `json:""`

	// Replicas is the number of replicated instances
	Replicas int32 `json:"replicas"`
	// NodeSelector restricts the pod to run on nodes matching the configured selectors
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
	// Ingress for this component. Used to inject labels/annotations into ingress
	Ingress *IngressConfig `json:"ingress,omitempty"`
	// An array of host names to build ingress rules for
	HostNames []string `json:"hostNames,omitempty"`
	// Who is issuing certificates for CA
	ClusterIssuer string `json:"clusterIssuer"`
}

BinocularsSpec defines the desired state of Binoculars

func (*BinocularsSpec) DeepCopy 

func (in *BinocularsSpec) DeepCopy() *BinocularsSpec

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

func (*BinocularsSpec) DeepCopyInto 

func (in *BinocularsSpec) DeepCopyInto(out *BinocularsSpec)

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

type BinocularsStatus 

type BinocularsStatus struct{}

BinocularsStatus defines the observed state of binoculars

func (*BinocularsStatus) DeepCopy 

func (in *BinocularsStatus) DeepCopy() *BinocularsStatus

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

func (*BinocularsStatus) DeepCopyInto 

func (in *BinocularsStatus) DeepCopyInto(out *BinocularsStatus)

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

type CommonSpecBase 

type CommonSpecBase struct {
	// Labels is the map of labels which wil be added to all objects
	Labels map[string]string `json:"labels,omitempty"`
	// Image is the configuration block for the image repository and tag
	Image Image `json:"image"`
	// ApplicationConfig is the internal configuration of the application which will be created as a Kubernetes Secret and mounted in the Kubernetes Deployment object
	// +kubebuilder:pruning:PreserveUnknownFields
	// +kubebuilder:validation:Schemaless
	ApplicationConfig runtime.RawExtension `json:"applicationConfig"`
	// PrometheusConfig is the configuration block for Prometheus monitoring
	Prometheus *PrometheusConfig `json:"prometheus,omitempty"`
	// Resources is the configuration block for setting resource requirements for this service
	Resources *corev1.ResourceRequirements `json:"resources,omitempty"`
	// Tolerations is the configuration block for specifying which taints this pod can tolerate
	Tolerations []corev1.Toleration `json:"tolerations,omitempty"`
	// TerminationGracePeriodSeconds specifies how many seconds should Kubernetes wait for the application to shut down gracefully before sending a KILL signal
	TerminationGracePeriodSeconds *int64 `json:"terminationGracePeriodSeconds,omitempty"`
	// if CustomServiceAccount is specified, then that service account is referenced in the Deployment (overrides service account defined in spec.serviceAccount field)
	CustomServiceAccount string `json:"customServiceAccount,omitempty"`
	// if ServiceAccount configuration is defined, it creates a new service account and references it in the deployment
	ServiceAccount *ServiceAccountConfig `json:"serviceAccount,omitempty"`
	// Extra environment variables that get added to deployment
	Environment []corev1.EnvVar `json:"environment,omitempty"`
	// Additional volumes that are mounted into deployments
	AdditionalVolumes []corev1.Volume `json:"additionalVolumes,omitempty"`
	// Additional volume mounts that are added as volumes
	AdditionalVolumeMounts []corev1.VolumeMount `json:"additionalVolumeMounts,omitempty"`
	// PortConfig is automatically populated with defaults and overlaid by values in ApplicationConfig.
	PortConfig PortConfig `json:"portConfig,omitempty"`
}

NOTE(Clif): You must label this with `json:""` when using it as an embedded struct in order for controller-gen to use the promoted fields as expected.

func (*CommonSpecBase) DeepCopy 

func (in *CommonSpecBase) DeepCopy() *CommonSpecBase

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

func (*CommonSpecBase) DeepCopyInto 

func (in *CommonSpecBase) DeepCopyInto(out *CommonSpecBase)

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

type EventIngester 

type EventIngester struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   EventIngesterSpec   `json:"spec,omitempty"`
	Status EventIngesterStatus `json:"status,omitempty"`
}

EventIngester is the Schema for the eventingesters API

func (*EventIngester) DeepCopy 

func (in *EventIngester) DeepCopy() *EventIngester

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

func (*EventIngester) DeepCopyInto 

func (in *EventIngester) DeepCopyInto(out *EventIngester)

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

func (*EventIngester) DeepCopyObject 

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

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

func (*EventIngester) Default 

func (r *EventIngester) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*EventIngester) SetupWebhookWithManager 

func (r *EventIngester) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*EventIngester) ValidateCreate 

func (r *EventIngester) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*EventIngester) ValidateDelete 

func (r *EventIngester) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*EventIngester) ValidateUpdate 

func (r *EventIngester) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type EventIngesterList 

type EventIngesterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []EventIngester `json:"items"`
}

EventIngesterList contains a list of EventIngester

func (*EventIngesterList) DeepCopy 

func (in *EventIngesterList) DeepCopy() *EventIngesterList

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

func (*EventIngesterList) DeepCopyInto 

func (in *EventIngesterList) DeepCopyInto(out *EventIngesterList)

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

func (*EventIngesterList) DeepCopyObject 

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

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

type EventIngesterSpec 

type EventIngesterSpec struct {
	CommonSpecBase `json:""`

	// Replicas is the number of replicated instances for ArmadaServer
	Replicas int32 `json:"replicas,omitempty"`
	// NodeSelector restricts the Executor pod to run on nodes matching the configured selectors
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
}

EventIngesterSpec defines the desired state of EventIngester

func (*EventIngesterSpec) DeepCopy 

func (in *EventIngesterSpec) DeepCopy() *EventIngesterSpec

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

func (*EventIngesterSpec) DeepCopyInto 

func (in *EventIngesterSpec) DeepCopyInto(out *EventIngesterSpec)

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

type EventIngesterStatus 

type EventIngesterStatus struct{}

EventIngesterStatus defines the observed state of EventIngester

func (*EventIngesterStatus) DeepCopy 

func (in *EventIngesterStatus) DeepCopy() *EventIngesterStatus

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

func (*EventIngesterStatus) DeepCopyInto 

func (in *EventIngesterStatus) DeepCopyInto(out *EventIngesterStatus)

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

type Executor 

type Executor struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ExecutorSpec   `json:"spec,omitempty"`
	Status ExecutorStatus `json:"status,omitempty"`
}

Executor is the Schema for the executors API

func (*Executor) DeepCopy 

func (in *Executor) DeepCopy() *Executor

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

func (*Executor) DeepCopyInto 

func (in *Executor) DeepCopyInto(out *Executor)

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

func (*Executor) DeepCopyObject 

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

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

func (*Executor) Default 

func (r *Executor) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Executor) SetupWebhookWithManager 

func (r *Executor) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Executor) ValidateCreate 

func (r *Executor) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Executor) ValidateDelete 

func (r *Executor) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Executor) ValidateUpdate 

func (r *Executor) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type ExecutorList 

type ExecutorList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Executor `json:"items"`
}

ExecutorList contains a list of Executor

func (*ExecutorList) DeepCopy 

func (in *ExecutorList) DeepCopy() *ExecutorList

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

func (*ExecutorList) DeepCopyInto 

func (in *ExecutorList) DeepCopyInto(out *ExecutorList)

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

func (*ExecutorList) DeepCopyObject 

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

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

type ExecutorSpec 

type ExecutorSpec struct {
	CommonSpecBase `json:""`

	// NodeSelector restricts the Executor pod to run on nodes matching the configured selectors
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
	// Additional ClusterRoleBindings which will be created
	AdditionalClusterRoleBindings []AdditionalClusterRoleBinding `json:"additionalClusterRoleBindings,omitempty"`
	// List of PriorityClasses which will be created
	PriorityClasses []*schedulingv1.PriorityClass `json:"priorityClasses,omitempty"`
}

ExecutorSpec defines the desired state of Executor

func (*ExecutorSpec) DeepCopy 

func (in *ExecutorSpec) DeepCopy() *ExecutorSpec

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

func (*ExecutorSpec) DeepCopyInto 

func (in *ExecutorSpec) DeepCopyInto(out *ExecutorSpec)

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

type ExecutorStatus 

type ExecutorStatus struct{}

ExecutorStatus defines the observed state of Executor

func (*ExecutorStatus) DeepCopy 

func (in *ExecutorStatus) DeepCopy() *ExecutorStatus

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

func (*ExecutorStatus) DeepCopyInto 

func (in *ExecutorStatus) DeepCopyInto(out *ExecutorStatus)

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

type Image 

type Image struct {
	// +kubebuilder:validation:MinLength=1
	// +kubebuilder:validation:Pattern:="^([a-z0-9]+(?:[._-][a-z0-9]+)*/*)+$"
	Repository string `json:"repository"`
	// +kubebuilder:validation:MinLength=1
	// +kubebuilder:validation:Pattern:="^[a-zA-Z0-9_.-]*$"
	Tag string `json:"tag"`
}

func (*Image) DeepCopy 

func (in *Image) DeepCopy() *Image

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

func (*Image) DeepCopyInto 

func (in *Image) DeepCopyInto(out *Image)

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

type IngressConfig 

type IngressConfig struct {
	// Labels is the map of labels which wil be added to all objects
	Labels map[string]string `json:"labels,omitempty"`
	// Annotations is a map of annotations which will be added to all ingress rules
	Annotations map[string]string `json:"annotations,omitempty"`
	// The type of ingress that is used
	IngressClass string `json:"ingressClass,omitempty"`
	// Overide name for ingress
	NameOverride string `json:"nameOverride,omitempty"`
}

func (*IngressConfig) DeepCopy 

func (in *IngressConfig) DeepCopy() *IngressConfig

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

func (*IngressConfig) DeepCopyInto 

func (in *IngressConfig) DeepCopyInto(out *IngressConfig)

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

type Lookout 

type Lookout struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   LookoutSpec   `json:"spec,omitempty"`
	Status LookoutStatus `json:"status,omitempty"`
}

Lookout is the Schema for the lookout API

func (*Lookout) DeepCopy 

func (in *Lookout) DeepCopy() *Lookout

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

func (*Lookout) DeepCopyInto 

func (in *Lookout) DeepCopyInto(out *Lookout)

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

func (*Lookout) DeepCopyObject 

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

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

func (*Lookout) Default 

func (r *Lookout) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Lookout) SetupWebhookWithManager 

func (r *Lookout) SetupWebhookWithManager(mgr ctrl.Manager) error

type LookoutIngester 

type LookoutIngester struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   LookoutIngesterSpec   `json:"spec,omitempty"`
	Status LookoutIngesterStatus `json:"status,omitempty"`
}

LookoutIngester is the Schema for the lookoutingesters API

func (*LookoutIngester) DeepCopy 

func (in *LookoutIngester) DeepCopy() *LookoutIngester

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

func (*LookoutIngester) DeepCopyInto 

func (in *LookoutIngester) DeepCopyInto(out *LookoutIngester)

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

func (*LookoutIngester) DeepCopyObject 

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

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

func (*LookoutIngester) Default 

func (r *LookoutIngester) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*LookoutIngester) SetupWebhookWithManager 

func (r *LookoutIngester) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*LookoutIngester) ValidateCreate 

func (r *LookoutIngester) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*LookoutIngester) ValidateDelete 

func (r *LookoutIngester) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*LookoutIngester) ValidateUpdate 

func (r *LookoutIngester) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type LookoutIngesterList 

type LookoutIngesterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []LookoutIngester `json:"items"`
}

LookoutIngesterList contains a list of LookoutIngester

func (*LookoutIngesterList) DeepCopy 

func (in *LookoutIngesterList) DeepCopy() *LookoutIngesterList

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

func (*LookoutIngesterList) DeepCopyInto 

func (in *LookoutIngesterList) DeepCopyInto(out *LookoutIngesterList)

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

func (*LookoutIngesterList) DeepCopyObject 

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

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

type LookoutIngesterSpec 

type LookoutIngesterSpec struct {
	CommonSpecBase `json:""`
}

LookoutIngesterSpec defines the desired state of LookoutIngester

func (*LookoutIngesterSpec) DeepCopy 

func (in *LookoutIngesterSpec) DeepCopy() *LookoutIngesterSpec

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

func (*LookoutIngesterSpec) DeepCopyInto 

func (in *LookoutIngesterSpec) DeepCopyInto(out *LookoutIngesterSpec)

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

type LookoutIngesterStatus 

type LookoutIngesterStatus struct {
}

LookoutIngesterStatus defines the observed state of LookoutIngester

func (*LookoutIngesterStatus) DeepCopy 

func (in *LookoutIngesterStatus) DeepCopy() *LookoutIngesterStatus

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

func (*LookoutIngesterStatus) DeepCopyInto 

func (in *LookoutIngesterStatus) DeepCopyInto(out *LookoutIngesterStatus)

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

type LookoutList 

type LookoutList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Lookout `json:"items"`
}

LookoutList contains a list of Lookout

func (*LookoutList) DeepCopy 

func (in *LookoutList) DeepCopy() *LookoutList

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

func (*LookoutList) DeepCopyInto 

func (in *LookoutList) DeepCopyInto(out *LookoutList)

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

func (*LookoutList) DeepCopyObject 

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

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

type LookoutSpec 

type LookoutSpec struct {
	CommonSpecBase `json:""`

	// Replicas is the number of replicated instances for Lookout
	Replicas int32 `json:"replicas,omitempty"`
	// NodeSelector restricts the Lookout pod to run on nodes matching the configured selectors
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
	// Ingress defines labels and annotations for the Ingress controller of Lookout
	Ingress *IngressConfig `json:"ingress,omitempty"`
	// An array of host names to build ingress rules for
	HostNames []string `json:"hostNames,omitempty"`
	// Who is issuing certificates for CA
	ClusterIssuer string `json:"clusterIssuer"`
	// DbPruningEnabled when true a pruning CronJob is created
	DbPruningEnabled *bool `json:"dbPruningEnabled,omitempty"`
	// DbPruningSchedule schedule to use for db pruning CronJob
	DbPruningSchedule *string `json:"dbPruningSchedule,omitempty"`
}

LookoutSpec defines the desired state of Lookout

func (*LookoutSpec) DeepCopy 

func (in *LookoutSpec) DeepCopy() *LookoutSpec

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

func (*LookoutSpec) DeepCopyInto 

func (in *LookoutSpec) DeepCopyInto(out *LookoutSpec)

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

type LookoutStatus 

type LookoutStatus struct{}

LookoutStatus defines the observed state of lookout

func (*LookoutStatus) DeepCopy 

func (in *LookoutStatus) DeepCopy() *LookoutStatus

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

func (*LookoutStatus) DeepCopyInto 

func (in *LookoutStatus) DeepCopyInto(out *LookoutStatus)

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

type PortConfig 

type PortConfig struct {
	HttpPort     int32 `json:"httpPort"`
	HttpNodePort int32 `json:"httpNodePort,omitempty"`
	GrpcPort     int32 `json:"grpcPort"`
	GrpcNodePort int32 `json:"grpcNodePort,omitempty"`
	MetricsPort  int32 `json:"metricsPort"`
}

func BuildPortConfig 

func BuildPortConfig(rawAppConfig runtime.RawExtension) (PortConfig, error)

BuildPortConfig extracts ports from the ApplicationConfig and returns a PortConfig

func (*PortConfig) DeepCopy 

func (in *PortConfig) DeepCopy() *PortConfig

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

func (*PortConfig) DeepCopyInto 

func (in *PortConfig) DeepCopyInto(out *PortConfig)

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

type PrometheusConfig 

type PrometheusConfig struct {
	// Enabled toggles should PrometheusRule and ServiceMonitor be created
	Enabled bool `json:"enabled,omitempty"`
	// Labels field enables adding additional labels to PrometheusRule and ServiceMonitor
	Labels map[string]string `json:"labels,omitempty"`
	// ScrapeInterval defines the interval at which Prometheus should scrape metrics
	// +kubebuilder:validation:Type:=string
	// +kubebuilder:validation:Format:=duration
	ScrapeInterval *metav1.Duration `json:"scrapeInterval,omitempty"`
}

func (*PrometheusConfig) DeepCopy 

func (in *PrometheusConfig) DeepCopy() *PrometheusConfig

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

func (*PrometheusConfig) DeepCopyInto 

func (in *PrometheusConfig) DeepCopyInto(out *PrometheusConfig)

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

type PrunerArgs 

type PrunerArgs struct {
	Timeout     string `json:"timeout,omitempty"`
	Batchsize   int32  `json:"batchsize,omitempty"`
	ExpireAfter string `json:"expireAfter,omitempty"`
}

PrunerArgs represent command-line args to the pruner cron job

func (*PrunerArgs) DeepCopy 

func (in *PrunerArgs) DeepCopy() *PrunerArgs

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

func (*PrunerArgs) DeepCopyInto 

func (in *PrunerArgs) DeepCopyInto(out *PrunerArgs)

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

type PrunerConfig 

type PrunerConfig struct {
	Enabled   bool                         `json:"enabled"`
	Schedule  string                       `json:"schedule,omitempty"`
	Resources *corev1.ResourceRequirements `json:"resources,omitempty"`
	Args      PrunerArgs                   `json:"args,omitempty"`
}

PrunerConfig definees the pruner cronjob settings

func (*PrunerConfig) DeepCopy 

func (in *PrunerConfig) DeepCopy() *PrunerConfig

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

func (*PrunerConfig) DeepCopyInto 

func (in *PrunerConfig) DeepCopyInto(out *PrunerConfig)

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

type Scheduler 

type Scheduler struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   SchedulerSpec   `json:"spec,omitempty"`
	Status SchedulerStatus `json:"status,omitempty"`
}

Scheduler is the Schema for the scheduler API

func (*Scheduler) DeepCopy 

func (in *Scheduler) DeepCopy() *Scheduler

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

func (*Scheduler) DeepCopyInto 

func (in *Scheduler) DeepCopyInto(out *Scheduler)

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

func (*Scheduler) DeepCopyObject 

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

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

func (*Scheduler) Default 

func (r *Scheduler) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Scheduler) SetupWebhookWithManager 

func (r *Scheduler) SetupWebhookWithManager(mgr ctrl.Manager) error

type SchedulerIngester 

type SchedulerIngester struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   SchedulerIngesterSpec   `json:"spec,omitempty"`
	Status SchedulerIngesterStatus `json:"status,omitempty"`
}

SchedulerIngester is the Schema for the scheduleringesters API

func (*SchedulerIngester) DeepCopy 

func (in *SchedulerIngester) DeepCopy() *SchedulerIngester

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

func (*SchedulerIngester) DeepCopyInto 

func (in *SchedulerIngester) DeepCopyInto(out *SchedulerIngester)

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

func (*SchedulerIngester) DeepCopyObject 

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

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

func (*SchedulerIngester) Default 

func (r *SchedulerIngester) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*SchedulerIngester) SetupWebhookWithManager 

func (r *SchedulerIngester) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*SchedulerIngester) ValidateCreate 

func (r *SchedulerIngester) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*SchedulerIngester) ValidateDelete 

func (r *SchedulerIngester) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*SchedulerIngester) ValidateUpdate 

func (r *SchedulerIngester) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type SchedulerIngesterList 

type SchedulerIngesterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []SchedulerIngester `json:"items"`
}

SchedulerIngesterList contains a list of SchedulerIngester

func (*SchedulerIngesterList) DeepCopy 

func (in *SchedulerIngesterList) DeepCopy() *SchedulerIngesterList

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

func (*SchedulerIngesterList) DeepCopyInto 

func (in *SchedulerIngesterList) DeepCopyInto(out *SchedulerIngesterList)

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

func (*SchedulerIngesterList) DeepCopyObject 

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

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

type SchedulerIngesterSpec 

type SchedulerIngesterSpec struct {
	CommonSpecBase `json:""`

	// Replicas is the number of replicated instances
	Replicas int32 `json:"replicas,omitempty"`
}

SchedulerIngesterSpec defines the desired state of SchedulerIngester

func (*SchedulerIngesterSpec) DeepCopy 

func (in *SchedulerIngesterSpec) DeepCopy() *SchedulerIngesterSpec

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

func (*SchedulerIngesterSpec) DeepCopyInto 

func (in *SchedulerIngesterSpec) DeepCopyInto(out *SchedulerIngesterSpec)

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

type SchedulerIngesterStatus 

type SchedulerIngesterStatus struct {
}

SchedulerIngesterStatus defines the observed state of SchedulerIngester

func (*SchedulerIngesterStatus) DeepCopy 

func (in *SchedulerIngesterStatus) DeepCopy() *SchedulerIngesterStatus

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

func (*SchedulerIngesterStatus) DeepCopyInto 

func (in *SchedulerIngesterStatus) DeepCopyInto(out *SchedulerIngesterStatus)

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

type SchedulerList 

type SchedulerList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Scheduler `json:"items"`
}

SchedulerList contains a list of Scheduler

func (*SchedulerList) DeepCopy 

func (in *SchedulerList) DeepCopy() *SchedulerList

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

func (*SchedulerList) DeepCopyInto 

func (in *SchedulerList) DeepCopyInto(out *SchedulerList)

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

func (*SchedulerList) DeepCopyObject 

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

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

type SchedulerSpec 

type SchedulerSpec struct {
	CommonSpecBase `json:""`

	// Replicas is the number of replicated instances
	Replicas int32 `json:"replicas,omitempty"`
	// Ingress defines labels and annotations for the Ingress controller of Scheduler
	Ingress *IngressConfig `json:"ingress,omitempty"`
	// An array of host names to build ingress rules for
	HostNames []string `json:"hostNames,omitempty"`
	// Who is issuing certificates for CA
	ClusterIssuer string `json:"clusterIssuer"`
	// Pruning config for cron job
	Pruner *PrunerConfig `json:"pruner,omitempty"`
}

SchedulerSpec defines the desired state of Scheduler

func (*SchedulerSpec) DeepCopy 

func (in *SchedulerSpec) DeepCopy() *SchedulerSpec

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

func (*SchedulerSpec) DeepCopyInto 

func (in *SchedulerSpec) DeepCopyInto(out *SchedulerSpec)

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

type SchedulerStatus 

type SchedulerStatus struct{}

SchedulerStatus defines the observed state of scheduler

func (*SchedulerStatus) DeepCopy 

func (in *SchedulerStatus) DeepCopy() *SchedulerStatus

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

func (*SchedulerStatus) DeepCopyInto 

func (in *SchedulerStatus) DeepCopyInto(out *SchedulerStatus)

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

type ServiceAccountConfig 

type ServiceAccountConfig struct {
	Secrets                      []corev1.ObjectReference      `json:"secrets,omitempty"`
	ImagePullSecrets             []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
	AutomountServiceAccountToken *bool                         `json:"automountServiceAccountToken,omitempty"`
}

func (*ServiceAccountConfig) DeepCopy 

func (in *ServiceAccountConfig) DeepCopy() *ServiceAccountConfig

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

func (*ServiceAccountConfig) DeepCopyInto 

func (in *ServiceAccountConfig) DeepCopyInto(out *ServiceAccountConfig)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.