v1alpha1

package

Go to main page

Versions in this module

v0

v0.3.0

Apr 13, 2026

Changes in this version

type ClusterSpec

+ TargetDistribution *TargetDistributionConfig

type ClusterStatus

+ Selector string

+ UnassignedTargets int32

type ServiceReference

+ URL string

type ServiceSelector

+ URL string

+ type TargetDistributionConfig struct

+ PodCapacity int

+ func (in *TargetDistributionConfig) DeepCopy() *TargetDistributionConfig

+ func (in *TargetDistributionConfig) DeepCopyInto(out *TargetDistributionConfig)

v0.2.0

Feb 26, 2026

Changes in this version

+ type ClusterTargetState struct

+ ConnectionState string

+ FailedReason string

+ LastUpdated metav1.Time

+ Pod string

+ State string

+ Subscriptions map[string]string

+ func (in *ClusterTargetState) DeepCopy() *ClusterTargetState

+ func (in *ClusterTargetState) DeepCopyInto(out *ClusterTargetState)

+ type SubscriptionHistoryConfig struct

+ End metav1.Time

+ Snapshot metav1.Time

+ Start metav1.Time

+ func (in *SubscriptionHistoryConfig) DeepCopy() *SubscriptionHistoryConfig

+ func (in *SubscriptionHistoryConfig) DeepCopyInto(out *SubscriptionHistoryConfig)

type SubscriptionSpec

+ History *SubscriptionHistoryConfig

+ Qos *uint32

+ SuppressRedundant bool

+ Target string

type TargetStatus

+ ClusterStates map[string]ClusterTargetState

+ Clusters int32

+ State string

v0.1.0

Feb 9, 2026

v0.0.3

Feb 4, 2026

v0.0.2

Jan 25, 2026

v0.0.1

Jan 19, 2026

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type APIConfig struct

+ GNMIPort int32

+ RestPort int32

+ TLS *ClusterTLSConfig

+ func (in *APIConfig) DeepCopy() *APIConfig

+ func (in *APIConfig) DeepCopyInto(out *APIConfig)

+ type Cluster struct

+ Spec ClusterSpec

+ Status ClusterStatus

+ func (*Cluster) Hub()

+ func (in *Cluster) DeepCopy() *Cluster

+ func (in *Cluster) DeepCopyInto(out *Cluster)

+ func (in *Cluster) DeepCopyObject() runtime.Object

+ type ClusterList struct

+ Items []Cluster

+ func (in *ClusterList) DeepCopy() *ClusterList

+ func (in *ClusterList) DeepCopyInto(out *ClusterList)

+ func (in *ClusterList) DeepCopyObject() runtime.Object

+ type ClusterSpec struct

+ API *APIConfig

+ ClientTLS *ClusterTLSConfig

+ Env []corev1.EnvVar

+ GRPCTunnel *GRPCTunnelConfig

+ Image string

+ Replicas *int32

+ Resources corev1.ResourceRequirements

+ func (in *ClusterSpec) DeepCopy() *ClusterSpec

+ func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec)

+ type ClusterStatus struct

+ Conditions []metav1.Condition

+ InputsCount int32

+ OutputsCount int32

+ PipelinesCount int32

+ ReadyReplicas int32

+ SubscriptionsCount int32

+ TargetsCount int32

+ func (in *ClusterStatus) DeepCopy() *ClusterStatus

+ func (in *ClusterStatus) DeepCopyInto(out *ClusterStatus)

+ type ClusterTLSConfig struct

+ BundleRef string

+ IssuerRef string

+ UseCSIDriver bool

+ func (in *ClusterTLSConfig) DeepCopy() *ClusterTLSConfig

+ func (in *ClusterTLSConfig) DeepCopyInto(out *ClusterTLSConfig)

+ type ConsulConfig struct

+ URL string

+ func (in *ConsulConfig) DeepCopy() *ConsulConfig

+ func (in *ConsulConfig) DeepCopyInto(out *ConsulConfig)

+ type GRPCKeepAliveConfig struct

+ PermitWithoutStream bool

+ Time metav1.Duration

+ Timeout metav1.Duration

+ func (in *GRPCKeepAliveConfig) DeepCopy() *GRPCKeepAliveConfig

+ func (in *GRPCKeepAliveConfig) DeepCopyInto(out *GRPCKeepAliveConfig)

+ type GRPCTunnelConfig struct

+ Port int32

+ Service *ServiceConfig

+ TLS *ClusterTLSConfig

+ func (in *GRPCTunnelConfig) DeepCopy() *GRPCTunnelConfig

