v1alpha

package
v0.0.12 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package v1 contains API Schema definitions for the operator v1 API group +kubebuilder:object:generate=true +groupName=operator.conduit.io

Index

Constants

View Source 
const (
	ErroredReason  = "Error"
	CreatedReason  = "Created"
	UpdatedReason  = "Updated"
	RunningReason  = "Running"
	StoppedReason  = "Stopped"
	PendingReason  = "Pending"
	VolBoundReason = "VolumeBound"
	DeletedReason  = "Deleted"
	DegradedReason = "Degraded"
)
View Source 
const (
	ConduitVersion             = "v0.13.6"
	ConduitImage               = "ghcr.io/conduitio/conduit"
	ConduitContainerName       = "conduit-server"
	ConduitPipelinePath        = "/conduit.pipelines"
	ConduitVolumePath          = "/conduit.storage"
	ConduitDBPath              = "/conduit.storage/db"
	ConduitConnectorsPath      = "/conduit.storage/connectors"
	ConduitProcessorsPath      = "/conduit.storage/processors"
	ConduitStorageVolumeMount  = "conduit-storage"
	ConduitPipelineVolumeMount = "conduit-pipelines"
	ConduitInitImage           = "golang:1.23-alpine"
	ConduitInitContainerName   = "conduit-init"
	ConduitLogFormatJSON       = "json"
	ConduitLogFormatText       = "cli"
)

Variables

View Source 
var (
	ConduitPipelineFile      = path.Join(ConduitPipelinePath, "pipeline.yaml")
	ConduitEarliestAvailable = "v0.11.0"
)
View Source 
var (
	// GroupVersionKind is group version used to register these objects
	GroupVersionKind = schema.GroupVersionKind{
		Group:   "operator.conduit.io",
		Version: "v1alpha",
		Kind:    "Conduit",
	}

	// GroupKind is the group kind
	GroupKind = GroupVersionKind.GroupKind()

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersionKind.GroupVersion()}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var ConduitConditions = NewConditionSet(
	ConditionConduitReady,
	ConditionConduitConfigReady,
	ConditionConduitSecretReady,
	ConditionConduitVolumeReady,
	ConditionConduitDeploymentRunning,
	ConditionConduitServiceReady,
)

Functions

This section is empty.

Types

type Condition 

type Condition struct {
	Type               ConditionType          `json:"type"`
	Status             corev1.ConditionStatus `json:"status"`
	Reason             string                 `json:"reason,omitempty"`
	Message            string                 `json:"message,omitempty"`
	LastTransitionTime *metav1.Time           `json:"lastTransitionTime,omitempty"`
}

func (*Condition) DeepCopy 

func (in *Condition) DeepCopy() *Condition

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

func (*Condition) DeepCopyInto 

func (in *Condition) DeepCopyInto(out *Condition)

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

func (*Condition) IsFalse 

func (c *Condition) IsFalse() bool

func (*Condition) IsTrue 

func (c *Condition) IsTrue() bool

func (*Condition) IsUnknown 

func (c *Condition) IsUnknown() bool

type ConditionSet 

type ConditionSet struct {
	// contains filtered or unexported fields
}

ConditionSet contains a main condition and a set of dependent conditions. When all dependent conditions are met, the main condition is met.

func NewConditionSet 

func NewConditionSet(main ConditionType, deps ...ConditionType) ConditionSet

func (*ConditionSet) DeepCopy 

func (in *ConditionSet) DeepCopy() *ConditionSet

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

func (*ConditionSet) DeepCopyInto 

func (in *ConditionSet) DeepCopyInto(out *ConditionSet)

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

func (ConditionSet) GetCondition 

func (l ConditionSet) GetCondition(conds Conditions, t ConditionType) *Condition

func (ConditionSet) GetConditionTypes 

func (l ConditionSet) GetConditionTypes() []ConditionType

func (ConditionSet) GetDependentConditionTypes 

func (l ConditionSet) GetDependentConditionTypes() []ConditionType

