Struct RivvenConnectSpec 

pub struct RivvenConnectSpec {

    pub cluster_ref: ClusterReference,
    pub replicas: i32,
    pub version: String,
    pub image: Option<String>,
    pub image_pull_policy: String,
    pub image_pull_secrets: Vec<String>,
    pub resources: Option<Value>,
    pub config: ConnectConfigSpec,
    pub sources: Vec<SourceConnectorSpec>,
    pub sinks: Vec<SinkConnectorSpec>,
    pub settings: GlobalConnectSettings,
    pub tls: ConnectTlsSpec,
    pub pod_annotations: BTreeMap<String, String>,
    pub pod_labels: BTreeMap<String, String>,
    pub env: Vec<EnvVar>,
    pub node_selector: BTreeMap<String, String>,
    pub tolerations: Vec<Toleration>,
    pub affinity: Option<Value>,
    pub service_account: Option<String>,
    pub security_context: Option<Value>,
    pub container_security_context: Option<Value>,
}

RivvenConnect custom resource for managing connectors

This CRD allows declarative management of Rivven Connect pipelines, including source connectors (CDC, HTTP, etc.) and sink connectors (S3, stdout, HTTP webhooks, etc.).

Fields

cluster_ref: ClusterReference

Reference to the RivvenCluster this connect instance connects to

replicas: i32

Number of connect worker replicas (1-10)

version: String

Connect image version

image: Option<String>

Custom container image (overrides version-based default)

image_pull_policy: String

Image pull policy

image_pull_secrets: Vec<String>

Image pull secrets

resources: Option<Value>

Resource requests/limits (following k8s ResourceRequirements schema)

config: ConnectConfigSpec

Global connect configuration

sources: Vec<SourceConnectorSpec>

Source connectors (read from external systems, publish to Rivven)

sinks: Vec<SinkConnectorSpec>

Sink connectors (consume from Rivven, write to external systems)

settings: GlobalConnectSettings

Global settings for all connectors

tls: ConnectTlsSpec

TLS configuration for broker connection

pod_annotations: BTreeMap<String, String>

Pod annotations

pod_labels: BTreeMap<String, String>

Pod labels (cannot override app.kubernetes.io/* labels)

env: Vec<EnvVar>

Environment variables for the container

node_selector: BTreeMap<String, String>

Node selector for pod scheduling

tolerations: Vec<Toleration>

Pod tolerations

affinity: Option<Value>

Pod affinity rules

service_account: Option<String>

Service account name

security_context: Option<Value>

Pod security context

container_security_context: Option<Value>

Container security context

Implementations

impl RivvenConnectSpec

pub fn get_image(&self) -> String

Get the full container image including version

pub fn get_labels(&self, connect_name: &str) -> BTreeMap<String, String>

Get labels for managed resources

pub fn get_selector_labels( &self, connect_name: &str, ) -> BTreeMap<String, String>

Get selector labels for managed resources

pub fn enabled_sources_count(&self) -> usize

Get enabled sources count

pub fn enabled_sinks_count(&self) -> usize

Get enabled sinks count

Trait Implementations

impl Clone for RivvenConnectSpec

fn clone(&self) -> RivvenConnectSpec

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RivvenConnectSpec

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RivvenConnectSpec

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for RivvenConnectSpec

fn schema_name() -> String

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn is_referenceable() -> bool

Whether JSON Schemas generated for this type should be re-used where possible using the $ref keyword.

impl Serialize for RivvenConnectSpec

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Validate for RivvenConnectSpec

fn validate(&self) -> Result<(), ValidationErrors>

impl<'v_a> ValidateArgs<'v_a> for RivvenConnectSpec

type Args = ()

fn validate_with_args(&self, args: Self::Args) -> Result<(), ValidationErrors>