+ func (in *GRPCTunnelConfig) DeepCopyInto(out *GRPCTunnelConfig)

+ type HTTPConfig struct

+ URL string

+ func (in *HTTPConfig) DeepCopy() *HTTPConfig

+ func (in *HTTPConfig) DeepCopyInto(out *HTTPConfig)

+ type Input struct

+ Spec InputSpec

+ Status InputStatus

+ func (*Input) Hub()

+ func (in *Input) DeepCopy() *Input

+ func (in *Input) DeepCopyInto(out *Input)

+ func (in *Input) DeepCopyObject() runtime.Object

+ type InputList struct

+ Items []Input

+ func (in *InputList) DeepCopy() *InputList

+ func (in *InputList) DeepCopyInto(out *InputList)

+ func (in *InputList) DeepCopyObject() runtime.Object

+ type InputSelector struct

+ InputRefs []string

+ InputSelectors []metav1.LabelSelector

+ ProcessorRefs []string

+ ProcessorSelectors []metav1.LabelSelector

+ func (in *InputSelector) DeepCopy() *InputSelector

+ func (in *InputSelector) DeepCopyInto(out *InputSelector)

+ type InputSpec struct

+ Config apiextensionsv1.JSON

+ Type string

+ func (in *InputSpec) DeepCopy() *InputSpec

+ func (in *InputSpec) DeepCopyInto(out *InputSpec)

+ type InputStatus struct

+ func (in *InputStatus) DeepCopy() *InputStatus

+ func (in *InputStatus) DeepCopyInto(out *InputStatus)

+ type Output struct

+ Spec OutputSpec

+ Status OutputStatus

+ func (*Output) Hub()

+ func (in *Output) DeepCopy() *Output

+ func (in *Output) DeepCopyInto(out *Output)

+ func (in *Output) DeepCopyObject() runtime.Object

+ type OutputList struct

+ Items []Output

+ func (in *OutputList) DeepCopy() *OutputList

+ func (in *OutputList) DeepCopyInto(out *OutputList)

+ func (in *OutputList) DeepCopyObject() runtime.Object

+ type OutputSelector struct

+ OutputRefs []string

+ OutputSelectors []metav1.LabelSelector

+ ProcessorRefs []string

+ ProcessorSelectors []metav1.LabelSelector

+ func (in *OutputSelector) DeepCopy() *OutputSelector

+ func (in *OutputSelector) DeepCopyInto(out *OutputSelector)

+ type OutputServiceSpec struct

+ Annotations map[string]string

+ Labels map[string]string

+ Type corev1.ServiceType

+ func (in *OutputServiceSpec) DeepCopy() *OutputServiceSpec

+ func (in *OutputServiceSpec) DeepCopyInto(out *OutputServiceSpec)

+ type OutputSpec struct

+ Config apiextensionsv1.JSON

+ Service *OutputServiceSpec

+ ServiceRef *ServiceReference

+ ServiceSelector *ServiceSelector

+ Type string

+ func (in *OutputSpec) DeepCopy() *OutputSpec

+ func (in *OutputSpec) DeepCopyInto(out *OutputSpec)

+ type OutputStatus struct

+ func (in *OutputStatus) DeepCopy() *OutputStatus

+ func (in *OutputStatus) DeepCopyInto(out *OutputStatus)

+ type Pipeline struct

+ Spec PipelineSpec

+ Status PipelineStatus

+ func (*Pipeline) Hub()

+ func (in *Pipeline) DeepCopy() *Pipeline

+ func (in *Pipeline) DeepCopyInto(out *Pipeline)

+ func (in *Pipeline) DeepCopyObject() runtime.Object

+ type PipelineList struct

+ Items []Pipeline

+ func (in *PipelineList) DeepCopy() *PipelineList

+ func (in *PipelineList) DeepCopyInto(out *PipelineList)

+ func (in *PipelineList) DeepCopyObject() runtime.Object

+ type PipelineSpec struct

+ ClusterRef string

+ Enabled bool

+ Inputs InputSelector

+ Labels map[string]string

+ Outputs OutputSelector

+ SubscriptionRefs []string

+ SubscriptionSelectors []metav1.LabelSelector

+ TargetRefs []string

+ TargetSelectors []metav1.LabelSelector

+ TunnelTargetPolicyRefs []string

+ TunnelTargetPolicySelectors []metav1.LabelSelector

+ func (in *PipelineSpec) DeepCopy() *PipelineSpec

+ func (in *PipelineSpec) DeepCopyInto(out *PipelineSpec)

+ type PipelineStatus struct

+ Conditions []metav1.Condition

+ InputsCount int32

