commontypes

package
v1.0.4 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AstarteAPISpec 

type AstarteAPISpec struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	SSL  *bool  `json:"ssl,omitempty"`
	Host string `json:"host"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteAPISpec) DeepCopy 

func (in *AstarteAPISpec) DeepCopy() *AstarteAPISpec

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

func (*AstarteAPISpec) DeepCopyInto 

func (in *AstarteAPISpec) DeepCopyInto(out *AstarteAPISpec)

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

func (*AstarteAPISpec) DeepCopyObject 

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

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

type AstarteAppengineAPISpec 

type AstarteAppengineAPISpec struct {
	metav1.TypeMeta       `json:",inline"`
	AstarteGenericAPISpec `json:",inline"`
	// +kubebuilder:validation:Minimum=100
	// +optional
	MaxResultsLimit *int `json:"maxResultsLimit,omitempty"`
	// Configures the name of the Room Events queue. Should be configured only in installations with a highly
	// customized RabbitMQ. It is advised to leave empty unless you know exactly what you're doing.
	// +optional
	RoomEventsQueueName string `json:"roomEventsQueueName,omitempty"`
	// Configures the name of the Room Events exchange. Should be configured only in installations with a highly
	// customized RabbitMQ. It is advised to leave empty unless you know exactly what you're doing.
	// +optional
	RoomEventsExchangeName string `json:"roomEventsExchangeName,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteAppengineAPISpec) DeepCopy 

func (in *AstarteAppengineAPISpec) DeepCopy() *AstarteAppengineAPISpec

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

func (*AstarteAppengineAPISpec) DeepCopyInto 

func (in *AstarteAppengineAPISpec) DeepCopyInto(out *AstarteAppengineAPISpec)

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

func (*AstarteAppengineAPISpec) DeepCopyObject 

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

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

type AstarteCFSSLCARootConfigSigningCAConstraintSpec 

type AstarteCFSSLCARootConfigSigningCAConstraintSpec struct {
	metav1.TypeMeta `json:",inline"`
	MaxPathLen      int  `json:"max_path_len"`
	IsCA            bool `json:"is_ca"`
	MaxPathLenZero  bool `json:"max_path_len_zero"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteCFSSLCARootConfigSigningCAConstraintSpec) DeepCopy 

func (in *AstarteCFSSLCARootConfigSigningCAConstraintSpec) DeepCopy() *AstarteCFSSLCARootConfigSigningCAConstraintSpec

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

func (*AstarteCFSSLCARootConfigSigningCAConstraintSpec) DeepCopyInto 

func (in *AstarteCFSSLCARootConfigSigningCAConstraintSpec) DeepCopyInto(out *AstarteCFSSLCARootConfigSigningCAConstraintSpec)

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

func (*AstarteCFSSLCARootConfigSigningCAConstraintSpec) DeepCopyObject 

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

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

type AstarteCFSSLCARootConfigSigningDefaultSpec 

type AstarteCFSSLCARootConfigSigningDefaultSpec struct {
	metav1.TypeMeta `json:",inline"`
	Usages          []string                                         `json:"usages"`
	Expiry          string                                           `json:"expiry"`
	CAConstraint    *AstarteCFSSLCARootConfigSigningCAConstraintSpec `json:"ca_constraint"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteCFSSLCARootConfigSigningDefaultSpec) DeepCopy 

func (in *AstarteCFSSLCARootConfigSigningDefaultSpec) DeepCopy() *AstarteCFSSLCARootConfigSigningDefaultSpec

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

func (*AstarteCFSSLCARootConfigSigningDefaultSpec) DeepCopyInto 

func (in *AstarteCFSSLCARootConfigSigningDefaultSpec) DeepCopyInto(out *AstarteCFSSLCARootConfigSigningDefaultSpec)

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

func (*AstarteCFSSLCARootConfigSigningDefaultSpec) DeepCopyObject 

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

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

type AstarteCFSSLCARootConfigSigningSpec 

type AstarteCFSSLCARootConfigSigningSpec struct {
	metav1.TypeMeta `json:",inline"`
	Default         *AstarteCFSSLCARootConfigSigningDefaultSpec `json:"default"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteCFSSLCARootConfigSigningSpec) DeepCopy 

func (in *AstarteCFSSLCARootConfigSigningSpec) DeepCopy() *AstarteCFSSLCARootConfigSigningSpec

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

func (*AstarteCFSSLCARootConfigSigningSpec) DeepCopyInto 

func (in *AstarteCFSSLCARootConfigSigningSpec) DeepCopyInto(out *AstarteCFSSLCARootConfigSigningSpec)

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

func (*AstarteCFSSLCARootConfigSigningSpec) DeepCopyObject 

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

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

type AstarteCFSSLCARootConfigSpec 

type AstarteCFSSLCARootConfigSpec struct {
	metav1.TypeMeta `json:",inline"`
	Signing         *AstarteCFSSLCARootConfigSigningSpec `json:"signing"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteCFSSLCARootConfigSpec) DeepCopy 

func (in *AstarteCFSSLCARootConfigSpec) DeepCopy() *AstarteCFSSLCARootConfigSpec

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

func (*AstarteCFSSLCARootConfigSpec) DeepCopyInto 

func (in *AstarteCFSSLCARootConfigSpec) DeepCopyInto(out *AstarteCFSSLCARootConfigSpec)

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

func (*AstarteCFSSLCARootConfigSpec) DeepCopyObject 

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

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

type AstarteCFSSLCSRRootCACASpec 

type AstarteCFSSLCSRRootCACASpec struct {
	metav1.TypeMeta `json:",inline"`
	Expiry          string `json:"expiry"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteCFSSLCSRRootCACASpec) DeepCopy 

func (in *AstarteCFSSLCSRRootCACASpec) DeepCopy() *AstarteCFSSLCSRRootCACASpec

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

func (*AstarteCFSSLCSRRootCACASpec) DeepCopyInto 

func (in *AstarteCFSSLCSRRootCACASpec) DeepCopyInto(out *AstarteCFSSLCSRRootCACASpec)

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

func (*AstarteCFSSLCSRRootCACASpec) DeepCopyObject 

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

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

type AstarteCFSSLCSRRootCAKeySpec 

type AstarteCFSSLCSRRootCAKeySpec struct {
	metav1.TypeMeta `json:",inline"`
	Algo            string `json:"algo"`
	Size            int    `json:"size"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteCFSSLCSRRootCAKeySpec) DeepCopy 

func (in *AstarteCFSSLCSRRootCAKeySpec) DeepCopy() *AstarteCFSSLCSRRootCAKeySpec

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

func (*AstarteCFSSLCSRRootCAKeySpec) DeepCopyInto 

func (in *AstarteCFSSLCSRRootCAKeySpec) DeepCopyInto(out *AstarteCFSSLCSRRootCAKeySpec)

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

func (*AstarteCFSSLCSRRootCAKeySpec) DeepCopyObject 

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

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

type AstarteCFSSLCSRRootCANamesSpec 

