Help us shape the future of Go! Take the 2026 Go Developer Survey

v1

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 12, 2020 License: Apache-2.0 Imports: 14 Imported by: 1

Documentation

Overview

Package v1 contains API Schema definitions for the bitflow v1 API group +k8s:deepcopy-gen=package,register +groupName=bitflow.com

Package v1 contains API Schema definitions for the bitflow v1 API group +k8s:deepcopy-gen=package,register +groupName=bitflow.com

Index

Constants

View Source 
const (
	DataSourcesKind             = "BitflowSource"
	DataSourcesResourceSingular = "bitflow-source"
	DataSourcesResource         = DataSourcesResourceSingular + "s"
)
View Source 
const (
	StepsKind             = "BitflowStep"
	StepsResourceSingular = "bitflow-step"
	StepsResource         = StepsResourceSingular + "s"

	MatchCheckWildcard = "wildcard"
	MatchCheckExact    = "exact"
	MatchCheckRegex    = "regex"
	MatchCheckPresent  = "present"
	MatchCheckAbsent   = "absent"

	StepTypeOneToOne  = "one-to-one" // The default, when the field is empty
	StepTypeAllToOne  = "all-to-one"
	StepTypeSingleton = "singleton"
)
View Source 
const (
	LabelStepType = "bitflow-step-type"
	LabelStepName = "bitflow-step-name"

	SourceLabelPodName       = "bitflow-pod"
	SourceLabelPodOutputName = "bitflow-pod-output"

	PipelineDepthLabel      = "bitflow-pipeline-depth"
	PipelinePathLabelPrefix = "bitflow-pipeline-"

	PodLabelOneToOneSourceName = "bitflow-source-name"
)
View Source 
const (
	Group        = "bitflow.com"
	Version      = "v1"
	GroupVersion = Group + "/" + Version
)

Variables

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: Group, Version: Version}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)

Functions

func DeepCopyUrl 

func DeepCopyUrl(u *url.URL) *url.URL

func GetOpenAPIDefinitions 

func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition

Types

type BitflowSource 

type BitflowSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   BitflowSourceSpec       `json:"spec,omitempty"`
	Status BitflowValidationStatus `json:"status,omitempty"`
}

BitflowSource is the Schema for the BitflowSource API +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="URL",type="string",JSONPath=".spec.url" +kubebuilder:printcolumn:name="ValidationError",type="string",JSONPath=".status.validationError" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:path=bitflow-sources,shortName=bso;bfso,singular=bitflow-source

func (*BitflowSource) DeepCopy 

func (in *BitflowSource) DeepCopy() *BitflowSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BitflowSource.

func (*BitflowSource) DeepCopyInto 

func (in *BitflowSource) DeepCopyInto(out *BitflowSource)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*BitflowSource) DeepCopyObject 

func (in *BitflowSource) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*BitflowSource) EqualSpec 

func (s *BitflowSource) EqualSpec(other *BitflowSource) bool

func (*BitflowSource) Log 

func (s *BitflowSource) Log() *log.Entry

func (*BitflowSource) LogFields 

func (s *BitflowSource) LogFields(entry *log.Entry) *log.Entry

func (*BitflowSource) String 

func (s *BitflowSource) String() string

func (*BitflowSource) Validate 

func (s *BitflowSource) Validate()

type BitflowSourceList 

type BitflowSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []BitflowSource `json:"items"`
}

BitflowSourceList contains a list of BitflowSource +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*BitflowSourceList) DeepCopy 

func (in *BitflowSourceList) DeepCopy() *BitflowSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BitflowSourceList.

func (*BitflowSourceList) DeepCopyInto 

func (in *BitflowSourceList) DeepCopyInto(out *BitflowSourceList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*BitflowSourceList) DeepCopyObject 

func (in *BitflowSourceList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*BitflowSourceList) GetItems 

func (l *BitflowSourceList) GetItems() []*BitflowSource

type BitflowSourceSpec 

type BitflowSourceSpec struct {
	// +kubebuilder:validation:MinLength=1
	URL string `json:"url"`
}

BitflowSourceSpec defines the desired state of BitflowSource +k8s:openapi-gen=true

func (*BitflowSourceSpec) DeepCopy 

func (in *BitflowSourceSpec) DeepCopy() *BitflowSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BitflowSourceSpec.

func (*BitflowSourceSpec) DeepCopyInto 

func (in *BitflowSourceSpec) DeepCopyInto(out *BitflowSourceSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BitflowStep 

type BitflowStep struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   BitflowStepSpec         `json:"spec,omitempty"`
	Status BitflowValidationStatus `json:"status,omitempty"`
}

BitflowStep is the Schema for the bitflowsteps API +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="ValidationError",type="string",JSONPath=".status.validationError" +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:path=bitflow-steps,shortName=bst;bfst +kubebuilder:singular=bitflow-step