+ OutputsCount int32

+ Status string

+ SubscriptionsCount int32

+ TargetsCount int32

+ TunnelTargetPoliciesCount int32

+ func (in *PipelineStatus) DeepCopy() *PipelineStatus

+ func (in *PipelineStatus) DeepCopyInto(out *PipelineStatus)

+ type Processor struct

+ Spec ProcessorSpec

+ Status ProcessorStatus

+ func (*Processor) Hub()

+ func (in *Processor) DeepCopy() *Processor

+ func (in *Processor) DeepCopyInto(out *Processor)

+ func (in *Processor) DeepCopyObject() runtime.Object

+ type ProcessorList struct

+ Items []Processor

+ func (in *ProcessorList) DeepCopy() *ProcessorList

+ func (in *ProcessorList) DeepCopyInto(out *ProcessorList)

+ func (in *ProcessorList) DeepCopyObject() runtime.Object

+ type ProcessorSpec struct

+ Config apiextensionsv1.JSON

+ Type string

+ func (in *ProcessorSpec) DeepCopy() *ProcessorSpec

+ func (in *ProcessorSpec) DeepCopyInto(out *ProcessorSpec)

+ type ProcessorStatus struct

+ func (in *ProcessorStatus) DeepCopy() *ProcessorStatus

+ func (in *ProcessorStatus) DeepCopyInto(out *ProcessorStatus)

+ type ServiceConfig struct

+ Annotations map[string]string

+ Labels map[string]string

+ Type corev1.ServiceType

+ func (in *ServiceConfig) DeepCopy() *ServiceConfig

+ func (in *ServiceConfig) DeepCopyInto(out *ServiceConfig)

+ type ServiceReference struct

+ Name string

+ Namespace string

+ Port string

+ func (in *ServiceReference) DeepCopy() *ServiceReference

+ func (in *ServiceReference) DeepCopyInto(out *ServiceReference)

+ type ServiceSelector struct

+ MatchLabels map[string]string

+ Namespace string

+ Port string

+ func (in *ServiceSelector) DeepCopy() *ServiceSelector

+ func (in *ServiceSelector) DeepCopyInto(out *ServiceSelector)

+ type Subscription struct

+ Spec SubscriptionSpec

+ Status SubscriptionStatus

+ func (*Subscription) Hub()

+ func (in *Subscription) DeepCopy() *Subscription

+ func (in *Subscription) DeepCopyInto(out *Subscription)

+ func (in *Subscription) DeepCopyObject() runtime.Object

+ type SubscriptionList struct

+ Items []Subscription

+ func (in *SubscriptionList) DeepCopy() *SubscriptionList

+ func (in *SubscriptionList) DeepCopyInto(out *SubscriptionList)

+ func (in *SubscriptionList) DeepCopyObject() runtime.Object

+ type SubscriptionSpec struct

+ Depth uint32

+ Encoding string

+ HeartbeatInterval metav1.Duration

+ Mode string

+ Paths []string

+ Prefix string

+ SampleInterval metav1.Duration

+ StreamSubscriptions []string

+ UpdatesOnly bool

+ func (in *SubscriptionSpec) DeepCopy() *SubscriptionSpec

+ func (in *SubscriptionSpec) DeepCopyInto(out *SubscriptionSpec)

+ type SubscriptionStatus struct

+ func (in *SubscriptionStatus) DeepCopy() *SubscriptionStatus

+ func (in *SubscriptionStatus) DeepCopyInto(out *SubscriptionStatus)

+ type Target struct

+ Spec TargetSpec

+ Status TargetStatus

+ func (*Target) Hub()

+ func (in *Target) DeepCopy() *Target

+ func (in *Target) DeepCopyInto(out *Target)

+ func (in *Target) DeepCopyObject() runtime.Object

+ type TargetList struct

+ Items []Target

+ func (in *TargetList) DeepCopy() *TargetList

+ func (in *TargetList) DeepCopyInto(out *TargetList)

+ func (in *TargetList) DeepCopyObject() runtime.Object

+ type TargetProfile struct

+ Spec TargetProfileSpec

+ Status TargetProfileStatus

+ func (*TargetProfile) Hub()

+ func (in *TargetProfile) DeepCopy() *TargetProfile

+ func (in *TargetProfile) DeepCopyInto(out *TargetProfile)

+ func (in *TargetProfile) DeepCopyObject() runtime.Object

+ type TargetProfileList struct

+ Items []TargetProfile

+ func (in *TargetProfileList) DeepCopy() *TargetProfileList

+ func (in *TargetProfileList) DeepCopyInto(out *TargetProfileList)