type AstarteCFSSLCSRRootCANamesSpec struct {
	metav1.TypeMeta `json:",inline"`
	C               string `json:"C"`
	L               string `json:"L"`
	O               string `json:"O"`
	OU              string `json:"OU"`
	ST              string `json:"ST"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteCFSSLCSRRootCANamesSpec) DeepCopy 

func (in *AstarteCFSSLCSRRootCANamesSpec) DeepCopy() *AstarteCFSSLCSRRootCANamesSpec

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

func (*AstarteCFSSLCSRRootCANamesSpec) DeepCopyInto 

func (in *AstarteCFSSLCSRRootCANamesSpec) DeepCopyInto(out *AstarteCFSSLCSRRootCANamesSpec)

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

func (*AstarteCFSSLCSRRootCANamesSpec) DeepCopyObject 

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

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

type AstarteCFSSLCSRRootCASpec 

type AstarteCFSSLCSRRootCASpec struct {
	metav1.TypeMeta `json:",inline"`
	CN              string                           `json:"CN"`
	Key             *AstarteCFSSLCSRRootCAKeySpec    `json:"key"`
	Names           []AstarteCFSSLCSRRootCANamesSpec `json:"names"`
	CA              *AstarteCFSSLCSRRootCACASpec     `json:"ca"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteCFSSLCSRRootCASpec) DeepCopy 

func (in *AstarteCFSSLCSRRootCASpec) DeepCopy() *AstarteCFSSLCSRRootCASpec

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

func (*AstarteCFSSLCSRRootCASpec) DeepCopyInto 

func (in *AstarteCFSSLCSRRootCASpec) DeepCopyInto(out *AstarteCFSSLCSRRootCASpec)

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

func (*AstarteCFSSLCSRRootCASpec) DeepCopyObject 

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

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

type AstarteCFSSLDBConfigSpec 

