Versions in this module Expand all Collapse all v0 v0.0.2 Apr 12, 2020 v0.0.1 Mar 26, 2020 Changes in this version + const DataSourcesKind + const DataSourcesResource + const DataSourcesResourceSingular + const Group + const GroupVersion + const LabelStepName + const LabelStepType + const MatchCheckAbsent + const MatchCheckExact + const MatchCheckPresent + const MatchCheckRegex + const MatchCheckWildcard + const PipelineDepthLabel + const PipelinePathLabelPrefix + const PodLabelOneToOneSourceName + const SourceLabelPodName + const SourceLabelPodOutputName + const StepTypeAllToOne + const StepTypeOneToOne + const StepTypeSingleton + const StepsKind + const StepsResource + const StepsResourceSingular + const Version + var SchemeBuilder = &scheme.Builder + var SchemeGroupVersion = schema.GroupVersion + func DeepCopyUrl(u *url.URL) *url.URL + func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition + type BitflowSource struct + Spec BitflowSourceSpec + Status BitflowValidationStatus + func (in *BitflowSource) DeepCopy() *BitflowSource + func (in *BitflowSource) DeepCopyInto(out *BitflowSource) + func (in *BitflowSource) DeepCopyObject() runtime.Object + func (s *BitflowSource) EqualSpec(other *BitflowSource) bool + func (s *BitflowSource) Log() *log.Entry + func (s *BitflowSource) LogFields(entry *log.Entry) *log.Entry + func (s *BitflowSource) String() string + func (s *BitflowSource) Validate() + type BitflowSourceList struct + Items []BitflowSource + func (in *BitflowSourceList) DeepCopy() *BitflowSourceList + func (in *BitflowSourceList) DeepCopyInto(out *BitflowSourceList) + func (in *BitflowSourceList) DeepCopyObject() runtime.Object + func (l *BitflowSourceList) GetItems() []*BitflowSource + type BitflowSourceSpec struct + URL string + func (in *BitflowSourceSpec) DeepCopy() *BitflowSourceSpec + func (in *BitflowSourceSpec) DeepCopyInto(out *BitflowSourceSpec) + type BitflowStep struct + Spec BitflowStepSpec + Status BitflowValidationStatus + func (in *BitflowStep) DeepCopy() *BitflowStep + func (in *BitflowStep) DeepCopyInto(out *BitflowStep) + func (in *BitflowStep) DeepCopyObject() runtime.Object + func (s *BitflowStep) IsRecursive(sourceLabels map[string]string) bool + func (s *BitflowStep) Log() *log.Entry + func (s *BitflowStep) LogFields(entry *log.Entry) *log.Entry + func (s *BitflowStep) Matches(sourceLabels map[string]string) bool + func (s *BitflowStep) MatchesLabels(sourceLabels map[string]string) bool + func (s *BitflowStep) String() string + func (s *BitflowStep) Type() string + func (s *BitflowStep) Validate() + type BitflowStepList struct + Items []BitflowStep + func (in *BitflowStepList) DeepCopy() *BitflowStepList + func (in *BitflowStepList) DeepCopyInto(out *BitflowStepList) + func (in *BitflowStepList) DeepCopyObject() runtime.Object + func (l *BitflowStepList) GetItems() []*BitflowStep + type BitflowStepSpec struct + Ingest []*IngestMatch + MinResources corev1.ResourceList + Outputs []*StepOutput + Scheduler string + Template *v1.Pod + Type string + func (in *BitflowStepSpec) DeepCopy() *BitflowStepSpec + func (in *BitflowStepSpec) DeepCopyInto(out *BitflowStepSpec) + type BitflowValidationStatus struct + ValidationError string + func (in *BitflowValidationStatus) DeepCopy() *BitflowValidationStatus + func (in *BitflowValidationStatus) DeepCopyInto(out *BitflowValidationStatus) + type IngestMatch struct + Check string + Key string + Value string + func (in *IngestMatch) DeepCopy() *IngestMatch + func (in *IngestMatch) DeepCopyInto(out *IngestMatch) + func (s *IngestMatch) Matches(labels map[string]string) bool + type StepOutput struct + Labels map[string]string + Name string + URL string + func (in *StepOutput) DeepCopy() *StepOutput + func (in *StepOutput) DeepCopyInto(out *StepOutput) + func (output *StepOutput) GetOutputSourceURL(pod *corev1.Pod) string + func (output *StepOutput) GetUrl() *url.URL + func (output *StepOutput) ParseUrl() (*url.URL, error)
Go to main page