func (ConditionSet) SetCondition 

func (l ConditionSet) SetCondition(
	conds Conditions,
	ct ConditionType,
	status corev1.ConditionStatus,
	reason string,
	message string,
) Conditions

type ConditionType 

type ConditionType string
const (
	ConditionConduitReady             ConditionType = "Ready"
	ConditionConduitConfigReady       ConditionType = "ConfigReady"
	ConditionConduitSecretReady       ConditionType = "SecretReady"
	ConditionConduitVolumeReady       ConditionType = "VolumeBound"
	ConditionConduitDeploymentRunning ConditionType = "DeploymentRunning"
	ConditionConduitServiceReady      ConditionType = "ServiceReady"

	ConduitFinalizer = "finalizers.operator.conduit.io"
)

type Conditions 

type Conditions []Condition

func (Conditions) DeepCopy 

func (in Conditions) DeepCopy() Conditions

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

func (Conditions) DeepCopyInto 

func (in Conditions) DeepCopyInto(out *Conditions)

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

func (Conditions) Len 

func (c Conditions) Len() int

func (Conditions) Less 

func (c Conditions) Less(i int, j int) bool

func (Conditions) Swap 

func (c Conditions) Swap(i int, j int)

type Conduit 

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

	Spec   ConduitSpec   `json:"spec,omitempty"`
	Status ConduitStatus `json:"status,omitempty"`
}

Conduit is the Schema for the conduits API

func (*Conduit) DeepCopy 

func (in *Conduit) DeepCopy() *Conduit

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

func (*Conduit) DeepCopyInto 

func (in *Conduit) DeepCopyInto(out *Conduit)

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

func (*Conduit) DeepCopyObject 

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

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

func (*Conduit) Hub 

func (*Conduit) Hub()

Hub marks this type as a conversion hub.

func (*Conduit) NamespacedName 

func (r *Conduit) NamespacedName() types.NamespacedName

type ConduitConnector 

type ConduitConnector struct {
	ID            string `json:"id,omitempty"`
	Name          string `json:"name,omitempty"`
	Type          string `json:"type,omitempty"`
	Plugin        string `json:"plugin,omitempty"`
	PluginName    string `json:"pluginName,omitempty"`
	PluginPkg     string `json:"pluginPkg,omitempty"`
	PluginVersion string `json:"pluginVersion,omitempty"`

	Settings   []SettingsVar       `json:"settings,omitempty"`
	Processors []*ConduitProcessor `json:"processors,omitempty"`
}

func (*ConduitConnector) DeepCopy 

func (in *ConduitConnector) DeepCopy() *ConduitConnector

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

func (*ConduitConnector) DeepCopyInto 

func (in *ConduitConnector) DeepCopyInto(out *ConduitConnector)

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

type ConduitInstanceMetadata 

type ConduitInstanceMetadata struct {
	PodAnnotations map[string]string `yaml:"podAnnotations"`
	Labels         map[string]string `yaml:"labels"`
	LogFormat      string            `yaml:"logFormat"`
}

+k8s:deepcopy-gen=false ConduitInstanceConfig contains metadata which will be passed to each conduit deployment

func NewConduitInstanceMetadata 

func NewConduitInstanceMetadata() *ConduitInstanceMetadata

Returns new conduit instance metadata struct with defaults

type ConduitList 

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

ConduitList contains a list of Conduit

func (*ConduitList) DeepCopy 

func (in *ConduitList) DeepCopy() *ConduitList

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

func (*ConduitList) DeepCopyInto 

func (in *ConduitList) DeepCopyInto(out *ConduitList)

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

func (*ConduitList) DeepCopyObject 

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

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

type ConduitProcessor 

type ConduitProcessor struct {
	ID        string `json:"id,omitempty"`
	Name      string `json:"name,omitempty"`
	Plugin    string `json:"plugin,omitempty"`
	Condition string `json:"condition,omitempty"`
	Workers   int    `json:"workers,omitempty"`

	Settings []SettingsVar `json:"settings,omitempty"`
}