type AstarteCFSSLDBConfigSpec struct {
	metav1.TypeMeta `json:",inline"`
	Driver          string `json:"driver,omitempty"`
	DataSource      string `json:"dataSource,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteCFSSLDBConfigSpec) DeepCopy 

func (in *AstarteCFSSLDBConfigSpec) DeepCopy() *AstarteCFSSLDBConfigSpec

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

func (*AstarteCFSSLDBConfigSpec) DeepCopyInto 

func (in *AstarteCFSSLDBConfigSpec) DeepCopyInto(out *AstarteCFSSLDBConfigSpec)

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

func (*AstarteCFSSLDBConfigSpec) DeepCopyObject 

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

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

type AstarteCFSSLSpec 

type AstarteCFSSLSpec struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	Deploy *bool `json:"deploy,omitempty"`
	// +optional
	URL string `json:"url,omitempty"`
	// +optional
	CaExpiry string `json:"caExpiry,omitempty"`
	// +optional
	CASecret v1.LocalObjectReference `json:"caSecret,omitempty"`
	// +optional
	CertificateExpiry string `json:"certificateExpiry,omitempty"`
	// +optional
	DBConfig *AstarteCFSSLDBConfigSpec `json:"dbConfig,omitempty"`
	// Compute Resources for this Component.
	// +optional
	Resources *v1.ResourceRequirements `json:"resources,omitempty"`
	// +optional
	Version string `json:"version,omitempty"`
	// +optional
	Image string `json:"image,omitempty"`
	// +optional
	Storage *AstartePersistentStorageSpec `json:"storage,omitempty"`
	// +optional
	CSRRootCa *AstarteCFSSLCSRRootCASpec `json:"csrRootCa,omitempty"`
	// +optional
	CARootConfig *AstarteCFSSLCARootConfigSpec `json:"caRootConfig,omitempty"`
	// Additional labels for this Component's pod(s).
	// Label keys can't be of the form "app", "component", "astarte-*", "flow-*"
	// +optional
	PodLabels map[string]string `json:"podLabels,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteCFSSLSpec) DeepCopy 

func (in *AstarteCFSSLSpec) DeepCopy() *AstarteCFSSLSpec

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

func (*AstarteCFSSLSpec) DeepCopyInto 

func (in *AstarteCFSSLSpec) DeepCopyInto(out *AstarteCFSSLSpec)

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

func (*AstarteCFSSLSpec) DeepCopyObject 

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

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

func (AstarteCFSSLSpec) GetPodLabels added in v1.0.3 

func (r AstarteCFSSLSpec) GetPodLabels() map[string]string

type AstarteCassandraConnectionSpec 

type AstarteCassandraConnectionSpec struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	PoolSize *int `json:"poolSize,omitempty"`
	// +optional
	Autodiscovery *bool `json:"autodiscovery,omitempty"`
	// +optional
	SSLConfiguration AstarteCassandraSSLConfigurationSpec `json:"sslConfiguration,omitempty"`
	// +optional
	Secret *LoginCredentialsSecret `json:"secret,omitempty"`
	// +optional
	Username string `json:"username,omitempty"`
	// +optional
	Password string `json:"password,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteCassandraConnectionSpec) DeepCopy 

func (in *AstarteCassandraConnectionSpec) DeepCopy() *AstarteCassandraConnectionSpec

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

func (*AstarteCassandraConnectionSpec) DeepCopyInto 

func (in *AstarteCassandraConnectionSpec) DeepCopyInto(out *AstarteCassandraConnectionSpec)

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

func (*AstarteCassandraConnectionSpec) DeepCopyObject 

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

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

type AstarteCassandraSSLConfigurationSpec 

type AstarteCassandraSSLConfigurationSpec struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	Enabled bool `json:"enabled,omitempty"`
	// +optional
	CustomCASecret v1.LocalObjectReference `json:"customCASecret,omitempty"`
	// +optional
	SNI *bool `json:"sni,omitempty"`
	// +optional
	CustomSNI string `json:"customSNI,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteCassandraSSLConfigurationSpec) DeepCopy 

func (in *AstarteCassandraSSLConfigurationSpec) DeepCopy() *AstarteCassandraSSLConfigurationSpec

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

func (*AstarteCassandraSSLConfigurationSpec) DeepCopyInto 

func (in *AstarteCassandraSSLConfigurationSpec) DeepCopyInto(out *AstarteCassandraSSLConfigurationSpec)

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

func (*AstarteCassandraSSLConfigurationSpec) DeepCopyObject 

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

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

type AstarteCassandraSpec 

type AstarteCassandraSpec struct {
	metav1.TypeMeta                 `json:",inline"`
	AstarteGenericClusteredResource `json:",inline"`
	// +optional
	Nodes string `json:"nodes,omitempty"`
	// +optional
	MaxHeapSize string `json:"maxHeapSize,omitempty"`
	// +optional
	HeapNewSize string `json:"heapNewSize,omitempty"`
	// +optional
	Storage *AstartePersistentStorageSpec `json:"storage,omitempty"`
	// +optional
	Connection *AstarteCassandraConnectionSpec `json:"connection,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteCassandraSpec) DeepCopy 

func (in *AstarteCassandraSpec) DeepCopy() *AstarteCassandraSpec

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

func (*AstarteCassandraSpec) DeepCopyInto 

func (in *AstarteCassandraSpec) DeepCopyInto(out *AstarteCassandraSpec)

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

func (*AstarteCassandraSpec) DeepCopyObject 

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

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

type AstarteClusterHealth 

type AstarteClusterHealth string

AstarteClusterHealth represents the overall health of the cluster 

const (
	// AstarteClusterHealthRed means the cluster is experiencing serious malfunctions or is down
	AstarteClusterHealthRed AstarteClusterHealth = "red"
	// AstarteClusterHealthYellow means the cluster is experiencing downtimes related to a single service
	AstarteClusterHealthYellow AstarteClusterHealth = "yellow"
	// AstarteClusterHealthGreen means the cluster is healthy, up and running
	AstarteClusterHealthGreen AstarteClusterHealth = "green"
)

type AstarteComponent 

type AstarteComponent string

AstarteComponent describes an internal Astarte Component 

const (
	// AppEngineAPI represents Astarte AppEngine API
	AppEngineAPI AstarteComponent = "appengine_api"
	// DataUpdaterPlant represents Astarte Data Updater Plant
	DataUpdaterPlant AstarteComponent = "data_updater_plant"
	// FlowComponent represents Astarte Flow
	FlowComponent AstarteComponent = "flow"
	// Housekeeping represents Astarte Housekeeping
	Housekeeping AstarteComponent = "housekeeping"
	// HousekeepingAPI represents Astarte Housekeeping API
	HousekeepingAPI AstarteComponent = "housekeeping_api"
	// Pairing represents Astarte Pairing
	Pairing AstarteComponent = "pairing"
	// PairingAPI represents Astarte Pairing API
	PairingAPI AstarteComponent = "pairing_api"
	// RealmManagement represents Astarte Realm Management
	RealmManagement AstarteComponent = "realm_management"
	// RealmManagementAPI represents Astarte Realm Management API
	RealmManagementAPI AstarteComponent = "realm_management_api"
	// TriggerEngine represents Astarte Trigger Engine
	TriggerEngine AstarteComponent = "trigger_engine"
	// Dashboard represents Astarte Dashboard
	Dashboard AstarteComponent = "dashboard"
)

func (*AstarteComponent) DashedString 

func (a *AstarteComponent) DashedString() string

DashedString returns the Astarte Component in a Kubernetes-friendly format, e.g: data-updater-plant instead of data_updater_plant

func (*AstarteComponent) DockerImageName 

func (a *AstarteComponent) DockerImageName() string

DockerImageName returns the Docker Image name for this Astarte Component

func (*AstarteComponent) ServiceName 

func (a *AstarteComponent) ServiceName() string

ServiceName returns the Kubernetes Service Name associated to this Astarte component.

func (*AstarteComponent) ServiceRelativePath 

func (a *AstarteComponent) ServiceRelativePath() string

ServiceRelativePath returns the relative path where the service will be served by the Astarte Voyager Ingress. This will return a meaningful value only for API components or the Dashboard.

func (*AstarteComponent) String 

func (a *AstarteComponent) String() string

type AstarteComponentsSpec 

type AstarteComponentsSpec struct {
	metav1.TypeMeta `json:",inline"`
	// Compute Resources for this Component.
	// +optional
	Resources *v1.ResourceRequirements `json:"resources,omitempty"`
	// +optional
	Flow AstarteGenericAPISpec `json:"flow,omitempty"`
	// +optional
	Housekeeping AstarteGenericComponentSpec `json:"housekeeping,omitempty"`
	// +optional
	RealmManagement AstarteGenericComponentSpec `json:"realmManagement,omitempty"`
	// +optional
	Pairing AstarteGenericComponentSpec `json:"pairing,omitempty"`
	// +optional
	DataUpdaterPlant AstarteDataUpdaterPlantSpec `json:"dataUpdaterPlant,omitempty"`
	// +optional
	AppengineAPI AstarteAppengineAPISpec `json:"appengineApi,omitempty"`
	// +optional
	TriggerEngine AstarteTriggerEngineSpec `json:"triggerEngine,omitempty"`
	// +optional
	Dashboard AstarteDashboardSpec `json:"dashboard,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteComponentsSpec) DeepCopy 

func (in *AstarteComponentsSpec) DeepCopy() *AstarteComponentsSpec

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

func (*AstarteComponentsSpec) DeepCopyInto 

func (in *AstarteComponentsSpec) DeepCopyInto(out *AstarteComponentsSpec)

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

func (*AstarteComponentsSpec) DeepCopyObject 

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

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

type AstarteDashboardConfigAuthSpec 

type AstarteDashboardConfigAuthSpec struct {
	metav1.TypeMeta `json:",inline"`
	Type            string `json:"type"`
	// +optional
	OAuthAPIURL string `json:"oauth_api_url,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteDashboardConfigAuthSpec) DeepCopy 

func (in *AstarteDashboardConfigAuthSpec) DeepCopy() *AstarteDashboardConfigAuthSpec

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

func (*AstarteDashboardConfigAuthSpec) DeepCopyInto 

func (in *AstarteDashboardConfigAuthSpec) DeepCopyInto(out *AstarteDashboardConfigAuthSpec)

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

func (*AstarteDashboardConfigAuthSpec) DeepCopyObject 

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

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

type AstarteDashboardConfigSpec 

type AstarteDashboardConfigSpec struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	RealmManagementAPIURL string `json:"realmManagementApiUrl,omitempty"`
	// +optional
	AppEngineAPIURL string `json:"appEngineApiUrl,omitempty"`
	// +optional
	PairingAPIURL string `json:"pairingApiUrl,omitempty"`
	// +optional
	FlowAPIURL string `json:"flowApiUrl,omitempty"`
	// +optional
	DefaultRealm string `json:"defaultRealm,omitempty"`
	// +optional
	DefaultAuth string `json:"defaultAuth,omitempty"`
	// +optional
	Auth []AstarteDashboardConfigAuthSpec `json:"auth,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteDashboardConfigSpec) DeepCopy 

func (in *AstarteDashboardConfigSpec) DeepCopy() *AstarteDashboardConfigSpec

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

func (*AstarteDashboardConfigSpec) DeepCopyInto 

func (in *AstarteDashboardConfigSpec) DeepCopyInto(out *AstarteDashboardConfigSpec)

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

func (*AstarteDashboardConfigSpec) DeepCopyObject 

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

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

type AstarteDashboardSpec 

type AstarteDashboardSpec struct {
	metav1.TypeMeta                 `json:",inline"`
	AstarteGenericClusteredResource `json:",inline"`
	// +optional
	Config AstarteDashboardConfigSpec `json:",inline"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteDashboardSpec) DeepCopy 

func (in *AstarteDashboardSpec) DeepCopy() *AstarteDashboardSpec

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

func (*AstarteDashboardSpec) DeepCopyInto 

func (in *AstarteDashboardSpec) DeepCopyInto(out *AstarteDashboardSpec)

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

func (*AstarteDashboardSpec) DeepCopyObject 

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

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

type AstarteDataUpdaterPlantSpec 

type AstarteDataUpdaterPlantSpec struct {
	metav1.TypeMeta                 `json:",inline"`
	AstarteGenericClusteredResource `json:",inline"`
	// +optional
	DataQueueCount *int `json:"dataQueueCount,omitempty"`
	// Controls the prefetch count for Data Updater Plant. When fine-tuning Astarte, this parameter
	// can make a difference for what concerns Data Updater Plant ingestion performance. However,
	// it can also degrade performance significantly and/or increase risk of data loss when misconfigured.
	// Configure this value only if you know what you're doing and you have experience with RabbitMQ.
	// Defaults to 300
	// +optional
	PrefetchCount *int `json:"prefetchCount,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteDataUpdaterPlantSpec) DeepCopy 

func (in *AstarteDataUpdaterPlantSpec) DeepCopy() *AstarteDataUpdaterPlantSpec

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

func (*AstarteDataUpdaterPlantSpec) DeepCopyInto 

func (in *AstarteDataUpdaterPlantSpec) DeepCopyInto(out *AstarteDataUpdaterPlantSpec)

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

func (*AstarteDataUpdaterPlantSpec) DeepCopyObject 

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

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

type AstarteFeatures 

type AstarteFeatures struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	RealmDeletion bool `json:"realmDeletion,omitempty"`
}

AstarteFeatures enables/disables selectively a set of global features in Astarte +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteFeatures) DeepCopy 

func (in *AstarteFeatures) DeepCopy() *AstarteFeatures

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

func (*AstarteFeatures) DeepCopyInto 

func (in *AstarteFeatures) DeepCopyInto(out *AstarteFeatures)

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

func (*AstarteFeatures) DeepCopyObject 

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

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

type AstarteGenericAPISpec 

type AstarteGenericAPISpec struct {
	metav1.TypeMeta                 `json:",inline"`
	AstarteGenericClusteredResource `json:",inline"`
	// +optional
	DisableAuthentication *bool `json:"disableAuthentication,omitempty"`
}

AstarteGenericAPISpec represents a generic Astarte API Component in the Deployment spec +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteGenericAPISpec) DeepCopy 

func (in *AstarteGenericAPISpec) DeepCopy() *AstarteGenericAPISpec

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

func (*AstarteGenericAPISpec) DeepCopyInto 

func (in *AstarteGenericAPISpec) DeepCopyInto(out *AstarteGenericAPISpec)

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

func (*AstarteGenericAPISpec) DeepCopyObject 

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

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

type AstarteGenericClusteredResource 

type AstarteGenericClusteredResource struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	Deploy *bool `json:"deploy,omitempty"`
	// +optional
	Replicas *int32 `json:"replicas,omitempty"`
	// +optional
	AntiAffinity *bool `json:"antiAffinity,omitempty"`
	// +optional
	CustomAffinity *v1.Affinity `json:"customAffinity,omitempty"`
	// +optional
	DeploymentStrategy *appsv1.DeploymentStrategy `json:"deploymentStrategy,omitempty"`
	// +optional
	Version string `json:"version,omitempty"`
	// +optional
	Image string `json:"image,omitempty"`
	// Compute Resources for this Component.
	// +optional
	Resources *v1.ResourceRequirements `json:"resources,omitempty"`
	// Additional environment variables for this Component
	// +optional
	AdditionalEnv []v1.EnvVar `json:"additionalEnv,omitempty"`
	// Additional labels for this Component's pod(s).
	// Label keys can't be of the form "app", "component", "astarte-*", "flow-*"
	// +optional
	PodLabels map[string]string `json:"podLabels,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteGenericClusteredResource) DeepCopy 

func (in *AstarteGenericClusteredResource) DeepCopy() *AstarteGenericClusteredResource

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

func (*AstarteGenericClusteredResource) DeepCopyInto 

func (in *AstarteGenericClusteredResource) DeepCopyInto(out *AstarteGenericClusteredResource)

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

func (*AstarteGenericClusteredResource) DeepCopyObject 

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

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

func (AstarteGenericClusteredResource) GetPodLabels added in v1.0.3 

func (r AstarteGenericClusteredResource) GetPodLabels() map[string]string

type AstarteGenericComponentSpec 

type AstarteGenericComponentSpec struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	API AstarteGenericAPISpec `json:"api,omitempty"`
	// +optional
	Backend AstarteGenericClusteredResource `json:"backend,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteGenericComponentSpec) DeepCopy 

func (in *AstarteGenericComponentSpec) DeepCopy() *AstarteGenericComponentSpec

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

func (*AstarteGenericComponentSpec) DeepCopyInto 

func (in *AstarteGenericComponentSpec) DeepCopyInto(out *AstarteGenericComponentSpec)

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

func (*AstarteGenericComponentSpec) DeepCopyObject 

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

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

type AstarteGenericIngressSpec 

type AstarteGenericIngressSpec struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	Deploy *bool `json:"deploy,omitempty"`
	// +optional
	Replicas *int32 `json:"replicas,omitempty"`
	// +optional
	Type string `json:"type,omitempty"`
	// +optional
	LoadBalancerIP string `json:"loadBalancerIp,omitempty"`
	// +optional
	NodeSelector string `json:"nodeSelector,omitempty"`
	// +optional
	TLSSecret string `json:"tlsSecret,omitempty"`
	// +optional
	TLSRef *voyager.LocalTypedReference `json:"tlsRef,omitempty"`
	// +optional
	AnnotationsService map[string]string `json:"annotationsService,omitempty"`
}

