v1alpha1

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the streaming v1alpha1 API group +kubebuilder:object:generate=true +groupName=streaming.benthos.dev

Index

• Constants
• Variables
• type BenthosPipeline
  • func (in *BenthosPipeline) DeepCopy() *BenthosPipeline
  • func (in *BenthosPipeline) DeepCopyInto(out *BenthosPipeline)
  • func (in *BenthosPipeline) DeepCopyObject() runtime.Object
• type BenthosPipelineList
  • func (in *BenthosPipelineList) DeepCopy() *BenthosPipelineList
  • func (in *BenthosPipelineList) DeepCopyInto(out *BenthosPipelineList)
  • func (in *BenthosPipelineList) DeepCopyObject() runtime.Object
• type BenthosPipelineSpec
  • func (in *BenthosPipelineSpec) DeepCopy() *BenthosPipelineSpec
  • func (in *BenthosPipelineSpec) DeepCopyInto(out *BenthosPipelineSpec)
• type BenthosPipelineStatus
  • func (in *BenthosPipelineStatus) DeepCopy() *BenthosPipelineStatus
  • func (in *BenthosPipelineStatus) DeepCopyInto(out *BenthosPipelineStatus)

Constants

const (
	// PipelineFinalizer is the finalizer used by the pipeline controller to cleanup resources when the pipeline is being deleted.
	PipelineFinalizer = "pipeline.streaming.benthos.dev"
)

Variables

var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "streaming.benthos.dev", Version: "v1alpha1"}

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

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Types

type BenthosPipeline

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

	Spec   BenthosPipelineSpec   `json:"spec,omitempty"`
	Status BenthosPipelineStatus `json:"status,omitempty"`
}

BenthosPipeline is the Schema for the benthospipelines API

func (*BenthosPipeline) DeepCopy

func (in *BenthosPipeline) DeepCopy() *BenthosPipeline

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

func (*BenthosPipeline) DeepCopyInto

func (in *BenthosPipeline) DeepCopyInto(out *BenthosPipeline)

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

func (*BenthosPipeline) DeepCopyObject

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

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

type BenthosPipelineList

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

BenthosPipelineList contains a list of BenthosPipeline

func (*BenthosPipelineList) DeepCopy

func (in *BenthosPipelineList) DeepCopy() *BenthosPipelineList

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

func (*BenthosPipelineList) DeepCopyInto

func (in *BenthosPipelineList) DeepCopyInto(out *BenthosPipelineList)

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

func (*BenthosPipelineList) DeepCopyObject

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

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

type BenthosPipelineSpec

type BenthosPipelineSpec struct {

	// Config defines the Benthos configuration as a string.
	Config string `json:"config,omitempty"`

	// Replicas defines the amount of replicas to create for the Benthos deployment.
	Replicas int32 `json:"replicas,omitempty"`
}

BenthosPipelineSpec defines the desired state of BenthosPipeline

func (*BenthosPipelineSpec) DeepCopy

func (in *BenthosPipelineSpec) DeepCopy() *BenthosPipelineSpec

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

func (*BenthosPipelineSpec) DeepCopyInto

func (in *BenthosPipelineSpec) DeepCopyInto(out *BenthosPipelineSpec)

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

type BenthosPipelineStatus

type BenthosPipelineStatus struct {
	Ready bool   `json:"ready,omitempty"`
	Phase string `json:"phase,omitempty"`
	// AvailableReplicas is the amount of pods available from the deployment.
	AvailableReplicas int32 `json:"availableReplicas,omitempty"`
}

BenthosPipelineStatus defines the observed state of BenthosPipeline

func (*BenthosPipelineStatus) DeepCopy

func (in *BenthosPipelineStatus) DeepCopy() *BenthosPipelineStatus

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

func (*BenthosPipelineStatus) DeepCopyInto

func (in *BenthosPipelineStatus) DeepCopyInto(out *BenthosPipelineStatus)

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