func (*BitflowStep) DeepCopy 

func (in *BitflowStep) DeepCopy() *BitflowStep

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BitflowStep.

func (*BitflowStep) DeepCopyInto 

func (in *BitflowStep) DeepCopyInto(out *BitflowStep)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*BitflowStep) DeepCopyObject 

func (in *BitflowStep) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*BitflowStep) IsRecursive 

func (s *BitflowStep) IsRecursive(sourceLabels map[string]string) bool

func (*BitflowStep) Log 

func (s *BitflowStep) Log() *log.Entry

func (*BitflowStep) LogFields 

func (s *BitflowStep) LogFields(entry *log.Entry) *log.Entry

func (*BitflowStep) Matches 

func (s *BitflowStep) Matches(sourceLabels map[string]string) bool

func (*BitflowStep) MatchesLabels 

func (s *BitflowStep) MatchesLabels(sourceLabels map[string]string) bool

func (*BitflowStep) String 

func (s *BitflowStep) String() string

func (*BitflowStep) Type 

func (s *BitflowStep) Type() string

func (*BitflowStep) Validate 

func (s *BitflowStep) Validate()

type BitflowStepList 

type BitflowStepList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []BitflowStep `json:"items"`
}

BitflowStepList contains a list of BitflowSteps +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*BitflowStepList) DeepCopy 

func (in *BitflowStepList) DeepCopy() *BitflowStepList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BitflowStepList.

func (*BitflowStepList) DeepCopyInto 

func (in *BitflowStepList) DeepCopyInto(out *BitflowStepList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*BitflowStepList) DeepCopyObject 

func (in *BitflowStepList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*BitflowStepList) GetItems 

func (l *BitflowStepList) GetItems() []*BitflowStep

type BitflowStepSpec 

type BitflowStepSpec struct {
	// +kubebuilder:validation:Enum=one-to-one;all-to-one;"";singleton
	Type         string              `json:"type,omitempty"`
	Scheduler    string              `json:"scheduler,omitempty"`
	Ingest       []*IngestMatch      `json:"ingest,omitempty"`
	Outputs      []*StepOutput       `json:"outputs,omitempty"`
	MinResources corev1.ResourceList `json:"minResources,omitempty"`
	Template     *v1.Pod             `json:"template"`
}

BitflowStepSpec defines the desired state of BitflowStep +k8s:openapi-gen=true

func (*BitflowStepSpec) DeepCopy 

func (in *BitflowStepSpec) DeepCopy() *BitflowStepSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BitflowStepSpec.

func (*BitflowStepSpec) DeepCopyInto 

func (in *BitflowStepSpec) DeepCopyInto(out *BitflowStepSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BitflowValidationStatus 

type BitflowValidationStatus struct {
	ValidationError string `json:"validationError"`
}

BitflowValidationStatus defines the validation status of a Bitflow object +k8s:openapi-gen=true

func (*BitflowValidationStatus) DeepCopy 

func (in *BitflowValidationStatus) DeepCopy() *BitflowValidationStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BitflowValidationStatus.

func (*BitflowValidationStatus) DeepCopyInto 

func (in *BitflowValidationStatus) DeepCopyInto(out *BitflowValidationStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type IngestMatch 

type IngestMatch struct {
	// +kubebuilder:validation:MinLength=1
	Key   string `json:"key"`
	Value string `json:"value,omitempty"`
	// +kubebuilder:validation:Enum=wildcard;exact;regex;present;"";absent
	Check string `json:"check,omitempty"`
	// contains filtered or unexported fields
}

+k8s:openapi-gen=true

func (*IngestMatch) DeepCopy 

func (in *IngestMatch) DeepCopy() *IngestMatch

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IngestMatch.

func (*IngestMatch) DeepCopyInto 

func (in *IngestMatch) DeepCopyInto(out *IngestMatch)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*IngestMatch) Matches 

func (s *IngestMatch) Matches(labels map[string]string) bool

type StepOutput 

type StepOutput struct {
	// +kubebuilder:validation:MinLength=1
	Name string `json:"name"`
	// +kubebuilder:validation:MinLength=1
	URL string `json:"url"`

	Labels map[string]string `json:"labels"`
	// contains filtered or unexported fields
}

+k8s:openapi-gen=true

func (*StepOutput) DeepCopy 

func (in *StepOutput) DeepCopy() *StepOutput

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StepOutput.

func (*StepOutput) DeepCopyInto 

func (in *StepOutput) DeepCopyInto(out *StepOutput)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StepOutput) GetOutputSourceURL 

func (output *StepOutput) GetOutputSourceURL(pod *corev1.Pod) string

func (*StepOutput) GetUrl 

func (output *StepOutput) GetUrl() *url.URL

func (*StepOutput) ParseUrl 

func (output *StepOutput) ParseUrl() (*url.URL, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.