AstarteGenericIngressSpec is a common struct for all Ingresses defined by AstarteVoyagerIngress +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteGenericIngressSpec) DeepCopy 

func (in *AstarteGenericIngressSpec) DeepCopy() *AstarteGenericIngressSpec

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

func (*AstarteGenericIngressSpec) DeepCopyInto 

func (in *AstarteGenericIngressSpec) DeepCopyInto(out *AstarteGenericIngressSpec)

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

func (*AstarteGenericIngressSpec) DeepCopyObject 

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

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

type AstartePersistentStorageSpec 

type AstartePersistentStorageSpec struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	Size *resource.Quantity `json:"size"`
	// +optional
	ClassName string `json:"className,omitempty"`
	// +optional
	VolumeDefinition *v1.Volume `json:"volumeDefinition,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstartePersistentStorageSpec) DeepCopy 

func (in *AstartePersistentStorageSpec) DeepCopy() *AstartePersistentStorageSpec

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

func (*AstartePersistentStorageSpec) DeepCopyInto 

func (in *AstartePersistentStorageSpec) DeepCopyInto(out *AstartePersistentStorageSpec)

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

func (*AstartePersistentStorageSpec) DeepCopyObject 

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

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

type AstarteRabbitMQConnectionSpec 

type AstarteRabbitMQConnectionSpec struct {
	metav1.TypeMeta `json:",inline"`
	Host            string `json:"host"`
	Port            *int16 `json:"port"`
	// +optional
	Username string `json:"username,omitempty"`
	// +optional
	Password string `json:"password,omitempty"`
	// +optional
	VirtualHost string `json:"virtualHost,omitempty"`
	// +optional
	SSLConfiguration AstarteRabbitMQSSLConfigurationSpec `json:"sslConfiguration,omitempty"`
	// +optional
	Secret *LoginCredentialsSecret `json:"secret,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteRabbitMQConnectionSpec) DeepCopy 

func (in *AstarteRabbitMQConnectionSpec) DeepCopy() *AstarteRabbitMQConnectionSpec

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

func (*AstarteRabbitMQConnectionSpec) DeepCopyInto 

func (in *AstarteRabbitMQConnectionSpec) DeepCopyInto(out *AstarteRabbitMQConnectionSpec)

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

func (*AstarteRabbitMQConnectionSpec) DeepCopyObject 

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

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

type AstarteRabbitMQSSLConfigurationSpec 