+ func (in *TargetProfileList) DeepCopyObject() runtime.Object

+ type TargetProfileSpec struct

+ CredentialsRef string

+ Encoding string

+ GRCPKeepAlive *GRPCKeepAliveConfig

+ GzipCompression bool

+ Labels map[string]string

+ Proxy string

+ RetryTimer metav1.Duration

+ TCPKeepAlive *metav1.Duration

+ TLS *TargetTLSConfig

+ Timeout metav1.Duration

+ func (in *TargetProfileSpec) DeepCopy() *TargetProfileSpec

+ func (in *TargetProfileSpec) DeepCopyInto(out *TargetProfileSpec)

+ type TargetProfileStatus struct

+ func (in *TargetProfileStatus) DeepCopy() *TargetProfileStatus

+ func (in *TargetProfileStatus) DeepCopyInto(out *TargetProfileStatus)

+ type TargetSource struct

+ Spec TargetSourceSpec

+ Status TargetSourceStatus

+ func (*TargetSource) Hub()

+ func (in *TargetSource) DeepCopy() *TargetSource

+ func (in *TargetSource) DeepCopyInto(out *TargetSource)

+ func (in *TargetSource) DeepCopyObject() runtime.Object

+ type TargetSourceList struct

+ Items []TargetSource

+ func (in *TargetSourceList) DeepCopy() *TargetSourceList

+ func (in *TargetSourceList) DeepCopyInto(out *TargetSourceList)

+ func (in *TargetSourceList) DeepCopyObject() runtime.Object

+ type TargetSourceSpec struct

+ ConfigMap string

+ Consul *ConsulConfig

+ HTTP *HTTPConfig

+ Labels map[string]string

+ PodSelector metav1.LabelSelector

+ ServiceSelector metav1.LabelSelector

+ func (in *TargetSourceSpec) DeepCopy() *TargetSourceSpec

+ func (in *TargetSourceSpec) DeepCopyInto(out *TargetSourceSpec)

+ type TargetSourceStatus struct

+ LastSync metav1.Time

+ Status string

+ TargetsCount int32

+ func (in *TargetSourceStatus) DeepCopy() *TargetSourceStatus

+ func (in *TargetSourceStatus) DeepCopyInto(out *TargetSourceStatus)

+ type TargetSpec struct

+ Address string

+ Profile string

+ func (in *TargetSpec) DeepCopy() *TargetSpec

+ func (in *TargetSpec) DeepCopyInto(out *TargetSpec)

+ type TargetStatus struct

+ ConnectionState string

+ LastConnected metav1.Time

+ LastDisconnected metav1.Time

+ LastError string

+ func (in *TargetStatus) DeepCopy() *TargetStatus

+ func (in *TargetStatus) DeepCopyInto(out *TargetStatus)

+ type TargetTLSConfig struct

+ CipherSuites []string

+ MaxVersion string

+ MinVersion string

+ ServerName string

+ func (in *TargetTLSConfig) DeepCopy() *TargetTLSConfig

+ func (in *TargetTLSConfig) DeepCopyInto(out *TargetTLSConfig)

+ type TunnelTargetPolicy struct

+ Spec TunnelTargetPolicySpec

+ Status TunnelTargetPolicyStatus

+ func (*TunnelTargetPolicy) Hub()

+ func (in *TunnelTargetPolicy) DeepCopy() *TunnelTargetPolicy

+ func (in *TunnelTargetPolicy) DeepCopyInto(out *TunnelTargetPolicy)

+ func (in *TunnelTargetPolicy) DeepCopyObject() runtime.Object

+ type TunnelTargetPolicyList struct

+ Items []TunnelTargetPolicy

+ func (in *TunnelTargetPolicyList) DeepCopy() *TunnelTargetPolicyList

+ func (in *TunnelTargetPolicyList) DeepCopyInto(out *TunnelTargetPolicyList)

+ func (in *TunnelTargetPolicyList) DeepCopyObject() runtime.Object

+ type TunnelTargetPolicySpec struct

+ Match *tunnelTargetMatch

+ Profile string

+ func (in *TunnelTargetPolicySpec) DeepCopy() *TunnelTargetPolicySpec

+ func (in *TunnelTargetPolicySpec) DeepCopyInto(out *TunnelTargetPolicySpec)

+ type TunnelTargetPolicyStatus struct

+ func (in *TunnelTargetPolicyStatus) DeepCopy() *TunnelTargetPolicyStatus

+ func (in *TunnelTargetPolicyStatus) DeepCopyInto(out *TunnelTargetPolicyStatus)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL