Versions in this module Expand all Collapse all v0 v0.0.1 Jan 25, 2021 Changes in this version + const PipelineSplitTransform + const PipelineTransform + var AddToScheme = SchemeBuilder.AddToScheme + var GroupVersion = schema.GroupVersion + var SchemeBuilder = &scheme.Builder + func GetJobLabels(pipeline types.Pipeline, key string) map[string]string + type Job struct + Spec JobSpec + Status JobStatus + func (in *Job) DeepCopy() *Job + func (in *Job) DeepCopyInto(out *Job) + func (in *Job) DeepCopyObject() runtime.Object + func (j *Job) GetPipelineKind() pipelinesmeta.PipelineKind + func (j *Job) GetSplitTransformPipeline(ctx context.Context, client client.Client) (*SplitTransform, error) + func (j *Job) GetTransformPipeline(ctx context.Context, client client.Client) (*Transform, error) + func (j *Job) OwnerReferences() []metav1.OwnerReference + type JobList struct + Items []Job + func (in *JobList) DeepCopy() *JobList + func (in *JobList) DeepCopyInto(out *JobList) + func (in *JobList) DeepCopyObject() runtime.Object + type JobSpec struct + PipelineReference pipelinesmeta.PipelineReference + Sinks []*pipelinesmeta.Object + Source *pipelinesmeta.Object + func (in *JobSpec) DeepCopy() *JobSpec + func (in *JobSpec) DeepCopyInto(out *JobSpec) + type JobState string + const JobFailed + const JobFinished + const JobInProgress + const JobPending + type JobStatus struct + Conditions []metav1.Condition + func (in *JobStatus) DeepCopy() *JobStatus + func (in *JobStatus) DeepCopyInto(out *JobStatus) + type SplitTransform struct + Spec SplitTransformSpec + Status SplitTransformStatus + func (in *SplitTransform) DeepCopy() *SplitTransform + func (in *SplitTransform) DeepCopyInto(out *SplitTransform) + func (in *SplitTransform) DeepCopyObject() runtime.Object + func (t *SplitTransform) GetPipelineConfig() *pipelinesmeta.PipelineConfig + func (t *SplitTransform) GetPipelineKind() pipelinesmeta.PipelineKind + func (t *SplitTransform) GetSinkConfig() *pipelinesmeta.SourceSinkConfig + func (t *SplitTransform) GetSinkObjects(srcKey string) []*pipelinesmeta.Object + func (t *SplitTransform) GetSrcConfig() *pipelinesmeta.SourceSinkConfig + func (t *SplitTransform) OwnerReferences() []metav1.OwnerReference + type SplitTransformList struct + Items []SplitTransform + func (in *SplitTransformList) DeepCopy() *SplitTransformList + func (in *SplitTransformList) DeepCopyInto(out *SplitTransformList) + func (in *SplitTransformList) DeepCopyObject() runtime.Object + type SplitTransformSpec struct + Audio *pipelinesmeta.SourceSinkConfig + Globals *pipelinesmeta.SourceSinkConfig + Pipeline *pipelinesmeta.PipelineConfig + Src *pipelinesmeta.SourceSinkConfig + Video *pipelinesmeta.SourceSinkConfig + func (in *SplitTransformSpec) DeepCopy() *SplitTransformSpec + func (in *SplitTransformSpec) DeepCopyInto(out *SplitTransformSpec) + type SplitTransformStatus struct + Conditions []metav1.Condition + func (in *SplitTransformStatus) DeepCopy() *SplitTransformStatus + func (in *SplitTransformStatus) DeepCopyInto(out *SplitTransformStatus) + type Transform struct + Spec TransformSpec + Status TransformStatus + func (in *Transform) DeepCopy() *Transform + func (in *Transform) DeepCopyInto(out *Transform) + func (in *Transform) DeepCopyObject() runtime.Object + func (t *Transform) GetPipelineConfig() *pipelinesmeta.PipelineConfig + func (t *Transform) GetPipelineKind() pipelinesmeta.PipelineKind + func (t *Transform) GetSinkConfig() *pipelinesmeta.SourceSinkConfig + func (t *Transform) GetSinkObjects(srcKey string) []*pipelinesmeta.Object + func (t *Transform) GetSrcConfig() *pipelinesmeta.SourceSinkConfig + func (t *Transform) OwnerReferences() []metav1.OwnerReference + type TransformList struct + Items []Transform + func (in *TransformList) DeepCopy() *TransformList + func (in *TransformList) DeepCopyInto(out *TransformList) + func (in *TransformList) DeepCopyObject() runtime.Object + type TransformSpec struct + Globals *pipelinesmeta.SourceSinkConfig + Pipeline *pipelinesmeta.PipelineConfig + Sink *pipelinesmeta.SourceSinkConfig + Src *pipelinesmeta.SourceSinkConfig + func (in *TransformSpec) DeepCopy() *TransformSpec + func (in *TransformSpec) DeepCopyInto(out *TransformSpec) + type TransformStatus struct + Conditions []metav1.Condition + func (in *TransformStatus) DeepCopy() *TransformStatus + func (in *TransformStatus) DeepCopyInto(out *TransformStatus)
Go to main page