type AstarteRabbitMQSSLConfigurationSpec struct {
	metav1.TypeMeta `json:",inline"`
	Enabled         bool `json:"enabled"`
	// +optional
	CustomCASecret v1.LocalObjectReference `json:"customCASecret,omitempty"`
	// +optional
	SNI *bool `json:"sni,omitempty"`
	// +optional
	CustomSNI string `json:"customSNI,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteRabbitMQSSLConfigurationSpec) DeepCopy 

func (in *AstarteRabbitMQSSLConfigurationSpec) DeepCopy() *AstarteRabbitMQSSLConfigurationSpec

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

func (*AstarteRabbitMQSSLConfigurationSpec) DeepCopyInto 

func (in *AstarteRabbitMQSSLConfigurationSpec) DeepCopyInto(out *AstarteRabbitMQSSLConfigurationSpec)

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

func (*AstarteRabbitMQSSLConfigurationSpec) DeepCopyObject 

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

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

type AstarteRabbitMQSpec 

type AstarteRabbitMQSpec struct {
	metav1.TypeMeta                 `json:",inline"`
	AstarteGenericClusteredResource `json:",inline"`
	// +optional
	Connection *AstarteRabbitMQConnectionSpec `json:"connection,omitempty"`
	// +optional
	Storage *AstartePersistentStorageSpec `json:"storage,omitempty"`
	// +optional
	AdditionalPlugins []string `json:"additionalPlugins,omitempty"`
	// Configures the data queues prefix on RabbitMQ. You should change this setting only
	// in custom RabbitMQ installations.
	// +optional
	DataQueuesPrefix string `json:"dataQueuesPrefix,omitempty"`
	// Configures the events exchange name on RabbitMQ. You should change this setting only
	// in custom RabbitMQ installations.
	// +optional
	EventsExchangeName string `json:"eventsExchangeName,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteRabbitMQSpec) DeepCopy 

func (in *AstarteRabbitMQSpec) DeepCopy() *AstarteRabbitMQSpec

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

func (*AstarteRabbitMQSpec) DeepCopyInto 

func (in *AstarteRabbitMQSpec) DeepCopyInto(out *AstarteRabbitMQSpec)

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

func (*AstarteRabbitMQSpec) DeepCopyObject 

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

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

type AstarteResourceEvent 

type AstarteResourceEvent string

AstarteResourceEvent represents a v1.Event reason for various events. They are all stated in this enum to ease understanding and as a reference to users. 

const (
	// AstarteResourceEventInconsistentVersion means the requested Astarte version is inconsistent or unexpected
	AstarteResourceEventInconsistentVersion AstarteResourceEvent = "ErrInconsistentVersion"
	// AstarteResourceEventUnsupportedVersion means the requested Astarte version is not supported by the Operator
	AstarteResourceEventUnsupportedVersion AstarteResourceEvent = "ErrUnsupportedVersion"
	// AstarteResourceEventMigration means the current Astarte Resource will be migrated from a previous one
	AstarteResourceEventMigration AstarteResourceEvent = "Migration"
	// AstarteResourceEventReconciliationFailed means there was a temporary failure in resource Reconciliation
	AstarteResourceEventReconciliationFailed AstarteResourceEvent = "ErrReconcile"
	// AstarteResourceEventCriticalError represents an unrecoverable error which requires manual intervention on the cluster
	AstarteResourceEventCriticalError AstarteResourceEvent = "ErrCritical"
	// AstarteResourceEventStatus represents a generic Status event - in common situations, this is the most common event type
	AstarteResourceEventStatus AstarteResourceEvent = "Status"
	// AstarteResourceEventUpgrade represents an event happening during a Cluster Upgrade
	AstarteResourceEventUpgrade AstarteResourceEvent = "Upgrade"
	// AstarteResourceEventUpgradeError represents an error happening during a Cluster Upgrade
	AstarteResourceEventUpgradeError AstarteResourceEvent = "ErrUpgrade"
)

func (AstarteResourceEvent) String 

func (e AstarteResourceEvent) String() string

type AstarteSpec 

type AstarteSpec struct {
	metav1.TypeMeta `json:",inline"`
	// The Astarte Version for this Resource
	Version string `json:"version"`
	// +optional
	ImagePullPolicy *v1.PullPolicy `json:"imagePullPolicy,omitempty"`
	// +optional
	ImagePullSecrets []v1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
	// +optional
	DistributionChannel string `json:"distributionChannel,omitempty"`
	// +optional
	DeploymentStrategy *appsv1.DeploymentStrategy `json:"deploymentStrategy,omitempty"`
	// +optional
	Features AstarteFeatures `json:"features,omitempty"`
	// +optional
	RBAC *bool `json:"rbac,omitempty"`
	// +optional
	StorageClassName string         `json:"storageClassName,omitempty"`
	API              AstarteAPISpec `json:"api"`
	// +optional
	RabbitMQ AstarteRabbitMQSpec `json:"rabbitmq"`
	// +optional
	Cassandra AstarteCassandraSpec `json:"cassandra"`
	VerneMQ   AstarteVerneMQSpec   `json:"vernemq"`
	// +optional
	CFSSL AstarteCFSSLSpec `json:"cfssl"`
	// +optional
	Components AstarteComponentsSpec `json:"components"`
	// +optional
	AstarteSystemKeyspace AstarteSystemKeyspaceSpec `json:"astarteSystemKeyspace,omitempty"`
	// ManualMaintenanceMode pauses all reconciliation activities but still computes the resource
	// status. It should be used only when the managed Astarte resources requires manual intervention
	// and the Operator cannot break out of the problem by itself. Do not set this field unless you
	// know exactly what you are doing.
	// +kubebuilder:default:=false
	// +optional
	ManualMaintenanceMode bool `json:"manualMaintenanceMode,omitempty"`
}

AstarteSpec defines the desired state of Astarte +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteSpec) DeepCopy 

func (in *AstarteSpec) DeepCopy() *AstarteSpec

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

func (*AstarteSpec) DeepCopyInto 

func (in *AstarteSpec) DeepCopyInto(out *AstarteSpec)

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

func (*AstarteSpec) DeepCopyObject 

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

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

type AstarteStatus 

type AstarteStatus struct {
	metav1.TypeMeta     `json:",inline"`
	ReconciliationPhase ReconciliationPhase  `json:"phase,omitempty"`
	AstarteVersion      string               `json:"astarteVersion,omitempty"`
	OperatorVersion     string               `json:"operatorVersion,omitempty"`
	Health              AstarteClusterHealth `json:"health,omitempty"`
	BaseAPIURL          string               `json:"baseAPIURL,omitempty"`
	BrokerURL           string               `json:"brokerURL,omitempty"`
}

AstarteStatus defines the observed state of Astarte +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteStatus) DeepCopy 

func (in *AstarteStatus) DeepCopy() *AstarteStatus

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

func (*AstarteStatus) DeepCopyInto 

func (in *AstarteStatus) DeepCopyInto(out *AstarteStatus)

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

func (*AstarteStatus) DeepCopyObject 

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

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

type AstarteSystemKeyspaceSpec 

type AstarteSystemKeyspaceSpec struct {
	metav1.TypeMeta `json:",inline"`
	// The Replication Factor for the keyspace
	// +optional
	ReplicationFactor int `json:"replicationFactor,omitempty"`
}

