v1alpha1

package

Go to main page

Versions in this module

v0

v0.5.1

May 5, 2026

v0.4.2

Apr 3, 2026

v0.4.1

Apr 3, 2026

v0.4.0

Apr 2, 2026

v0.3.2

Apr 1, 2026

v0.3.1

Mar 31, 2026

Changes in this version

type PipelineInstance

+ func (pi *PipelineInstance) GetQueueDLQ() string

v0.3.0

Mar 31, 2026

Changes in this version

type PipelineSpec

+ ImagePullSecrets []corev1.LocalObjectReference

v0.2.8

Mar 30, 2026

v0.2.7

Mar 22, 2026

v0.2.6

Mar 17, 2026

v0.2.5

Mar 8, 2026

v0.2.4

Mar 8, 2026

v0.2.3

Mar 8, 2026

v0.2.2

Mar 8, 2026

v0.2.1

Feb 25, 2026

v0.2.0

Jan 8, 2026

Changes in this version

+ type PipelineInstance struct

+ Spec PipelineInstanceSpec

+ Status PipelineInstanceStatus

+ func (in *PipelineInstance) DeepCopy() *PipelineInstance

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

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

+ func (pi *PipelineInstance) GetInstanceID() string

+ func (pi *PipelineInstance) GetQueueGroup() string

+ func (pi *PipelineInstance) GetQueueStream() string

+ type PipelineInstanceList struct

+ Items []PipelineInstance

+ func (in *PipelineInstanceList) DeepCopy() *PipelineInstanceList

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

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

+ type PipelineInstanceSpec struct

+ Execution *ExecutionConfig

+ PipelineRef PipelineReference

+ SourceRef SourceReference

+ func (in *PipelineInstanceSpec) DeepCopy() *PipelineInstanceSpec

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

+ type PipelineInstanceStatus struct

+ CompletionTime *metav1.Time

+ Conditions []metav1.Condition

+ Counts *FileCounts

+ JobName string

+ StartTime *metav1.Time

+ Streaming *StreamingStatus

+ func (in *PipelineInstanceStatus) DeepCopy() *PipelineInstanceStatus

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

+ type PipelineSource struct

+ Spec PipelineSourceSpec

+ Status PipelineSourceStatus

+ func (in *PipelineSource) DeepCopy() *PipelineSource

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

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

+ type PipelineSourceList struct

+ Items []PipelineSource

+ func (in *PipelineSourceList) DeepCopy() *PipelineSourceList

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

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

+ type PipelineSourceSpec struct

+ Bucket *BucketSource

+ RTSP *RTSPSource

+ func (in *PipelineSourceSpec) DeepCopy() *PipelineSourceSpec

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

+ type PipelineSourceStatus struct

+ Conditions []metav1.Condition

+ func (in *PipelineSourceStatus) DeepCopy() *PipelineSourceStatus

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

+ type SourceReference struct

+ Name string

+ Namespace *string

+ func (in *SourceReference) DeepCopy() *SourceReference

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

v0.1.7

Nov 5, 2025

v0.1.6

Oct 30, 2025

v0.1.0

Oct 30, 2025

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type BucketSource struct

+ CredentialsSecret *SecretReference

+ Endpoint string

+ InsecureSkipTLSVerify bool

+ Name string

+ Prefix string

+ Region string

+ UsePathStyle bool

+ func (in *BucketSource) DeepCopy() *BucketSource

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

+ type ConfigVar struct

+ Name string

+ Value string

+ func (in *ConfigVar) DeepCopy() *ConfigVar

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

+ type ExecutionConfig struct

+ MaxAttempts *int32

+ Parallelism *int32

+ PendingTimeout *metav1.Duration

+ func (in *ExecutionConfig) DeepCopy() *ExecutionConfig

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

+ type FileCounts struct

+ Failed int64

+ Queued int64

+ Running int64

+ Succeeded int64

+ TotalFiles int64

+ func (in *FileCounts) DeepCopy() *FileCounts

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

+ type Filter struct

+ Args []string

+ Command []string

+ Config []ConfigVar

+ Env []corev1.EnvVar

+ Image string

+ ImagePullPolicy corev1.PullPolicy

+ Name string

+ Resources *corev1.ResourceRequirements

+ func (in *Filter) DeepCopy() *Filter

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

+ type Pipeline struct

+ Spec PipelineSpec

+ Status PipelineStatus

+ 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 PipelineMode string

+ const PipelineModeBatch

+ const PipelineModeStream

+ type PipelineReference struct

+ Name string

+ Namespace *string

+ func (in *PipelineReference) DeepCopy() *PipelineReference

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

+ type PipelineRun struct

+ Spec PipelineRunSpec

+ Status PipelineRunStatus

+ func (in *PipelineRun) DeepCopy() *PipelineRun

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

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

+ func (pr *PipelineRun) GetQueueGroup() string

+ func (pr *PipelineRun) GetQueueStream() string

+ func (pr *PipelineRun) GetRunID() string

+ type PipelineRunList struct

+ Items []PipelineRun

+ func (in *PipelineRunList) DeepCopy() *PipelineRunList

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

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

+ type PipelineRunSpec struct

+ Execution *ExecutionConfig

+ PipelineRef PipelineReference

+ func (in *PipelineRunSpec) DeepCopy() *PipelineRunSpec

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

+ type PipelineRunStatus struct

+ CompletionTime *metav1.Time

+ Conditions []metav1.Condition

+ Counts *FileCounts

+ JobName string

+ StartTime *metav1.Time

+ Streaming *StreamingStatus

+ func (in *PipelineRunStatus) DeepCopy() *PipelineRunStatus

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

+ type PipelineSpec struct

+ Filters []Filter

+ Mode PipelineMode

+ Services []ServicePort

+ Source Source

+ VideoInputPath string

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

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

+ type PipelineStatus struct

+ Conditions []metav1.Condition

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

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

+ type RTSPSource struct

+ CredentialsSecret *SecretReference

+ Host string

+ IdleTimeout *metav1.Duration

+ Path string

+ Port int32

+ func (in *RTSPSource) DeepCopy() *RTSPSource

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

+ type SecretReference struct

+ Name string

+ Namespace string

+ func (in *SecretReference) DeepCopy() *SecretReference

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

+ type ServicePort struct

+ Name string

+ Port int32

+ Protocol corev1.Protocol

+ TargetPort *int32

+ func (in *ServicePort) DeepCopy() *ServicePort

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

+ type Source struct

+ Bucket *BucketSource

+ RTSP *RTSPSource

+ func (in *Source) DeepCopy() *Source

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

+ type StreamingStatus struct

+ AvailableReplicas int32

+ ContainerRestarts int32

+ DeploymentName string

+ LastFrameAt *metav1.Time

+ LastReadyTime *metav1.Time

+ ReadyReplicas int32

+ UpdatedReplicas int32

+ func (in *StreamingStatus) DeepCopy() *StreamingStatus

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

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