func (*ConduitProcessor) DeepCopy 

func (in *ConduitProcessor) DeepCopy() *ConduitProcessor

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

func (*ConduitProcessor) DeepCopyInto 

func (in *ConduitProcessor) DeepCopyInto(out *ConduitProcessor)

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

type ConduitSpec 

type ConduitSpec struct {
	ID          string `json:"id,omitempty"`
	Name        string `json:"name,omitempty"`
	Description string `json:"description,omitempty"`
	Image       string `json:"image,omitempty"`
	Running     *bool  `json:"running,omitempty"`
	Version     string `json:"version,omitempty"`

	Registry   *SchemaRegistry     `json:"schemaRegistry,omitempty"`
	Connectors []*ConduitConnector `json:"connectors,omitempty"`
	Processors []*ConduitProcessor `json:"processors,omitempty"`
}

ConduitSpec defines the desired state of Conduit

func (*ConduitSpec) DeepCopy 

func (in *ConduitSpec) DeepCopy() *ConduitSpec

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

func (*ConduitSpec) DeepCopyInto 

func (in *ConduitSpec) DeepCopyInto(out *ConduitSpec)

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

type ConduitStatus 

type ConduitStatus struct {
	ObservedGeneration int64        `json:"observedGeneration,omitempty"`
	Conditions         Conditions   `json:"conditions,omitempty"`
	UpdatedAt          *metav1.Time `json:"updatedAt,omitempty"`
}

ConduitStatus defines the observed state of Conduit

func (*ConduitStatus) ConditionChanged 

func (s *ConduitStatus) ConditionChanged(ct ConditionType, expected corev1.ConditionStatus) bool

ConditionChanged returns true when the expected condition status does not match current status

func (*ConduitStatus) DeepCopy 

func (in *ConduitStatus) DeepCopy() *ConduitStatus

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

func (*ConduitStatus) DeepCopyInto 

func (in *ConduitStatus) DeepCopyInto(out *ConduitStatus)

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

func (*ConduitStatus) GetCondition 

func (s *ConduitStatus) GetCondition(ct ConditionType) *Condition

func (*ConduitStatus) SetCondition 

func (s *ConduitStatus) SetCondition(ct ConditionType, status corev1.ConditionStatus, reason string, message string)

type GlobalConfigMapRef 

type GlobalConfigMapRef struct {
	Namespace string `json:"namespace,omitempty"`
	Name      string `json:"name,omitempty"`
	Key       string `json:"key,omitempty"`
}

func (*GlobalConfigMapRef) DeepCopy 

func (in *GlobalConfigMapRef) DeepCopy() *GlobalConfigMapRef

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

func (*GlobalConfigMapRef) DeepCopyInto 

func (in *GlobalConfigMapRef) DeepCopyInto(out *GlobalConfigMapRef)

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

type SchemaRegistry 

type SchemaRegistry struct {
	URL      string      `json:"url,omitempty"`
	Username SettingsVar `json:"basicAuthUser,omitempty"`
	Password SettingsVar `json:"basicAuthPassword,omitempty"`
	Token    SettingsVar `json:"bearerToken,omitempty"`
}

func (*SchemaRegistry) DeepCopy 

func (in *SchemaRegistry) DeepCopy() *SchemaRegistry

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

func (*SchemaRegistry) DeepCopyInto 

func (in *SchemaRegistry) DeepCopyInto(out *SchemaRegistry)

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

type SettingsVar 

type SettingsVar struct {
	Name         string                    `json:"name,omitempty"`
	Value        string                    `json:"value,omitempty"`
	SecretRef    *corev1.SecretKeySelector `json:"secretRef,omitempty"`
	ConfigMapRef *GlobalConfigMapRef       `json:"configMapRef,omitempty"`
}

func (*SettingsVar) DeepCopy 

func (in *SettingsVar) DeepCopy() *SettingsVar

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

func (*SettingsVar) DeepCopyInto 

func (in *SettingsVar) DeepCopyInto(out *SettingsVar)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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