astarteSystemKeyspace configures the main system keyspace for Astarte. As of now, these settings have effect only upon cluster initialization, and will be ignored otherwise. +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteSystemKeyspaceSpec) DeepCopy 

func (in *AstarteSystemKeyspaceSpec) DeepCopy() *AstarteSystemKeyspaceSpec

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

func (*AstarteSystemKeyspaceSpec) DeepCopyInto 

func (in *AstarteSystemKeyspaceSpec) DeepCopyInto(out *AstarteSystemKeyspaceSpec)

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

func (*AstarteSystemKeyspaceSpec) DeepCopyObject 

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

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

type AstarteTriggerEngineSpec 

type AstarteTriggerEngineSpec struct {
	metav1.TypeMeta                 `json:",inline"`
	AstarteGenericClusteredResource `json:",inline"`
	// Configures the name of the Events queue. Should be configured only in installations with a highly
	// customized RabbitMQ. It is advised to leave empty unless you know exactly what you're doing.
	// +optional
	EventsQueueName string `json:"eventsQueueName,omitempty"`
	// Configures the routing key for Trigger Events. Should be configured only in installations
	// with a highly customized RabbitMQ and a custom Trigger Engine setup. It is advised to leave
	// empty unless you know exactly what you're doing, misconfiguring this value can cause heavy
	// breakage within Trigger Engine.
	// +optional
	EventsRoutingKey string `json:"eventsRoutingKey,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteTriggerEngineSpec) DeepCopy 

func (in *AstarteTriggerEngineSpec) DeepCopy() *AstarteTriggerEngineSpec

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

func (*AstarteTriggerEngineSpec) DeepCopyInto 

func (in *AstarteTriggerEngineSpec) DeepCopyInto(out *AstarteTriggerEngineSpec)

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

func (*AstarteTriggerEngineSpec) DeepCopyObject 

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

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

type AstarteVerneMQSpec 

type AstarteVerneMQSpec struct {
	metav1.TypeMeta                 `json:",inline"`
	AstarteGenericClusteredResource `json:",inline"`
	Host                            string `json:"host"`
	// +optional
	Port *int16 `json:"port,omitempty"`
	// +optional
	// +optional
	CaSecret string `json:"caSecret,omitempty"`
	// +optional
	Storage *AstartePersistentStorageSpec `json:"storage,omitempty"`
	// Controls the device heartbeat from the broker to Astarte. The heartbeat is sent periodically
	// to prevent Astarte from keeping up stale connections from Devices in case the broker misbehaves
	// and does not send disconnection events. You should usually not tweak this value. Moreover, keep
	// in mind that when a lot of devices are connected simultaneously, having a short heartbeat time
	// might cause performance issues. Defaults to an hour.
	// +optional
	DeviceHeartbeatSeconds int `json:"deviceHeartbeatSeconds,omitempty"`
	// The maximum number of QoS 1 or 2 messages to hold in the offline queue.
	// Defaults to 1000000. Set to -1 for no maximum (not recommended). Set to 0
	// if no messages should be stored offline.
	// +optional
	MaxOfflineMessages *int `json:"maxOfflineMessages,omitempty"`
	// This option allows persistent clients ( = clean session set to
	// false) to be removed if they do not reconnect within 'persistent_client_expiration'.
	// This is a non-standard option. As far as the MQTT specification is concerned,
	// persistent clients persist forever.
	// The expiration period should be an integer followed by one of 'd', 'w', 'm', 'y' for
	// day, week, month, and year.
	// Default: 1 year
	// +optional
	PersistentClientExpiration string `json:"persistentClientExpiration,omitempty"`
	// +optional
	MirrorQueue string `json:"mirrorQueue,omitempty"`
	// This option allows, when true, to handle SSL termination at VerneMQ level.
	// Default: false
	// +optional
	SSLListener *bool `json:"sslListener,omitempty"`
	// Reference the name of the secret containing the TLS certificate for VerneMQ.
	// The secret must be present in the same namespace in which Astarte resides.
	// The field will be used only if SSLListener is set to true.
	// +optional
	SSLListenerCertSecretName string `json:"sslListenerCertSecretName,omitempty"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteVerneMQSpec) DeepCopy 

func (in *AstarteVerneMQSpec) DeepCopy() *AstarteVerneMQSpec

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

func (*AstarteVerneMQSpec) DeepCopyInto 

func (in *AstarteVerneMQSpec) DeepCopyInto(out *AstarteVerneMQSpec)

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

func (*AstarteVerneMQSpec) DeepCopyObject 

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

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

type AstarteVoyagerIngressAPISpec 

type AstarteVoyagerIngressAPISpec struct {
	metav1.TypeMeta           `json:",inline"`
	AstarteGenericIngressSpec `json:",inline"`
	// +optional
	Cors *bool `json:"cors,omitempty"`
	// +optional
	ExposeHousekeeping *bool `json:"exposeHousekeeping,omitempty"`
	// When true, all /metrics endpoints for Astarte services will be served by the Ingress.
	// Beware this might be a security hole. You can control which IPs can access /metrics
	// with serveMetricsToSubnet
	// +optional
	ServeMetrics *bool `json:"serveMetrics,omitempty"`
	// When specified and when serveMetrics is true, /metrics endpoints will be served only to IPs
	// in the provided subnet range. The subnet has to be compatible with the HAProxy
	// ACL src syntax (e.g.: 10.0.0.0/16)
	// +optional
	ServeMetricsToSubnet string `json:"serveMetricsToSubnet,omitempty"`
}

AstarteVoyagerIngressAPISpec defines the specification of the APIs +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteVoyagerIngressAPISpec) DeepCopy 

func (in *AstarteVoyagerIngressAPISpec) DeepCopy() *AstarteVoyagerIngressAPISpec

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

func (*AstarteVoyagerIngressAPISpec) DeepCopyInto 

func (in *AstarteVoyagerIngressAPISpec) DeepCopyInto(out *AstarteVoyagerIngressAPISpec)

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

func (*AstarteVoyagerIngressAPISpec) DeepCopyObject 

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

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

type AstarteVoyagerIngressBrokerSpec 

type AstarteVoyagerIngressBrokerSpec struct {
	metav1.TypeMeta           `json:",inline"`
	AstarteGenericIngressSpec `json:",inline"`
	// +optional
	MaxConnections *int `json:"maxConnections,omitempty"`
}

AstarteVoyagerIngressBrokerSpec defines the specification of the Broker +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteVoyagerIngressBrokerSpec) DeepCopy 

func (in *AstarteVoyagerIngressBrokerSpec) DeepCopy() *AstarteVoyagerIngressBrokerSpec

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

func (*AstarteVoyagerIngressBrokerSpec) DeepCopyInto 

func (in *AstarteVoyagerIngressBrokerSpec) DeepCopyInto(out *AstarteVoyagerIngressBrokerSpec)

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

func (*AstarteVoyagerIngressBrokerSpec) DeepCopyObject 

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

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

type AstarteVoyagerIngressDashboardSpec 

type AstarteVoyagerIngressDashboardSpec struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	SSL *bool `json:"ssl,omitempty"`
	// +optional
	Host string `json:"host,omitempty"`
	// +optional
	TLSSecret string `json:"tlsSecret,omitempty"`
	// +optional
	TLSRef *voyager.LocalTypedReference `json:"tlsRef,omitempty"`
}

