Documentation ¶
Index ¶
- Constants
- func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition
- type Condition
- type ConditionMetaInterface
- type ConditionType
- type ConditionsMeta
- func (in *ConditionsMeta) DeepCopy() *ConditionsMeta
- func (in *ConditionsMeta) DeepCopyInto(out *ConditionsMeta)
- func (c *ConditionsMeta) GetConditions() []Condition
- func (c *ConditionsMeta) SetConditions(conditions []Condition)
- func (c *ConditionsMeta) SetDeployed() bool
- func (c *ConditionsMeta) SetFailed(reason KogitoServiceConditionReason, err error)
- func (c *ConditionsMeta) SetProvisioning() bool
- type KogitoCloudEventInfo
- type KogitoCloudEventsStatus
- type KogitoProbe
- type KogitoRuntime
- type KogitoRuntimeList
- type KogitoRuntimeSpec
- type KogitoRuntimeStatus
- type KogitoService
- type KogitoServiceConditionReason
- type KogitoServiceList
- type KogitoServiceSpec
- func (k *KogitoServiceSpec) AddDeploymentLabel(name, value string)
- func (k *KogitoServiceSpec) AddEnvironmentVariable(name, value string)
- func (k *KogitoServiceSpec) AddEnvironmentVariableFromSecret(variableName, secretName, secretKey string)
- func (k *KogitoServiceSpec) AddInfra(name string)
- func (k *KogitoServiceSpec) AddResourceLimit(name, value string)
- func (k *KogitoServiceSpec) AddResourceRequest(name, value string)
- func (k *KogitoServiceSpec) AddServiceLabel(name, value string)
- func (in *KogitoServiceSpec) DeepCopy() *KogitoServiceSpec
- func (in *KogitoServiceSpec) DeepCopyInto(out *KogitoServiceSpec)
- func (k *KogitoServiceSpec) GetConfig() map[string]string
- func (k *KogitoServiceSpec) GetDeploymentLabels() map[string]string
- func (k *KogitoServiceSpec) GetEnvs() []corev1.EnvVar
- func (k *KogitoServiceSpec) GetImage() string
- func (k *KogitoServiceSpec) GetInfra() []string
- func (k *KogitoServiceSpec) GetMonitoring() Monitoring
- func (k *KogitoServiceSpec) GetProbes() KogitoProbe
- func (k *KogitoServiceSpec) GetPropertiesConfigMap() string
- func (k *KogitoServiceSpec) GetReplicas() *int32
- func (k *KogitoServiceSpec) GetResources() corev1.ResourceRequirements
- func (k *KogitoServiceSpec) GetServiceLabels() map[string]string
- func (k *KogitoServiceSpec) IsInsecureImageRegistry() bool
- func (k *KogitoServiceSpec) SetDeploymentLabels(labels map[string]string)
- func (k *KogitoServiceSpec) SetEnvs(envs []corev1.EnvVar)
- func (k *KogitoServiceSpec) SetImage(image string)
- func (k *KogitoServiceSpec) SetReplicas(replicas int32)
- func (k *KogitoServiceSpec) SetResources(resources corev1.ResourceRequirements)
- func (k *KogitoServiceSpec) SetServiceLabels(labels map[string]string)
- type KogitoServiceSpecInterface
- type KogitoServiceStatus
- func (in *KogitoServiceStatus) DeepCopy() *KogitoServiceStatus
- func (in *KogitoServiceStatus) DeepCopyInto(out *KogitoServiceStatus)
- func (k *KogitoServiceStatus) GetCloudEvents() KogitoCloudEventsStatus
- func (k *KogitoServiceStatus) GetDeploymentConditions() []appsv1.DeploymentCondition
- func (k *KogitoServiceStatus) GetExternalURI() string
- func (k *KogitoServiceStatus) GetImage() string
- func (k *KogitoServiceStatus) SetCloudEvents(cloudEvents KogitoCloudEventsStatus)
- func (k *KogitoServiceStatus) SetDeploymentConditions(deploymentConditions []appsv1.DeploymentCondition)
- func (k *KogitoServiceStatus) SetExternalURI(uri string)
- func (k *KogitoServiceStatus) SetImage(image string)
- type KogitoServiceStatusInterface
- type Monitoring
- type RuntimeType
Constants ¶
const ( // MonitoringDefaultPath default path MonitoringDefaultPath = "/metrics" // MonitoringDefaultScheme default scheme MonitoringDefaultScheme = "http" )
Variables ¶
This section is empty.
Functions ¶
func GetOpenAPIDefinitions ¶
func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition
Types ¶
type Condition ¶
type Condition struct { Type ConditionType `json:"type"` Status corev1.ConditionStatus `json:"status"` LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"` Reason KogitoServiceConditionReason `json:"reason,omitempty"` Message string `json:"message,omitempty"` }
Condition is the detailed condition for the resource +k8s:openapi-gen=true
func (*Condition) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Condition.
func (*Condition) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConditionMetaInterface ¶
type ConditionMetaInterface interface { SetDeployed() bool SetProvisioning() bool SetFailed(reason KogitoServiceConditionReason, err error) GetConditions() []Condition SetConditions(conditions []Condition) }
ConditionMetaInterface defines the base information for kogito services conditions
type ConditionType ¶
type ConditionType string
ConditionType is the type of condition
const ( // DeployedConditionType - The KogitoService is deployed DeployedConditionType ConditionType = "Deployed" // ProvisioningConditionType - The KogitoService is being provisioned ProvisioningConditionType ConditionType = "Provisioning" // FailedConditionType - The KogitoService is in a failed state FailedConditionType ConditionType = "Failed" )
type ConditionsMeta ¶
type ConditionsMeta struct { // +listType=atomic // History of conditions for the resource // +operator-sdk:gen-csv:customresourcedefinitions.statusDescriptors=true // +operator-sdk:gen-csv:customresourcedefinitions.statusDescriptors.x-descriptors="urn:alm:descriptor:io.kubernetes.conditions" Conditions []Condition `json:"conditions"` }
ConditionsMeta definition of a Condition structure
func (*ConditionsMeta) DeepCopy ¶
func (in *ConditionsMeta) DeepCopy() *ConditionsMeta
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConditionsMeta.
func (*ConditionsMeta) DeepCopyInto ¶
func (in *ConditionsMeta) DeepCopyInto(out *ConditionsMeta)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ConditionsMeta) GetConditions ¶
func (c *ConditionsMeta) GetConditions() []Condition
GetConditions returns the conditions history
func (*ConditionsMeta) SetConditions ¶
func (c *ConditionsMeta) SetConditions(conditions []Condition)
SetConditions sets the conditions history
func (*ConditionsMeta) SetDeployed ¶
func (c *ConditionsMeta) SetDeployed() bool
SetDeployed Updates the condition with the DeployedCondition and True status
func (*ConditionsMeta) SetFailed ¶
func (c *ConditionsMeta) SetFailed(reason KogitoServiceConditionReason, err error)
SetFailed Sets the failed condition with the error reason and message
func (*ConditionsMeta) SetProvisioning ¶
func (c *ConditionsMeta) SetProvisioning() bool
SetProvisioning Sets the condition type to Provisioning and status True if not yet set.
type KogitoCloudEventInfo ¶
type KogitoCloudEventInfo struct { // +operator-sdk:gen-csv:customresourcedefinitions.statusDescriptors=true Type string `json:"type"` // +operator-sdk:gen-csv:customresourcedefinitions.statusDescriptors=true Source string `json:"source,omitempty"` }
KogitoCloudEventInfo describes the CloudEvent information based on the specification
func (*KogitoCloudEventInfo) DeepCopy ¶
func (in *KogitoCloudEventInfo) DeepCopy() *KogitoCloudEventInfo
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KogitoCloudEventInfo.
func (*KogitoCloudEventInfo) DeepCopyInto ¶
func (in *KogitoCloudEventInfo) DeepCopyInto(out *KogitoCloudEventInfo)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KogitoCloudEventsStatus ¶
type KogitoCloudEventsStatus struct { // +optional // +listType=atomic // +operator-sdk:gen-csv:customresourcedefinitions.statusDescriptors=true Consumes []KogitoCloudEventInfo `json:"consumes,omitempty"` // +optional // +listType=atomic // +operator-sdk:gen-csv:customresourcedefinitions.statusDescriptors=true Produces []KogitoCloudEventInfo `json:"produces,omitempty"` }
KogitoCloudEventsStatus describes the CloudEvents that can be produced or consumed by this Kogito Service instance
func (*KogitoCloudEventsStatus) DeepCopy ¶
func (in *KogitoCloudEventsStatus) DeepCopy() *KogitoCloudEventsStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KogitoCloudEventsStatus.
func (*KogitoCloudEventsStatus) DeepCopyInto ¶
func (in *KogitoCloudEventsStatus) DeepCopyInto(out *KogitoCloudEventsStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KogitoProbe ¶
type KogitoProbe struct { // LivenessProbe describes how the Kogito container liveness probe should work // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=false // +optional LivenessProbe corev1.Probe `json:"livenessProbe,omitempty"` // ReadinessProbe describes how the Kogito container readiness probe should work // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=false // +optional ReadinessProbe corev1.Probe `json:"readinessProbe,omitempty"` }
KogitoProbe configure liveness, readiness and startup probes for containers
func (*KogitoProbe) DeepCopy ¶
func (in *KogitoProbe) DeepCopy() *KogitoProbe
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KogitoProbe.
func (*KogitoProbe) DeepCopyInto ¶
func (in *KogitoProbe) DeepCopyInto(out *KogitoProbe)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KogitoRuntime ¶
type KogitoRuntime struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec KogitoRuntimeSpec `json:"spec,omitempty"` Status KogitoRuntimeStatus `json:"status,omitempty"` }
KogitoRuntime is a custom Kogito service. +k8s:openapi-gen=true +kubebuilder:resource:path=kogitoruntimes,scope=Namespaced +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Replicas",type="integer",JSONPath=".spec.replicas",description="Number of replicas set for this service" +kubebuilder:printcolumn:name="Image",type="string",JSONPath=".status.image",description="Image of this service" +kubebuilder:printcolumn:name="Endpoint",type="string",JSONPath=".status.externalURI",description="External URI to access this service" +operator-sdk:gen-csv:customresourcedefinitions.displayName="Kogito service" +operator-sdk:gen-csv:customresourcedefinitions.resources="Deployment,apps/v1,\"A Kubernetes Deployment\"" +operator-sdk:gen-csv:customresourcedefinitions.resources="Route,route.openshift.io/v1,\"A Openshift Route\"" +operator-sdk:gen-csv:customresourcedefinitions.resources="ConfigMap,v1,\"A Kubernetes ConfigMap\"" +operator-sdk:gen-csv:customresourcedefinitions.resources="Service,v1,\"A Kubernetes Service\""
func (*KogitoRuntime) DeepCopy ¶
func (in *KogitoRuntime) DeepCopy() *KogitoRuntime
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KogitoRuntime.
func (*KogitoRuntime) DeepCopyInto ¶
func (in *KogitoRuntime) DeepCopyInto(out *KogitoRuntime)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KogitoRuntime) DeepCopyObject ¶
func (in *KogitoRuntime) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*KogitoRuntime) GetSpec ¶
func (k *KogitoRuntime) GetSpec() KogitoServiceSpecInterface
GetSpec ...
func (*KogitoRuntime) GetStatus ¶
func (k *KogitoRuntime) GetStatus() KogitoServiceStatusInterface
GetStatus ...
type KogitoRuntimeList ¶
type KogitoRuntimeList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []KogitoRuntime `json:"items"` }
KogitoRuntimeList contains a list of KogitoRuntime.
func (*KogitoRuntimeList) DeepCopy ¶
func (in *KogitoRuntimeList) DeepCopy() *KogitoRuntimeList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KogitoRuntimeList.
func (*KogitoRuntimeList) DeepCopyInto ¶
func (in *KogitoRuntimeList) DeepCopyInto(out *KogitoRuntimeList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KogitoRuntimeList) DeepCopyObject ¶
func (in *KogitoRuntimeList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*KogitoRuntimeList) GetItemAt ¶
func (l *KogitoRuntimeList) GetItemAt(index int) KogitoService
GetItemAt ...
func (*KogitoRuntimeList) GetItemsCount ¶
func (l *KogitoRuntimeList) GetItemsCount() int
GetItemsCount ...
type KogitoRuntimeSpec ¶
type KogitoRuntimeSpec struct { KogitoServiceSpec `json:",inline"` // Annotates the pods managed by the operator with the required metadata for Istio to setup its sidecars, enabling the mesh. Defaults to false. // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=true // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.displayName="Enable Istio" // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.x-descriptors="urn:alm:descriptor:com.tectonic.ui:booleanSwitch" EnableIstio bool `json:"enableIstio,omitempty"` // The name of the runtime used, either Quarkus or SpringBoot. // Default value: quarkus // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=true // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.displayName="runtime" // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.x-descriptors="urn:alm:descriptor:com.tectonic.ui:label" // +kubebuilder:validation:Enum=quarkus;springboot Runtime RuntimeType `json:"runtime,omitempty"` }
KogitoRuntimeSpec defines the desired state of KogitoRuntime.
func (*KogitoRuntimeSpec) DeepCopy ¶
func (in *KogitoRuntimeSpec) DeepCopy() *KogitoRuntimeSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KogitoRuntimeSpec.
func (*KogitoRuntimeSpec) DeepCopyInto ¶
func (in *KogitoRuntimeSpec) DeepCopyInto(out *KogitoRuntimeSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KogitoRuntimeSpec) GetRuntime ¶
func (k *KogitoRuntimeSpec) GetRuntime() RuntimeType
GetRuntime ...
type KogitoRuntimeStatus ¶
type KogitoRuntimeStatus struct {
KogitoServiceStatus `json:",inline"`
}
KogitoRuntimeStatus defines the observed state of KogitoRuntime.
func (*KogitoRuntimeStatus) DeepCopy ¶
func (in *KogitoRuntimeStatus) DeepCopy() *KogitoRuntimeStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KogitoRuntimeStatus.
func (*KogitoRuntimeStatus) DeepCopyInto ¶
func (in *KogitoRuntimeStatus) DeepCopyInto(out *KogitoRuntimeStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KogitoService ¶
type KogitoService interface { metav1.Object runtime.Object // GetSpec gets the Kogito Service specification structure. GetSpec() KogitoServiceSpecInterface // GetStatus gets the Kogito Service Status structure. GetStatus() KogitoServiceStatusInterface }
KogitoService defines the interface for any Kogito service that the operator can handle, e.g. Data Index, Jobs Service, Runtimes, etc.
type KogitoServiceConditionReason ¶
type KogitoServiceConditionReason string
KogitoServiceConditionReason is the type of reason
const ( // CreateResourceFailedReason - Unable to create the requested resources CreateResourceFailedReason KogitoServiceConditionReason = "CreateResourceFailed" // KogitoInfraNotReadyReason - Unable to deploy Kogito Infra KogitoInfraNotReadyReason KogitoServiceConditionReason = "KogitoInfraNotReadyReason" // ServiceReconciliationFailure - Unable to determine the error ServiceReconciliationFailure KogitoServiceConditionReason = "ReconciliationFailure" // MessagingIntegrationFailureReason ... MessagingIntegrationFailureReason KogitoServiceConditionReason = "MessagingProvisionFailure" // MonitoringIntegrationFailureReason ... MonitoringIntegrationFailureReason KogitoServiceConditionReason = "MonitoringIntegrationFailure" // InternalServiceNotReachable ... InternalServiceNotReachable KogitoServiceConditionReason = "InternalServiceNotReachable" )
type KogitoServiceList ¶
type KogitoServiceList interface { runtime.Object // GetItemsCount gets the number of items in the list GetItemsCount() int // GetItemAt gets the item at the given index GetItemAt(index int) KogitoService }
KogitoServiceList defines a base interface for Kogito Service list.
type KogitoServiceSpec ¶
type KogitoServiceSpec struct { // Number of replicas that the service will have deployed in the cluster. // Default value: 1. // +optional // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=true // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.displayName="Replicas" // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.x-descriptors="urn:alm:descriptor:com.tectonic.ui:podCount" // +kubebuilder:validation:Minimum=0 Replicas *int32 `json:"replicas,omitempty"` // +optional // +listType=atomic // Environment variables to be added to the runtime container. Keys must be a C_IDENTIFIER. // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=true Env []corev1.EnvVar `json:"env,omitempty"` // +optional // Image definition for the service. Example: "quay.io/kiegroup/kogito-service:latest". // On OpenShift an ImageStream will be created in the current namespace pointing to the given image. // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=true Image string `json:"image,omitempty"` // +optional // A flag indicating that image streams created by Kogito Operator should be configured to allow pulling from insecure registries. // Usable just on OpenShift. // Defaults to 'false'. // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=true // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.displayName="Insecure Image Registry" // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.x-descriptors="urn:alm:descriptor:com.tectonic.ui:booleanSwitch" InsecureImageRegistry bool `json:"insecureImageRegistry,omitempty"` // Defined compute resource requirements for the deployed service. // +optional // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=true // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.x-descriptors="urn:alm:descriptor:com.tectonic.ui:resourceRequirements" Resources corev1.ResourceRequirements `json:"resources,omitempty"` // Additional labels to be added to the Deployment and Pods managed by the operator. // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=true // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.displayName="Additional Deployment Labels" // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.x-descriptors="urn:alm:descriptor:com.tectonic.ui:text" DeploymentLabels map[string]string `json:"deploymentLabels,omitempty"` // Additional labels to be added to the Service managed by the operator. // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=true // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.displayName="Additional Service Labels" // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.x-descriptors="urn:alm:descriptor:com.tectonic.ui:text" ServiceLabels map[string]string `json:"serviceLabels,omitempty"` // +optional // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=true // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.displayName="ConfigMap Properties" // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.x-descriptors="urn:alm:descriptor:com.tectonic.ui:text" // Custom ConfigMap with application.properties file to be mounted for the Kogito service. // The ConfigMap must be created in the same namespace. // Use this property if you need custom properties to be mounted before the application deployment. // If left empty, one will be created for you. Later it can be updated to add any custom properties to apply to the service. PropertiesConfigMap string `json:"propertiesConfigMap,omitempty"` // Infra provides list of dependent KogitoInfra objects. // +optional Infra []string `json:"infra,omitempty"` // Create Service monitor instance to connect with Monitoring service // +optional Monitoring Monitoring `json:"monitoring,omitempty"` // +optional // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=true // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.displayName="Configs" // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.x-descriptors="urn:alm:descriptor:com.tectonic.ui:text" // Application properties that will be set to the service. For example 'MY_VAR: my_value'. Config map[string]string `json:"config,omitempty"` // Configure liveness, readiness and startup probes for containers // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors=false // +optional Probes KogitoProbe `json:"probes,omitempty"` }
KogitoServiceSpec is the basic structure for the Kogito Service specification.
func (*KogitoServiceSpec) AddDeploymentLabel ¶
func (k *KogitoServiceSpec) AddDeploymentLabel(name, value string)
AddDeploymentLabel adds new deployment label. Works also on uninitialized DeploymentLabels field.
func (*KogitoServiceSpec) AddEnvironmentVariable ¶
func (k *KogitoServiceSpec) AddEnvironmentVariable(name, value string)
AddEnvironmentVariable adds new environment variable to service environment variables.
func (*KogitoServiceSpec) AddEnvironmentVariableFromSecret ¶
func (k *KogitoServiceSpec) AddEnvironmentVariableFromSecret(variableName, secretName, secretKey string)
AddEnvironmentVariableFromSecret adds a new environment variable from the secret under the key.
func (*KogitoServiceSpec) AddResourceLimit ¶
func (k *KogitoServiceSpec) AddResourceLimit(name, value string)
AddResourceLimit adds new resource limit. Works also on uninitialized Limits field.
func (*KogitoServiceSpec) AddResourceRequest ¶
func (k *KogitoServiceSpec) AddResourceRequest(name, value string)
AddResourceRequest adds new resource request. Works also on uninitialized Requests field.
func (*KogitoServiceSpec) AddServiceLabel ¶
func (k *KogitoServiceSpec) AddServiceLabel(name, value string)
AddServiceLabel adds new service label. Works also on uninitialized ServiceLabels field.
func (*KogitoServiceSpec) DeepCopy ¶
func (in *KogitoServiceSpec) DeepCopy() *KogitoServiceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KogitoServiceSpec.
func (*KogitoServiceSpec) DeepCopyInto ¶
func (in *KogitoServiceSpec) DeepCopyInto(out *KogitoServiceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KogitoServiceSpec) GetConfig ¶
func (k *KogitoServiceSpec) GetConfig() map[string]string
GetConfig ...
func (*KogitoServiceSpec) GetDeploymentLabels ¶
func (k *KogitoServiceSpec) GetDeploymentLabels() map[string]string
GetDeploymentLabels ...
func (*KogitoServiceSpec) GetEnvs ¶
func (k *KogitoServiceSpec) GetEnvs() []corev1.EnvVar
GetEnvs ...
func (*KogitoServiceSpec) GetMonitoring ¶
func (k *KogitoServiceSpec) GetMonitoring() Monitoring
GetMonitoring ...
func (*KogitoServiceSpec) GetProbes ¶
func (k *KogitoServiceSpec) GetProbes() KogitoProbe
GetProbes ...
func (*KogitoServiceSpec) GetPropertiesConfigMap ¶
func (k *KogitoServiceSpec) GetPropertiesConfigMap() string
GetPropertiesConfigMap ...
func (*KogitoServiceSpec) GetReplicas ¶
func (k *KogitoServiceSpec) GetReplicas() *int32
GetReplicas ...
func (*KogitoServiceSpec) GetResources ¶
func (k *KogitoServiceSpec) GetResources() corev1.ResourceRequirements
GetResources ...
func (*KogitoServiceSpec) GetServiceLabels ¶
func (k *KogitoServiceSpec) GetServiceLabels() map[string]string
GetServiceLabels ...
func (*KogitoServiceSpec) IsInsecureImageRegistry ¶
func (k *KogitoServiceSpec) IsInsecureImageRegistry() bool
IsInsecureImageRegistry ...
func (*KogitoServiceSpec) SetDeploymentLabels ¶
func (k *KogitoServiceSpec) SetDeploymentLabels(labels map[string]string)
SetDeploymentLabels ...
func (*KogitoServiceSpec) SetEnvs ¶
func (k *KogitoServiceSpec) SetEnvs(envs []corev1.EnvVar)
SetEnvs ...
func (*KogitoServiceSpec) SetImage ¶
func (k *KogitoServiceSpec) SetImage(image string)
SetImage ...
func (*KogitoServiceSpec) SetReplicas ¶
func (k *KogitoServiceSpec) SetReplicas(replicas int32)
SetReplicas ...
func (*KogitoServiceSpec) SetResources ¶
func (k *KogitoServiceSpec) SetResources(resources corev1.ResourceRequirements)
SetResources ...
func (*KogitoServiceSpec) SetServiceLabels ¶
func (k *KogitoServiceSpec) SetServiceLabels(labels map[string]string)
SetServiceLabels ...
type KogitoServiceSpecInterface ¶
type KogitoServiceSpecInterface interface { GetReplicas() *int32 SetReplicas(replicas int32) GetEnvs() []corev1.EnvVar SetEnvs(envs []corev1.EnvVar) AddEnvironmentVariable(name, value string) AddEnvironmentVariableFromSecret(variableName, secretName, secretKey string) GetImage() string SetImage(image string) GetResources() corev1.ResourceRequirements SetResources(resources corev1.ResourceRequirements) AddResourceRequest(name, value string) AddResourceLimit(name, value string) GetDeploymentLabels() map[string]string SetDeploymentLabels(labels map[string]string) AddDeploymentLabel(name, value string) GetServiceLabels() map[string]string SetServiceLabels(labels map[string]string) AddServiceLabel(name, value string) GetRuntime() RuntimeType IsInsecureImageRegistry() bool GetPropertiesConfigMap() string GetInfra() []string AddInfra(name string) GetMonitoring() Monitoring GetConfig() map[string]string GetProbes() KogitoProbe }
KogitoServiceSpecInterface defines the interface for the Kogito service specification, it's the basic structure for any Kogito service.
type KogitoServiceStatus ¶
type KogitoServiceStatus struct { ConditionsMeta `json:",inline"` // General conditions for the Kogito Service deployment. // +operator-sdk:gen-csv:customresourcedefinitions.statusDescriptors=true // +operator-sdk:gen-csv:customresourcedefinitions.specDescriptors.displayName="Deployment Conditions" // +operator-sdk:gen-csv:customresourcedefinitions.statusDescriptors.x-descriptors="urn:alm:descriptor:io.kubernetes.conditions" DeploymentConditions []appsv1.DeploymentCondition `json:"deploymentConditions,omitempty"` // Image is the resolved image for this service. // +operator-sdk:gen-csv:customresourcedefinitions.statusDescriptors=true Image string `json:"image,omitempty"` // URI is where the service is exposed. // +operator-sdk:gen-csv:customresourcedefinitions.statusDescriptors=true // +operator-sdk:gen-csv:customresourcedefinitions.statusDescriptors.x-descriptors="urn:alm:descriptor:org.w3:link" ExternalURI string `json:"externalURI,omitempty"` // Describes the CloudEvents that this instance can consume or produce // +operator-sdk:gen-csv:customresourcedefinitions.statusDescriptors=true CloudEvents KogitoCloudEventsStatus `json:"cloudEvents,omitempty"` }
KogitoServiceStatus is the basic structure for any Kogito Service status.
func (*KogitoServiceStatus) DeepCopy ¶
func (in *KogitoServiceStatus) DeepCopy() *KogitoServiceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KogitoServiceStatus.
func (*KogitoServiceStatus) DeepCopyInto ¶
func (in *KogitoServiceStatus) DeepCopyInto(out *KogitoServiceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KogitoServiceStatus) GetCloudEvents ¶
func (k *KogitoServiceStatus) GetCloudEvents() KogitoCloudEventsStatus
GetCloudEvents ...
func (*KogitoServiceStatus) GetDeploymentConditions ¶
func (k *KogitoServiceStatus) GetDeploymentConditions() []appsv1.DeploymentCondition
GetDeploymentConditions gets the deployment conditions for the service.
func (*KogitoServiceStatus) GetExternalURI ¶
func (k *KogitoServiceStatus) GetExternalURI() string
GetExternalURI ...
func (*KogitoServiceStatus) SetCloudEvents ¶
func (k *KogitoServiceStatus) SetCloudEvents(cloudEvents KogitoCloudEventsStatus)
SetCloudEvents ...
func (*KogitoServiceStatus) SetDeploymentConditions ¶
func (k *KogitoServiceStatus) SetDeploymentConditions(deploymentConditions []appsv1.DeploymentCondition)
SetDeploymentConditions sets the deployment conditions for the service.
func (*KogitoServiceStatus) SetExternalURI ¶
func (k *KogitoServiceStatus) SetExternalURI(uri string)
SetExternalURI ...
func (*KogitoServiceStatus) SetImage ¶
func (k *KogitoServiceStatus) SetImage(image string)
SetImage ...
type KogitoServiceStatusInterface ¶
type KogitoServiceStatusInterface interface { ConditionMetaInterface GetDeploymentConditions() []appsv1.DeploymentCondition SetDeploymentConditions(deploymentConditions []appsv1.DeploymentCondition) GetImage() string SetImage(image string) GetExternalURI() string SetExternalURI(uri string) GetCloudEvents() KogitoCloudEventsStatus SetCloudEvents(cloudEvents KogitoCloudEventsStatus) }
KogitoServiceStatusInterface defines the basic interface for the Kogito Service status.
type Monitoring ¶
type Monitoring struct { // HTTP scheme to use for scraping. // +optional Scheme string `json:"scheme,omitempty"` // HTTP path to scrape for metrics. // +optional Path string `json:"path,omitempty"` }
Monitoring properties to connect with Monitoring service
func (*Monitoring) DeepCopy ¶
func (in *Monitoring) DeepCopy() *Monitoring
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Monitoring.
func (*Monitoring) DeepCopyInto ¶
func (in *Monitoring) DeepCopyInto(out *Monitoring)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RuntimeType ¶
type RuntimeType string
RuntimeType - type of condition.
const ( // QuarkusRuntimeType Runtime for quarkus application QuarkusRuntimeType RuntimeType = "quarkus" // SpringBootRuntimeType Runtime for springboot application SpringBootRuntimeType RuntimeType = "springboot" )