AstarteVoyagerIngressDashboardSpec defines the specification of the Dashboard +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteVoyagerIngressDashboardSpec) DeepCopy 

func (in *AstarteVoyagerIngressDashboardSpec) DeepCopy() *AstarteVoyagerIngressDashboardSpec

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

func (*AstarteVoyagerIngressDashboardSpec) DeepCopyInto 

func (in *AstarteVoyagerIngressDashboardSpec) DeepCopyInto(out *AstarteVoyagerIngressDashboardSpec)

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

func (*AstarteVoyagerIngressDashboardSpec) DeepCopyObject 

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

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

type AstarteVoyagerIngressLetsEncryptSpec 

type AstarteVoyagerIngressLetsEncryptSpec struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	Use *bool `json:"use,omitempty"`
	// +optional
	Staging *bool `json:"staging,omitempty"`
	// +optional
	AcmeEmail string `json:"acmeEmail,omitempty"`
	// +optional
	Domains []string `json:"domains,omitempty"`
	// +optional
	AutoHTTPChallenge *bool `json:"autoHTTPChallenge,omitempty"`
	// +optional
	ChallengeProvider voyager.ChallengeProvider `json:"challengeProvider,omitempty"`
}

AstarteVoyagerIngressLetsEncryptSpec defines the specification of the Let's Encrypt Integration +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteVoyagerIngressLetsEncryptSpec) DeepCopy 

func (in *AstarteVoyagerIngressLetsEncryptSpec) DeepCopy() *AstarteVoyagerIngressLetsEncryptSpec

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

func (*AstarteVoyagerIngressLetsEncryptSpec) DeepCopyInto 

func (in *AstarteVoyagerIngressLetsEncryptSpec) DeepCopyInto(out *AstarteVoyagerIngressLetsEncryptSpec)

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

func (*AstarteVoyagerIngressLetsEncryptSpec) DeepCopyObject 

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

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

type AstarteVoyagerIngressSpec 

type AstarteVoyagerIngressSpec struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	ImagePullPolicy *v1.PullPolicy `json:"imagePullPolicy,omitempty"`
	Astarte         string         `json:"astarte"`
	// +optional
	API AstarteVoyagerIngressAPISpec `json:"api,omitempty"`
	// +optional
	Dashboard AstarteVoyagerIngressDashboardSpec `json:"dashboard,omitempty"`
	// +optional
	Broker AstarteVoyagerIngressBrokerSpec `json:"broker,omitempty"`
	// +optional
	Letsencrypt AstarteVoyagerIngressLetsEncryptSpec `json:"letsencrypt,omitempty"`
}

AstarteVoyagerIngressSpec defines the desired state of AstarteVoyagerIngress +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteVoyagerIngressSpec) DeepCopy 

func (in *AstarteVoyagerIngressSpec) DeepCopy() *AstarteVoyagerIngressSpec

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

func (*AstarteVoyagerIngressSpec) DeepCopyInto 

func (in *AstarteVoyagerIngressSpec) DeepCopyInto(out *AstarteVoyagerIngressSpec)

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

func (*AstarteVoyagerIngressSpec) DeepCopyObject 

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

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

type AstarteVoyagerIngressStatus 

type AstarteVoyagerIngressStatus struct {
	metav1.TypeMeta `json:",inline"`
}

AstarteVoyagerIngressStatus defines the observed state of AstarteVoyagerIngress +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*AstarteVoyagerIngressStatus) DeepCopy 

func (in *AstarteVoyagerIngressStatus) DeepCopy() *AstarteVoyagerIngressStatus

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

func (*AstarteVoyagerIngressStatus) DeepCopyInto 

func (in *AstarteVoyagerIngressStatus) DeepCopyInto(out *AstarteVoyagerIngressStatus)

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

func (*AstarteVoyagerIngressStatus) DeepCopyObject 

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

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

type BlockWorker 

type BlockWorker struct {
	metav1.TypeMeta `json:",inline"`
	WorkerID        string       `json:"id"`
	DataProvider    DataProvider `json:"dataProvider"`
}

BlockWorker defines a Worker for a Container Block +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*BlockWorker) DeepCopy 

func (in *BlockWorker) DeepCopy() *BlockWorker

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

func (*BlockWorker) DeepCopyInto 

func (in *BlockWorker) DeepCopyInto(out *BlockWorker)

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

func (*BlockWorker) DeepCopyObject 

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

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

type ContainerBlockSpec 

type ContainerBlockSpec struct {
	metav1.TypeMeta `json:",inline"`
	BlockID         string `json:"id"`
	Image           string `json:"image"`
	// +optional
	ImagePullSecrets []v1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
	// +optional
	Environment []v1.EnvVar `json:"environment"`
	// +optional
	Resources v1.ResourceRequirements `json:"resources"`
	// Configuration represents the JSON string carrying the user configuration for this block
	Configuration string `json:"config"`
	//+kubebuilder:validation:MinItems:=1
	Workers []BlockWorker `json:"workers"`
}

ContainerBlockSpec defines a Container Block in a Flow +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*ContainerBlockSpec) DeepCopy 

func (in *ContainerBlockSpec) DeepCopy() *ContainerBlockSpec

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

func (*ContainerBlockSpec) DeepCopyInto 

func (in *ContainerBlockSpec) DeepCopyInto(out *ContainerBlockSpec)

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

func (*ContainerBlockSpec) DeepCopyObject 

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

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

type DataProvider 

type DataProvider struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	RabbitMQ *RabbitMQDataProvider `json:"rabbitmq,omitempty"`
}

DataProvider is a struct which defines which Data Providers (e.g. Brokers) are available for a Worker +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*DataProvider) DeepCopy 

func (in *DataProvider) DeepCopy() *DataProvider

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

func (*DataProvider) DeepCopyInto 

func (in *DataProvider) DeepCopyInto(out *DataProvider)

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

func (*DataProvider) DeepCopyObject 

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

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

type FlowSpec 

type FlowSpec struct {
	metav1.TypeMeta `json:",inline"`
	Astarte         v1.LocalObjectReference `json:"astarte"`
	AstarteRealm    string                  `json:"astarteRealm"`
	// Defines the amount of non-container blocks in the Flow
	NativeBlocks int `json:"nativeBlocks"`
	// Defines the overall resources consumed by Native Blocks
	NativeBlocksResources v1.ResourceList `json:"nativeBlocksResources"`
	// EE Only: Defines the Flow Pool in which the Flow will be allocated.
	FlowPool        v1.LocalObjectReference `json:"flowPool,omitempty"`
	ContainerBlocks []ContainerBlockSpec    `json:"blocks"`
}

FlowSpec defines the desired state of Flow +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*FlowSpec) DeepCopy 

func (in *FlowSpec) DeepCopy() *FlowSpec

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

func (*FlowSpec) DeepCopyInto 

func (in *FlowSpec) DeepCopyInto(out *FlowSpec)

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

func (*FlowSpec) DeepCopyObject 

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

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

type FlowState 

type FlowState string

FlowState describes the global state of a Flow 

const (
	// FlowStateUnknown represents an Unknown State of the Flow. When in this state, it might
	// have never been reconciled.
	FlowStateUnknown FlowState = ""
	// FlowStateUnstable means the Flow is either reconciling or restarting some of its blocks.
	// It usually transitions to this State before moving to Flowing.
	FlowStateUnstable FlowState = "Unstable"
	// FlowStateUnhealthy means the Flow is currently having some non-transient or unrecoverable errors.
	// Manual intervention might be required.
	FlowStateUnhealthy FlowState = "Unhealthy"
	// FlowStateFlowing means the Flow is currently active and all of its blocks are stable. A healthy flow should stay
	// in this state for most of its lifecycle.
	FlowStateFlowing FlowState = "Flowing"
)

type FlowStatus 

type FlowStatus struct {
	metav1.TypeMeta `json:",inline"`
	// State defines the overall state of the Flow
	State FlowState `json:"state"`
	// Represents the total number of the Container Blocks in the Flow
	TotalContainerBlocks int `json:"totalContainerBlocks"`
	// Represents the total number of Ready Container Blocks in the Flow. In a healthy Flow,
	// this matches the number of Total Container Blocks.
	ReadyContainerBlocks int `json:"readyContainerBlocks"`
	// The overall resources allocated in the cluster for this Block
	Resources v1.ResourceList `json:"resources"`
	// Represents the total number of Container Blocks with non temporary failures. Present only
	// if any of the Blocks is in such state. When present, manual intervention is most likely required.
	// +optional
	FailingContainerBlocks int `json:"failingContainerBlocks,omitempty"`
	// UnrecoverableFailures lists all the ContainerStates of failing containers, for further inspection.
	// +optional
	UnrecoverableFailures []v1.ContainerState `json:"unrecoverableFailures,omitempty"`
}

FlowStatus defines the observed state of Flow +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*FlowStatus) DeepCopy 

func (in *FlowStatus) DeepCopy() *FlowStatus

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

func (*FlowStatus) DeepCopyInto 

func (in *FlowStatus) DeepCopyInto(out *FlowStatus)

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

func (*FlowStatus) DeepCopyObject 

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

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

type LoginCredentialsSecret 

type LoginCredentialsSecret struct {
	metav1.TypeMeta `json:",inline"`
	Name            string `json:"name"`
	UsernameKey     string `json:"usernameKey"`
	PasswordKey     string `json:"passwordKey"`
}

+k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*LoginCredentialsSecret) DeepCopy 

func (in *LoginCredentialsSecret) DeepCopy() *LoginCredentialsSecret

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

func (*LoginCredentialsSecret) DeepCopyInto 

func (in *LoginCredentialsSecret) DeepCopyInto(out *LoginCredentialsSecret)

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

func (*LoginCredentialsSecret) DeepCopyObject 

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

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

type PodLabelsGetter added in v1.0.3 

type PodLabelsGetter interface {
	GetPodLabels() map[string]string
}

This interface is implemented by all Astarte components which have a podLabels field.

type RabbitMQConfig 

type RabbitMQConfig struct {
	metav1.TypeMeta `json:",inline"`
	Host            string `json:"host"`
	// +optional
	Port int16 `json:"port,omitempty"`
	// +optional
	SSL      *bool  `json:"ssl,omitempty"`
	Username string `json:"username"`
	Password string `json:"password"`
}

RabbitMQConfig represents configuration for RabbitMQ +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*RabbitMQConfig) DeepCopy 

func (in *RabbitMQConfig) DeepCopy() *RabbitMQConfig

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

func (*RabbitMQConfig) DeepCopyInto 

func (in *RabbitMQConfig) DeepCopyInto(out *RabbitMQConfig)

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

func (*RabbitMQConfig) DeepCopyObject 

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

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

type RabbitMQDataProvider 

type RabbitMQDataProvider struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	Queues []string `json:"queues,omitempty"`
	// +optional
	Exchange *RabbitMQExchange `json:"exchange,omitempty"`
	// RabbitMQConfig is an optional field which allows to specify configuration for an external RabbitMQ
	// broker. If not specified, Astarte's main Broker will be used.
	// +optional
	RabbitMQConfig *RabbitMQConfig `json:"rabbitmq,omitempty"`
}

RabbitMQDataProvider is a representation of a Data Provider based upon RabbitMQ +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*RabbitMQDataProvider) DeepCopy 

func (in *RabbitMQDataProvider) DeepCopy() *RabbitMQDataProvider

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

func (*RabbitMQDataProvider) DeepCopyInto 

func (in *RabbitMQDataProvider) DeepCopyInto(out *RabbitMQDataProvider)

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

func (*RabbitMQDataProvider) DeepCopyObject 

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

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

func (*RabbitMQDataProvider) IsConsumer 

func (r *RabbitMQDataProvider) IsConsumer() bool

IsConsumer returns whether the Data Provider has a Consumer stage

func (*RabbitMQDataProvider) IsProducer 

func (r *RabbitMQDataProvider) IsProducer() bool

IsProducer returns whether the Data Provider has a Producer stage

func (*RabbitMQDataProvider) Type 

func (r *RabbitMQDataProvider) Type() string

Type returns the type of the Data Provider

type RabbitMQExchange 

type RabbitMQExchange struct {
	metav1.TypeMeta `json:",inline"`
	Name            string `json:"name"`
	RoutingKey      string `json:"routingKey"`
}

RabbitMQExchange is a representation of a RabbitMQ Exchange +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*RabbitMQExchange) DeepCopy 

func (in *RabbitMQExchange) DeepCopy() *RabbitMQExchange

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

func (*RabbitMQExchange) DeepCopyInto 

func (in *RabbitMQExchange) DeepCopyInto(out *RabbitMQExchange)

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

func (*RabbitMQExchange) DeepCopyObject 

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

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

type ReconciliationPhase 

type ReconciliationPhase string

ReconciliationPhase describes the reconciliation phase the Resource is in 

const (
	// ReconciliationPhaseUnknown represents an Unknown Phase of the Resource. When in this state, it might
	// have never been reconciled
	ReconciliationPhaseUnknown ReconciliationPhase = ""
	// ReconciliationPhaseReconciling means the Resource is currently in the process of being reconciled
	ReconciliationPhaseReconciling ReconciliationPhase = "Reconciling"
	// ReconciliationPhaseUpgrading means the Resource is currently in the process of being upgraded to a new Astarte version.
	// When successful, the Resource will transition to ReconciliationPhaseReconciling
	ReconciliationPhaseUpgrading ReconciliationPhase = "Upgrading"
	// ReconciliationPhaseReconciled means the Resource is currently reconciled and stable. The resource should stay in this
	// state for most of the time.
	ReconciliationPhaseReconciled ReconciliationPhase = "Reconciled"
	// ReconciliationPhaseManualMaintenanceMode means the Resource is currently not being reconciled as the resource is in
	// Manual Maintenance Mode. This happens only when the user explicitly requires that.
	ReconciliationPhaseManualMaintenanceMode ReconciliationPhase = "Disabled, in Manual Maintenance Mode"
	// ReconciliationPhaseFailed means the Resource failed to reconcile. If this state persists, a manual intervention
	// might be necessary.
	ReconciliationPhaseFailed ReconciliationPhase = "Failed"
)

func (*ReconciliationPhase) String 

func (p *ReconciliationPhase) String() string

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.