v1alpha1

package
v0.0.26 Latest Latest
Warning

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

Go to latest
Published: May 27, 2021 License: Apache-2.0 Imports: 19 Imported by: 2

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the dataflow v1alpha1 API group +kubebuilder:object:generate=true +groupName=dataflow.argoproj.io

Index

Constants

View Source
const (
	// conditions
	ConditionCompleted    = "Completed"    // the pipeline completed
	ConditionErrors       = "Errors"       // added if any step encounters an error
	ConditionRunning      = "Running"      // added if any step is currently running
	ConditionSunkMessages = "SunkMessages" // added if any messages have been written to a sink for any step
	ConditionTerminating  = "Terminating"  // added if any terminator step terminated
	// container names
	CtrInit    = "init"
	CtrMain    = "main"
	CtrSidecar = "sidecar"
	// env vars
	EnvImageFormat    = "ARGO_DATAFLOW_IMAGE_FORMAT" // default "quay.io/argoproj/%s:latest"
	EnvNamespace      = "ARGO_DATAFLOW_NAMESPACE"
	EnvPipelineName   = "ARGO_DATAFLOW_PIPELINE_NAME"
	EnvReplica        = "ARGO_DATAFLOW_REPLICA"
	EnvStepSpec       = "ARGO_DATAFLOW_STEP_SPEC"
	EnvStepStatus     = "ARGO_DATAFLOW_STEP_STATUS"
	EnvPeekDelay      = "ARGO_DATAFLOW_PEEK_DELAY"      // how long between peeking (default 4m)
	EnvPullPolicy     = "ARGO_DATAFLOW_PULL_POLICY"     // default ""
	EnvScalingDelay   = "ARGO_DATAFLOW_SCALING_DELAY"   // // how long to wait between any scaling events (including peeking) default "4m"
	EnvUpdateInterval = "ARGO_DATAFLOW_UPDATE_INTERVAL" // default "30s"
	// label/annotation keys
	KeyDefaultContainer = "kubectl.kubernetes.io/default-container"
	KeyPipelineName     = "dataflow.argoproj.io/pipeline-name"
	KeyReplica          = "dataflow.argoproj.io/replica"
	KeyStepName         = "dataflow.argoproj.io/step-name" // the step name without pipeline name prefix
	KeyHash             = "dataflow.argoproj.io/hash"      // hash of the object
	// paths
	PathCheckout    = "/var/run/argo-dataflow/checkout"
	PathFIFOIn      = "/var/run/argo-dataflow/in"
	PathFIFOOut     = "/var/run/argo-dataflow/out"
	PathGroups      = "/var/run/argo-dataflow/groups"
	PathHandlerFile = "/var/run/argo-dataflow/handler"
	PathKill        = "/var/run/argo-dataflow/kill"
	PathPreStop     = "/var/run/argo-dataflow/prestop"
	PathWorkingDir  = "/var/run/argo-dataflow/wd"
	PathVarRun      = "/var/run/argo-dataflow"
)

Variables

View Source
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "dataflow.argoproj.io", 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

	PipelineGroupVersionResource = GroupVersion.WithResource("pipelines")
	PipelineGroupVersionKind     = GroupVersion.WithKind("Pipeline")
	StepGroupVersionKind         = GroupVersion.WithKind("Step")
	StepGroupVersionResource     = GroupVersion.WithResource("steps")
)
View Source
var (
	SmallResourceRequirements = corev1.ResourceRequirements{
		Limits: corev1.ResourceList{
			"cpu":    resource.MustParse("50m"),
			"memory": resource.MustParse("256Mi"),
		},
		Requests: corev1.ResourceList{
			"cpu":    resource.MustParse("50m"),
			"memory": resource.MustParse("64Mi"),
		},
	}
	LargeResourceRequirements = corev1.ResourceRequirements{
		Limits: corev1.ResourceList{
			"cpu":    resource.MustParse("100m"),
			"memory": resource.MustParse("256Mi"),
		},
		Requests: corev1.ResourceList{
			"cpu":    resource.MustParse("100m"),
			"memory": resource.MustParse("256Mi"),
		},
	}
)
View Source
var DefaultInterface = &Interface{HTTP: &HTTP{}}
View Source
var KeyKillCmd = func(x string) string {
	return fmt.Sprintf("dataflow.argoproj.io/kill-cmd.%s", x)
}

Functions

func RequeueAfter

func RequeueAfter(currentReplicas, targetReplicas int, scalingDelay time.Duration) time.Duration

func StringOr

func StringOr(a, b string) string

func StringsOr

func StringsOr(a, b []string) []string

Types

type Cat

type Cat struct{}

func (*Cat) DeepCopy

func (in *Cat) DeepCopy() *Cat

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

func (*Cat) DeepCopyInto

func (in *Cat) DeepCopyInto(out *Cat)

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

func (*Cat) Descriptor

func (*Cat) Descriptor() ([]byte, []int)

func (*Cat) Marshal

func (m *Cat) Marshal() (dAtA []byte, err error)

func (*Cat) MarshalTo

func (m *Cat) MarshalTo(dAtA []byte) (int, error)

func (*Cat) MarshalToSizedBuffer

func (m *Cat) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Cat) ProtoMessage

func (*Cat) ProtoMessage()

func (*Cat) Reset

func (m *Cat) Reset()

func (*Cat) Size

func (m *Cat) Size() (n int)

func (*Cat) String

func (this *Cat) String() string

func (*Cat) Unmarshal

func (m *Cat) Unmarshal(dAtA []byte) error

func (*Cat) XXX_DiscardUnknown

func (m *Cat) XXX_DiscardUnknown()

func (*Cat) XXX_Marshal

func (m *Cat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Cat) XXX_Merge

func (m *Cat) XXX_Merge(src proto.Message)

func (*Cat) XXX_Size

func (m *Cat) XXX_Size() int

func (*Cat) XXX_Unmarshal

func (m *Cat) XXX_Unmarshal(b []byte) error

type Container

type Container struct {
	Image        string               `json:"image" protobuf:"bytes,1,opt,name=image"`
	VolumeMounts []corev1.VolumeMount `json:"volumeMounts,omitempty" protobuf:"bytes,5,rep,name=volumeMounts"`
	In           *Interface           `json:"in,omitempty" protobuf:"bytes,3,opt,name=in"`
	Command      []string             `json:"command,omitempty" protobuf:"bytes,6,rep,name=command"`
	Args         []string             `json:"args,omitempty" protobuf:"bytes,7,rep,name=args"`
	Env          []corev1.EnvVar      `json:"env,omitempty" protobuf:"bytes,8,rep,name=env"`
}

func (*Container) DeepCopy

func (in *Container) DeepCopy() *Container

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

func (*Container) DeepCopyInto

func (in *Container) DeepCopyInto(out *Container)

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

func (*Container) Descriptor

func (*Container) Descriptor() ([]byte, []int)

func (*Container) GetIn

func (in *Container) GetIn() *Interface

func (*Container) Marshal

func (m *Container) Marshal() (dAtA []byte, err error)

func (*Container) MarshalTo

func (m *Container) MarshalTo(dAtA []byte) (int, error)

func (*Container) MarshalToSizedBuffer

func (m *Container) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Container) ProtoMessage

func (*Container) ProtoMessage()

func (*Container) Reset

func (m *Container) Reset()

func (*Container) Size

func (m *Container) Size() (n int)

func (*Container) String

func (this *Container) String() string

func (*Container) Unmarshal

func (m *Container) Unmarshal(dAtA []byte) error

func (*Container) XXX_DiscardUnknown

func (m *Container) XXX_DiscardUnknown()

func (*Container) XXX_Marshal

func (m *Container) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Container) XXX_Merge

func (m *Container) XXX_Merge(src proto.Message)

func (*Container) XXX_Size

func (m *Container) XXX_Size() int

func (*Container) XXX_Unmarshal

func (m *Container) XXX_Unmarshal(b []byte) error

type Cron

type Cron struct {
	Schedule string `json:"schedule" protobuf:"bytes,1,opt,name=schedule"`
	// +kubebuilder:default="2006-01-02T15:04:05Z07:00"
	Layout string `json:"layout,omitempty" protobuf:"bytes,2,opt,name=layout"`
}

func (*Cron) DeepCopy

func (in *Cron) DeepCopy() *Cron

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

func (*Cron) DeepCopyInto

func (in *Cron) DeepCopyInto(out *Cron)

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

func (*Cron) Descriptor

func (*Cron) Descriptor() ([]byte, []int)

func (*Cron) Marshal

func (m *Cron) Marshal() (dAtA []byte, err error)

func (*Cron) MarshalTo

func (m *Cron) MarshalTo(dAtA []byte) (int, error)

func (*Cron) MarshalToSizedBuffer

func (m *Cron) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Cron) ProtoMessage

func (*Cron) ProtoMessage()

func (*Cron) Reset

func (m *Cron) Reset()

func (*Cron) Size

func (m *Cron) Size() (n int)

func (*Cron) String

func (this *Cron) String() string

func (*Cron) Unmarshal

func (m *Cron) Unmarshal(dAtA []byte) error

func (*Cron) XXX_DiscardUnknown

func (m *Cron) XXX_DiscardUnknown()

func (*Cron) XXX_Marshal

func (m *Cron) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Cron) XXX_Merge

func (m *Cron) XXX_Merge(src proto.Message)

func (*Cron) XXX_Size

func (m *Cron) XXX_Size() int

func (*Cron) XXX_Unmarshal

func (m *Cron) XXX_Unmarshal(b []byte) error

type Error added in v0.0.4

type Error struct {
	// +kubebuilder:validation:MaxLength=64
	Message string      `json:"message" protobuf:"bytes,1,opt,name=message"`
	Time    metav1.Time `json:"time" protobuf:"bytes,2,opt,name=time"`
}

func (*Error) DeepCopy added in v0.0.4

func (in *Error) DeepCopy() *Error

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

func (*Error) DeepCopyInto added in v0.0.4

func (in *Error) DeepCopyInto(out *Error)

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

func (*Error) Descriptor added in v0.0.4

func (*Error) Descriptor() ([]byte, []int)

func (*Error) Marshal added in v0.0.4

func (m *Error) Marshal() (dAtA []byte, err error)

func (*Error) MarshalTo added in v0.0.4

func (m *Error) MarshalTo(dAtA []byte) (int, error)

func (*Error) MarshalToSizedBuffer added in v0.0.4

func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Error) ProtoMessage added in v0.0.4

func (*Error) ProtoMessage()

func (*Error) Reset added in v0.0.4

func (m *Error) Reset()

func (*Error) Size added in v0.0.4

func (m *Error) Size() (n int)

func (*Error) String added in v0.0.4

func (this *Error) String() string

func (*Error) Unmarshal added in v0.0.4

func (m *Error) Unmarshal(dAtA []byte) error

func (*Error) XXX_DiscardUnknown added in v0.0.4

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal added in v0.0.4

func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Error) XXX_Merge added in v0.0.4

func (m *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size added in v0.0.4

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal added in v0.0.4

func (m *Error) XXX_Unmarshal(b []byte) error

type Expand added in v0.0.9

type Expand struct{}

func (*Expand) DeepCopy added in v0.0.9

func (in *Expand) DeepCopy() *Expand

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

func (*Expand) DeepCopyInto added in v0.0.9

func (in *Expand) DeepCopyInto(out *Expand)

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

func (*Expand) Descriptor added in v0.0.9

func (*Expand) Descriptor() ([]byte, []int)

func (*Expand) Marshal added in v0.0.9

func (m *Expand) Marshal() (dAtA []byte, err error)

func (*Expand) MarshalTo added in v0.0.9

func (m *Expand) MarshalTo(dAtA []byte) (int, error)

func (*Expand) MarshalToSizedBuffer added in v0.0.9

func (m *Expand) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Expand) ProtoMessage added in v0.0.9

func (*Expand) ProtoMessage()

func (*Expand) Reset added in v0.0.9

func (m *Expand) Reset()

func (*Expand) Size added in v0.0.9

func (m *Expand) Size() (n int)

func (*Expand) String added in v0.0.9

func (this *Expand) String() string

func (*Expand) Unmarshal added in v0.0.9

func (m *Expand) Unmarshal(dAtA []byte) error

func (*Expand) XXX_DiscardUnknown added in v0.0.9

func (m *Expand) XXX_DiscardUnknown()

func (*Expand) XXX_Marshal added in v0.0.9

func (m *Expand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Expand) XXX_Merge added in v0.0.9

func (m *Expand) XXX_Merge(src proto.Message)

func (*Expand) XXX_Size added in v0.0.9

func (m *Expand) XXX_Size() int

func (*Expand) XXX_Unmarshal added in v0.0.9

func (m *Expand) XXX_Unmarshal(b []byte) error

type Filter

type Filter string

type Flatten added in v0.0.9

type Flatten struct{}

func (*Flatten) DeepCopy added in v0.0.9

func (in *Flatten) DeepCopy() *Flatten

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

func (*Flatten) DeepCopyInto added in v0.0.9

func (in *Flatten) DeepCopyInto(out *Flatten)

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

func (*Flatten) Descriptor added in v0.0.9

func (*Flatten) Descriptor() ([]byte, []int)

func (*Flatten) Marshal added in v0.0.9

func (m *Flatten) Marshal() (dAtA []byte, err error)

func (*Flatten) MarshalTo added in v0.0.9

func (m *Flatten) MarshalTo(dAtA []byte) (int, error)

func (*Flatten) MarshalToSizedBuffer added in v0.0.9

func (m *Flatten) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Flatten) ProtoMessage added in v0.0.9

func (*Flatten) ProtoMessage()

func (*Flatten) Reset added in v0.0.9

func (m *Flatten) Reset()

func (*Flatten) Size added in v0.0.9

func (m *Flatten) Size() (n int)

func (*Flatten) String added in v0.0.9

func (this *Flatten) String() string

func (*Flatten) Unmarshal added in v0.0.9

func (m *Flatten) Unmarshal(dAtA []byte) error

func (*Flatten) XXX_DiscardUnknown added in v0.0.9

func (m *Flatten) XXX_DiscardUnknown()

func (*Flatten) XXX_Marshal added in v0.0.9

func (m *Flatten) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Flatten) XXX_Merge added in v0.0.9

func (m *Flatten) XXX_Merge(src proto.Message)

func (*Flatten) XXX_Size added in v0.0.9

func (m *Flatten) XXX_Size() int

func (*Flatten) XXX_Unmarshal added in v0.0.9

func (m *Flatten) XXX_Unmarshal(b []byte) error

type GetPodSpecReq added in v0.0.4

type GetPodSpecReq struct {
	PipelineName   string            `protobuf:"bytes,1,opt,name=pipelineName"`
	Namespace      string            `protobuf:"bytes,2,opt,name=namespace"`
	Replica        int32             `protobuf:"varint,3,opt,name=replica"`
	ImageFormat    string            `protobuf:"bytes,4,opt,name=imageFormat"`
	RunnerImage    string            `protobuf:"bytes,5,opt,name=runnerImage"`
	PullPolicy     corev1.PullPolicy `protobuf:"bytes,6,opt,name=pullPolicy,casttype=k8s.io/api/core/v1.PullPolicy"`
	UpdateInterval time.Duration     `protobuf:"varint,7,opt,name=updateInterval,casttype=time.Duration"`
	StepStatus     StepStatus        `protobuf:"bytes,8,opt,name=stepStatus"`
}

func (*GetPodSpecReq) DeepCopy added in v0.0.4

func (in *GetPodSpecReq) DeepCopy() *GetPodSpecReq

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

func (*GetPodSpecReq) DeepCopyInto added in v0.0.4

func (in *GetPodSpecReq) DeepCopyInto(out *GetPodSpecReq)

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

func (*GetPodSpecReq) Descriptor added in v0.0.4

func (*GetPodSpecReq) Descriptor() ([]byte, []int)

func (*GetPodSpecReq) Marshal added in v0.0.4

func (m *GetPodSpecReq) Marshal() (dAtA []byte, err error)

func (*GetPodSpecReq) MarshalTo added in v0.0.4

func (m *GetPodSpecReq) MarshalTo(dAtA []byte) (int, error)

func (*GetPodSpecReq) MarshalToSizedBuffer added in v0.0.4

func (m *GetPodSpecReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetPodSpecReq) ProtoMessage added in v0.0.4

func (*GetPodSpecReq) ProtoMessage()

func (*GetPodSpecReq) Reset added in v0.0.4

func (m *GetPodSpecReq) Reset()

func (*GetPodSpecReq) Size added in v0.0.4

func (m *GetPodSpecReq) Size() (n int)

func (*GetPodSpecReq) String added in v0.0.4

func (this *GetPodSpecReq) String() string

func (*GetPodSpecReq) Unmarshal added in v0.0.4

func (m *GetPodSpecReq) Unmarshal(dAtA []byte) error

func (*GetPodSpecReq) XXX_DiscardUnknown added in v0.0.4

func (m *GetPodSpecReq) XXX_DiscardUnknown()

func (*GetPodSpecReq) XXX_Marshal added in v0.0.4

func (m *GetPodSpecReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPodSpecReq) XXX_Merge added in v0.0.4

func (m *GetPodSpecReq) XXX_Merge(src proto.Message)

func (*GetPodSpecReq) XXX_Size added in v0.0.4

func (m *GetPodSpecReq) XXX_Size() int

func (*GetPodSpecReq) XXX_Unmarshal added in v0.0.4

func (m *GetPodSpecReq) XXX_Unmarshal(b []byte) error

type Git

type Git struct {
	Image   string   `json:"image" protobuf:"bytes,1,opt,name=image"`
	Command []string `json:"command,omitempty" protobuf:"bytes,6,rep,name=command"`
	URL     string   `json:"url" protobuf:"bytes,2,opt,name=url"`
	// +kubebuilder:default=.
	Path string `json:"path,omitempty" protobuf:"bytes,3,opt,name=path"`
	// +kubebuilder:default=main
	Branch string          `json:"branch,omitempty" protobuf:"bytes,4,opt,name=branch"`
	Env    []corev1.EnvVar `json:"env,omitempty" protobuf:"bytes,5,rep,name=env"`
}

func (*Git) DeepCopy

func (in *Git) DeepCopy() *Git

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

func (*Git) DeepCopyInto

func (in *Git) DeepCopyInto(out *Git)

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

func (*Git) Descriptor

func (*Git) Descriptor() ([]byte, []int)

func (*Git) Marshal

func (m *Git) Marshal() (dAtA []byte, err error)

func (*Git) MarshalTo

func (m *Git) MarshalTo(dAtA []byte) (int, error)

func (*Git) MarshalToSizedBuffer

func (m *Git) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Git) ProtoMessage

func (*Git) ProtoMessage()

func (*Git) Reset

func (m *Git) Reset()

func (*Git) Size

func (m *Git) Size() (n int)

func (*Git) String

func (this *Git) String() string

func (*Git) Unmarshal

func (m *Git) Unmarshal(dAtA []byte) error

func (*Git) XXX_DiscardUnknown

func (m *Git) XXX_DiscardUnknown()

func (*Git) XXX_Marshal

func (m *Git) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Git) XXX_Merge

func (m *Git) XXX_Merge(src proto.Message)

func (*Git) XXX_Size

func (m *Git) XXX_Size() int

func (*Git) XXX_Unmarshal

func (m *Git) XXX_Unmarshal(b []byte) error

type Group

type Group struct {
	Key        string      `json:"key" protobuf:"bytes,1,opt,name=key"`
	EndOfGroup string      `json:"endOfGroup" protobuf:"bytes,2,opt,name=endOfGroup"`
	Format     GroupFormat `json:"format,omitempty" protobuf:"bytes,3,opt,name=format,casttype=GroupFormat"`
	Storage    *Storage    `json:"storage,omitempty" protobuf:"bytes,4,opt,name=storage"`
}

func (*Group) DeepCopy

func (in *Group) DeepCopy() *Group

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

func (*Group) DeepCopyInto

func (in *Group) DeepCopyInto(out *Group)

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

func (*Group) Descriptor

func (*Group) Descriptor() ([]byte, []int)

func (*Group) Marshal

func (m *Group) Marshal() (dAtA []byte, err error)

func (*Group) MarshalTo

func (m *Group) MarshalTo(dAtA []byte) (int, error)

func (*Group) MarshalToSizedBuffer

func (m *Group) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Group) ProtoMessage

func (*Group) ProtoMessage()

func (*Group) Reset

func (m *Group) Reset()

func (*Group) Size

func (m *Group) Size() (n int)

func (*Group) String

func (this *Group) String() string

func (*Group) Unmarshal

func (m *Group) Unmarshal(dAtA []byte) error

func (*Group) XXX_DiscardUnknown

func (m *Group) XXX_DiscardUnknown()

func (*Group) XXX_Marshal

func (m *Group) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Group) XXX_Merge

func (m *Group) XXX_Merge(src proto.Message)

func (*Group) XXX_Size

func (m *Group) XXX_Size() int

func (*Group) XXX_Unmarshal

func (m *Group) XXX_Unmarshal(b []byte) error

type GroupFormat

type GroupFormat string

+kubebuilder:validation:Enum="";JSONBytesArray;JSONStringArray

const (
	GroupFormatUnknown         GroupFormat = ""                // all messages are sent one by one - probably not what you want
	GroupFormatJSONBytesArray  GroupFormat = "JSONBytesArray"  // messages are sent as an array where each element is a base 64 encoded
	GroupFormatJSONStringArray GroupFormat = "JSONStringArray" // messages are sent as an array where each element is a string
)

type HTTP

type HTTP struct{}

func (*HTTP) DeepCopy

func (in *HTTP) DeepCopy() *HTTP

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

func (*HTTP) DeepCopyInto

func (in *HTTP) DeepCopyInto(out *HTTP)

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

func (*HTTP) Descriptor

func (*HTTP) Descriptor() ([]byte, []int)

func (*HTTP) Marshal

func (m *HTTP) Marshal() (dAtA []byte, err error)

func (*HTTP) MarshalTo

func (m *HTTP) MarshalTo(dAtA []byte) (int, error)

func (*HTTP) MarshalToSizedBuffer

func (m *HTTP) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HTTP) ProtoMessage

func (*HTTP) ProtoMessage()

func (*HTTP) Reset

func (m *HTTP) Reset()

func (*HTTP) Size

func (m *HTTP) Size() (n int)

func (*HTTP) String

func (this *HTTP) String() string

func (*HTTP) Unmarshal

func (m *HTTP) Unmarshal(dAtA []byte) error

func (*HTTP) XXX_DiscardUnknown

func (m *HTTP) XXX_DiscardUnknown()

func (*HTTP) XXX_Marshal

func (m *HTTP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HTTP) XXX_Merge

func (m *HTTP) XXX_Merge(src proto.Message)

func (*HTTP) XXX_Size

func (m *HTTP) XXX_Size() int

func (*HTTP) XXX_Unmarshal

func (m *HTTP) XXX_Unmarshal(b []byte) error

type HTTPSink added in v0.0.10

type HTTPSink struct {
	URL string `json:"url" protobuf:"bytes,1,opt,name=url"`
}

func (*HTTPSink) DeepCopy added in v0.0.10

func (in *HTTPSink) DeepCopy() *HTTPSink

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

func (*HTTPSink) DeepCopyInto added in v0.0.10

func (in *HTTPSink) DeepCopyInto(out *HTTPSink)

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

func (*HTTPSink) Descriptor added in v0.0.10

func (*HTTPSink) Descriptor() ([]byte, []int)

func (*HTTPSink) Marshal added in v0.0.10

func (m *HTTPSink) Marshal() (dAtA []byte, err error)

func (*HTTPSink) MarshalTo added in v0.0.10

func (m *HTTPSink) MarshalTo(dAtA []byte) (int, error)

func (*HTTPSink) MarshalToSizedBuffer added in v0.0.10

func (m *HTTPSink) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HTTPSink) ProtoMessage added in v0.0.10

func (*HTTPSink) ProtoMessage()

func (*HTTPSink) Reset added in v0.0.10

func (m *HTTPSink) Reset()

func (*HTTPSink) Size added in v0.0.10

func (m *HTTPSink) Size() (n int)

func (*HTTPSink) String added in v0.0.10

func (this *HTTPSink) String() string

func (*HTTPSink) Unmarshal added in v0.0.10

func (m *HTTPSink) Unmarshal(dAtA []byte) error

func (*HTTPSink) XXX_DiscardUnknown added in v0.0.10

func (m *HTTPSink) XXX_DiscardUnknown()

func (*HTTPSink) XXX_Marshal added in v0.0.10

func (m *HTTPSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HTTPSink) XXX_Merge added in v0.0.10

func (m *HTTPSink) XXX_Merge(src proto.Message)

func (*HTTPSink) XXX_Size added in v0.0.10

func (m *HTTPSink) XXX_Size() int

func (*HTTPSink) XXX_Unmarshal added in v0.0.10

func (m *HTTPSink) XXX_Unmarshal(b []byte) error

type HTTPSource added in v0.0.10

type HTTPSource struct{}

func (*HTTPSource) DeepCopy added in v0.0.10

func (in *HTTPSource) DeepCopy() *HTTPSource

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

func (*HTTPSource) DeepCopyInto added in v0.0.10

func (in *HTTPSource) DeepCopyInto(out *HTTPSource)

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

func (*HTTPSource) Descriptor added in v0.0.10

func (*HTTPSource) Descriptor() ([]byte, []int)

func (*HTTPSource) Marshal added in v0.0.10

func (m *HTTPSource) Marshal() (dAtA []byte, err error)

func (*HTTPSource) MarshalTo added in v0.0.10

func (m *HTTPSource) MarshalTo(dAtA []byte) (int, error)

func (*HTTPSource) MarshalToSizedBuffer added in v0.0.10

func (m *HTTPSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HTTPSource) ProtoMessage added in v0.0.10

func (*HTTPSource) ProtoMessage()

func (*HTTPSource) Reset added in v0.0.10

func (m *HTTPSource) Reset()

func (*HTTPSource) Size added in v0.0.10

func (m *HTTPSource) Size() (n int)

func (*HTTPSource) String added in v0.0.10

func (this *HTTPSource) String() string

func (*HTTPSource) Unmarshal added in v0.0.10

func (m *HTTPSource) Unmarshal(dAtA []byte) error

func (*HTTPSource) XXX_DiscardUnknown added in v0.0.10

func (m *HTTPSource) XXX_DiscardUnknown()

func (*HTTPSource) XXX_Marshal added in v0.0.10

func (m *HTTPSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HTTPSource) XXX_Merge added in v0.0.10

func (m *HTTPSource) XXX_Merge(src proto.Message)

func (*HTTPSource) XXX_Size added in v0.0.10

func (m *HTTPSource) XXX_Size() int

func (*HTTPSource) XXX_Unmarshal added in v0.0.10

func (m *HTTPSource) XXX_Unmarshal(b []byte) error

type Handler

type Handler struct {
	Runtime Runtime `json:"runtime" protobuf:"bytes,4,opt,name=runtime,casttype=Runtime"`
	Code    string  `json:"code" protobuf:"bytes,3,opt,name=code"`
}

func (*Handler) DeepCopy

func (in *Handler) DeepCopy() *Handler

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

func (*Handler) DeepCopyInto

func (in *Handler) DeepCopyInto(out *Handler)

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

func (*Handler) Descriptor

func (*Handler) Descriptor() ([]byte, []int)

func (*Handler) Marshal

func (m *Handler) Marshal() (dAtA []byte, err error)

func (*Handler) MarshalTo

func (m *Handler) MarshalTo(dAtA []byte) (int, error)

func (*Handler) MarshalToSizedBuffer

func (m *Handler) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Handler) ProtoMessage

func (*Handler) ProtoMessage()

func (*Handler) Reset

func (m *Handler) Reset()

func (*Handler) Size

func (m *Handler) Size() (n int)

func (*Handler) String

func (this *Handler) String() string

func (*Handler) Unmarshal

func (m *Handler) Unmarshal(dAtA []byte) error

func (*Handler) XXX_DiscardUnknown

func (m *Handler) XXX_DiscardUnknown()

func (*Handler) XXX_Marshal

func (m *Handler) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Handler) XXX_Merge

func (m *Handler) XXX_Merge(src proto.Message)

func (*Handler) XXX_Size

func (m *Handler) XXX_Size() int

func (*Handler) XXX_Unmarshal

func (m *Handler) XXX_Unmarshal(b []byte) error

type Interface

type Interface struct {
	FIFO bool  `json:"fifo,omitempty" protobuf:"varint,1,opt,name=fifo"`
	HTTP *HTTP `json:"http,omitempty" protobuf:"bytes,2,opt,name=http"`
}

func (*Interface) DeepCopy

func (in *Interface) DeepCopy() *Interface

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

func (*Interface) DeepCopyInto

func (in *Interface) DeepCopyInto(out *Interface)

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

func (*Interface) Descriptor

func (*Interface) Descriptor() ([]byte, []int)

func (*Interface) Marshal

func (m *Interface) Marshal() (dAtA []byte, err error)

func (*Interface) MarshalTo

func (m *Interface) MarshalTo(dAtA []byte) (int, error)

func (*Interface) MarshalToSizedBuffer

func (m *Interface) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Interface) ProtoMessage

func (*Interface) ProtoMessage()

func (*Interface) Reset

func (m *Interface) Reset()

func (*Interface) Size

func (m *Interface) Size() (n int)

func (*Interface) String

func (this *Interface) String() string

func (*Interface) Unmarshal

func (m *Interface) Unmarshal(dAtA []byte) error

func (*Interface) XXX_DiscardUnknown

func (m *Interface) XXX_DiscardUnknown()

func (*Interface) XXX_Marshal

func (m *Interface) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Interface) XXX_Merge

func (m *Interface) XXX_Merge(src proto.Message)

func (*Interface) XXX_Size

func (m *Interface) XXX_Size() int

func (*Interface) XXX_Unmarshal

func (m *Interface) XXX_Unmarshal(b []byte) error

type Kafka

type Kafka struct {
	// +kubebuilder:default=default
	Name    string    `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	Brokers []string  `json:"brokers,omitempty" protobuf:"bytes,2,opt,name=brokers"`
	Topic   string    `json:"topic" protobuf:"bytes,3,opt,name=topic"`
	Version string    `json:"version,omitempty" protobuf:"bytes,4,opt,name=version"`
	NET     *KafkaNET `json:"net,omitempty" protobuf:"bytes,5,opt,name=net"`
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:default=1
	Parallel uint32 `json:"parallel,omitempty" protobuf:"varint,6,opt,name=parallel"`
}

func (*Kafka) DeepCopy

func (in *Kafka) DeepCopy() *Kafka

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

func (*Kafka) DeepCopyInto

func (in *Kafka) DeepCopyInto(out *Kafka)

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

func (*Kafka) Descriptor

func (*Kafka) Descriptor() ([]byte, []int)

func (*Kafka) Marshal

func (m *Kafka) Marshal() (dAtA []byte, err error)

func (*Kafka) MarshalTo

func (m *Kafka) MarshalTo(dAtA []byte) (int, error)

func (*Kafka) MarshalToSizedBuffer

func (m *Kafka) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Kafka) ProtoMessage

func (*Kafka) ProtoMessage()

func (*Kafka) Reset

func (m *Kafka) Reset()

func (*Kafka) Size

func (m *Kafka) Size() (n int)

func (*Kafka) String

func (this *Kafka) String() string

func (*Kafka) Unmarshal

func (m *Kafka) Unmarshal(dAtA []byte) error

func (*Kafka) XXX_DiscardUnknown

func (m *Kafka) XXX_DiscardUnknown()

func (*Kafka) XXX_Marshal

func (m *Kafka) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Kafka) XXX_Merge

func (m *Kafka) XXX_Merge(src proto.Message)

func (*Kafka) XXX_Size

func (m *Kafka) XXX_Size() int

func (*Kafka) XXX_Unmarshal

func (m *Kafka) XXX_Unmarshal(b []byte) error

type KafkaNET

type KafkaNET struct {
	TLS *TLS `json:"tls,omitempty" protobuf:"bytes,1,opt,name=tls"`
}

func (*KafkaNET) DeepCopy

func (in *KafkaNET) DeepCopy() *KafkaNET

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

func (*KafkaNET) DeepCopyInto

func (in *KafkaNET) DeepCopyInto(out *KafkaNET)

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

func (*KafkaNET) Descriptor

func (*KafkaNET) Descriptor() ([]byte, []int)

func (*KafkaNET) Marshal

func (m *KafkaNET) Marshal() (dAtA []byte, err error)

func (*KafkaNET) MarshalTo

func (m *KafkaNET) MarshalTo(dAtA []byte) (int, error)

func (*KafkaNET) MarshalToSizedBuffer

func (m *KafkaNET) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KafkaNET) ProtoMessage

func (*KafkaNET) ProtoMessage()

func (*KafkaNET) Reset

func (m *KafkaNET) Reset()

func (*KafkaNET) Size

func (m *KafkaNET) Size() (n int)

func (*KafkaNET) String

func (this *KafkaNET) String() string

func (*KafkaNET) Unmarshal

func (m *KafkaNET) Unmarshal(dAtA []byte) error

func (*KafkaNET) XXX_DiscardUnknown

func (m *KafkaNET) XXX_DiscardUnknown()

func (*KafkaNET) XXX_Marshal

func (m *KafkaNET) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KafkaNET) XXX_Merge

func (m *KafkaNET) XXX_Merge(src proto.Message)

func (*KafkaNET) XXX_Size

func (m *KafkaNET) XXX_Size() int

func (*KafkaNET) XXX_Unmarshal

func (m *KafkaNET) XXX_Unmarshal(b []byte) error

type Log

type Log struct{}

func (*Log) DeepCopy

func (in *Log) DeepCopy() *Log

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

func (*Log) DeepCopyInto

func (in *Log) DeepCopyInto(out *Log)

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

func (*Log) Descriptor

func (*Log) Descriptor() ([]byte, []int)

func (*Log) Marshal

func (m *Log) Marshal() (dAtA []byte, err error)

func (*Log) MarshalTo

func (m *Log) MarshalTo(dAtA []byte) (int, error)

func (*Log) MarshalToSizedBuffer

func (m *Log) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Log) ProtoMessage

func (*Log) ProtoMessage()

func (*Log) Reset

func (m *Log) Reset()

func (*Log) Size

func (m *Log) Size() (n int)

func (*Log) String

func (this *Log) String() string

func (*Log) Unmarshal

func (m *Log) Unmarshal(dAtA []byte) error

func (*Log) XXX_DiscardUnknown

func (m *Log) XXX_DiscardUnknown()

func (*Log) XXX_Marshal

func (m *Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Log) XXX_Merge

func (m *Log) XXX_Merge(src proto.Message)

func (*Log) XXX_Size

func (m *Log) XXX_Size() int

func (*Log) XXX_Unmarshal

func (m *Log) XXX_Unmarshal(b []byte) error

type Map

type Map string

type Message

type Message struct {
	// +kubebuilder:validation:MaxLength=64
	Data string      `json:"data" protobuf:"bytes,1,opt,name=data"`
	Time metav1.Time `json:"time" protobuf:"bytes,2,opt,name=time"`
}

func (*Message) DeepCopy

func (in *Message) DeepCopy() *Message

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

func (*Message) DeepCopyInto

func (in *Message) DeepCopyInto(out *Message)

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

func (*Message) Descriptor

func (*Message) Descriptor() ([]byte, []int)

func (*Message) Marshal

func (m *Message) Marshal() (dAtA []byte, err error)

func (*Message) MarshalTo

func (m *Message) MarshalTo(dAtA []byte) (int, error)

func (*Message) MarshalToSizedBuffer

func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) Size

func (m *Message) Size() (n int)

func (*Message) String

func (this *Message) String() string

func (*Message) Unmarshal

func (m *Message) Unmarshal(dAtA []byte) error

func (*Message) XXX_DiscardUnknown

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal

func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Message) XXX_Merge

func (m *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_Size

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal

func (m *Message) XXX_Unmarshal(b []byte) error

type Metadata

type Metadata struct {
	Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,1,rep,name=annotations"`
	Labels      map[string]string `json:"labels,omitempty" protobuf:"bytes,2,rep,name=labels"`
}

func (*Metadata) DeepCopy

func (in *Metadata) DeepCopy() *Metadata

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

func (*Metadata) DeepCopyInto

func (in *Metadata) DeepCopyInto(out *Metadata)

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

func (*Metadata) Descriptor

func (*Metadata) Descriptor() ([]byte, []int)

func (*Metadata) Marshal

func (m *Metadata) Marshal() (dAtA []byte, err error)

func (*Metadata) MarshalTo

func (m *Metadata) MarshalTo(dAtA []byte) (int, error)

func (*Metadata) MarshalToSizedBuffer

func (m *Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) Reset

func (m *Metadata) Reset()

func (*Metadata) Size

func (m *Metadata) Size() (n int)

func (*Metadata) String

func (this *Metadata) String() string

func (*Metadata) Unmarshal

func (m *Metadata) Unmarshal(dAtA []byte) error

func (*Metadata) XXX_DiscardUnknown

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal

func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metadata) XXX_Merge

func (m *Metadata) XXX_Merge(src proto.Message)

func (*Metadata) XXX_Size

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal

func (m *Metadata) XXX_Unmarshal(b []byte) error

type Metrics

type Metrics struct {
	Total  uint64 `json:"total,omitempty" protobuf:"varint,1,opt,name=total"`
	Errors uint64 `json:"errors,omitempty" protobuf:"varint,5,opt,name=errors"`
	Rate   uint64 `json:"rate,omitempty" protobuf:"varint,6,opt,name=rate"` // current rate of messages per second
}

func (*Metrics) DeepCopy

func (in *Metrics) DeepCopy() *Metrics

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

func (*Metrics) DeepCopyInto

func (in *Metrics) DeepCopyInto(out *Metrics)

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

func (*Metrics) Descriptor

func (*Metrics) Descriptor() ([]byte, []int)

func (*Metrics) Marshal

func (m *Metrics) Marshal() (dAtA []byte, err error)

func (*Metrics) MarshalTo

func (m *Metrics) MarshalTo(dAtA []byte) (int, error)

func (*Metrics) MarshalToSizedBuffer

func (m *Metrics) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Metrics) ProtoMessage

func (*Metrics) ProtoMessage()

func (*Metrics) Reset

func (m *Metrics) Reset()

func (*Metrics) Size

func (m *Metrics) Size() (n int)

func (*Metrics) String

func (this *Metrics) String() string

func (*Metrics) Unmarshal

func (m *Metrics) Unmarshal(dAtA []byte) error

func (*Metrics) XXX_DiscardUnknown

func (m *Metrics) XXX_DiscardUnknown()

func (*Metrics) XXX_Marshal

func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metrics) XXX_Merge

func (m *Metrics) XXX_Merge(src proto.Message)

func (*Metrics) XXX_Size

func (m *Metrics) XXX_Size() int

func (*Metrics) XXX_Unmarshal

func (m *Metrics) XXX_Unmarshal(b []byte) error

type Pipeline

type Pipeline struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Spec   PipelineSpec   `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	Status PipelineStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:resource:shortName=pl +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Phase",type=string,JSONPath=`.status.phase` +kubebuilder:printcolumn:name="Message",type=string,JSONPath=`.status.message`

func (*Pipeline) DeepCopy

func (in *Pipeline) DeepCopy() *Pipeline

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

func (*Pipeline) DeepCopyInto

func (in *Pipeline) DeepCopyInto(out *Pipeline)

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

func (*Pipeline) DeepCopyObject

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

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

func (*Pipeline) Descriptor

func (*Pipeline) Descriptor() ([]byte, []int)

func (*Pipeline) Marshal

func (m *Pipeline) Marshal() (dAtA []byte, err error)

func (*Pipeline) MarshalTo

func (m *Pipeline) MarshalTo(dAtA []byte) (int, error)

func (*Pipeline) MarshalToSizedBuffer

func (m *Pipeline) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Pipeline) ProtoMessage

func (*Pipeline) ProtoMessage()

func (*Pipeline) Reset

func (m *Pipeline) Reset()

func (*Pipeline) Size

func (m *Pipeline) Size() (n int)

func (*Pipeline) String

func (this *Pipeline) String() string

func (*Pipeline) Unmarshal

func (m *Pipeline) Unmarshal(dAtA []byte) error

func (*Pipeline) XXX_DiscardUnknown

func (m *Pipeline) XXX_DiscardUnknown()

func (*Pipeline) XXX_Marshal

func (m *Pipeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Pipeline) XXX_Merge

func (m *Pipeline) XXX_Merge(src proto.Message)

func (*Pipeline) XXX_Size

func (m *Pipeline) XXX_Size() int

func (*Pipeline) XXX_Unmarshal

func (m *Pipeline) XXX_Unmarshal(b []byte) error

type PipelineList

type PipelineList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []Pipeline `json:"items" protobuf:"bytes,2,rep,name=items"`
}

func (*PipelineList) DeepCopy

func (in *PipelineList) DeepCopy() *PipelineList

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

func (*PipelineList) DeepCopyInto

func (in *PipelineList) DeepCopyInto(out *PipelineList)

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

func (*PipelineList) DeepCopyObject

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

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

func (*PipelineList) Descriptor

func (*PipelineList) Descriptor() ([]byte, []int)

func (*PipelineList) Marshal

func (m *PipelineList) Marshal() (dAtA []byte, err error)

func (*PipelineList) MarshalTo

func (m *PipelineList) MarshalTo(dAtA []byte) (int, error)

func (*PipelineList) MarshalToSizedBuffer

func (m *PipelineList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PipelineList) ProtoMessage

func (*PipelineList) ProtoMessage()

func (*PipelineList) Reset

func (m *PipelineList) Reset()

func (*PipelineList) Size

func (m *PipelineList) Size() (n int)

func (*PipelineList) String

func (this *PipelineList) String() string

func (*PipelineList) Unmarshal

func (m *PipelineList) Unmarshal(dAtA []byte) error

func (*PipelineList) XXX_DiscardUnknown

func (m *PipelineList) XXX_DiscardUnknown()

func (*PipelineList) XXX_Marshal

func (m *PipelineList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineList) XXX_Merge

func (m *PipelineList) XXX_Merge(src proto.Message)

func (*PipelineList) XXX_Size

func (m *PipelineList) XXX_Size() int

func (*PipelineList) XXX_Unmarshal

func (m *PipelineList) XXX_Unmarshal(b []byte) error

type PipelinePhase

type PipelinePhase string

+kubebuilder:validation:Enum="";Pending;Running;Succeeded;Failed

const (
	PipelineUnknown   PipelinePhase = ""
	PipelinePending   PipelinePhase = "Pending"
	PipelineRunning   PipelinePhase = "Running"
	PipelineSucceeded PipelinePhase = "Succeeded"
	PipelineFailed    PipelinePhase = "Failed"
)

func MinPipelinePhase

func MinPipelinePhase(v ...PipelinePhase) PipelinePhase

func (PipelinePhase) Completed

func (p PipelinePhase) Completed() bool

type PipelineSpec

type PipelineSpec struct {
	// +patchStrategy=merge
	// +patchMergeKey=name
	Steps []StepSpec `json:"steps,omitempty" protobuf:"bytes,1,rep,name=steps"`
}

func (*PipelineSpec) DeepCopy

func (in *PipelineSpec) DeepCopy() *PipelineSpec

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

func (*PipelineSpec) DeepCopyInto

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

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

func (*PipelineSpec) Descriptor

func (*PipelineSpec) Descriptor() ([]byte, []int)

func (*PipelineSpec) HasStep

func (in *PipelineSpec) HasStep(name string) bool

func (*PipelineSpec) Marshal

func (m *PipelineSpec) Marshal() (dAtA []byte, err error)

func (*PipelineSpec) MarshalTo

func (m *PipelineSpec) MarshalTo(dAtA []byte) (int, error)

func (*PipelineSpec) MarshalToSizedBuffer

func (m *PipelineSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PipelineSpec) ProtoMessage

func (*PipelineSpec) ProtoMessage()

func (*PipelineSpec) Reset

func (m *PipelineSpec) Reset()

func (*PipelineSpec) Size

func (m *PipelineSpec) Size() (n int)

func (*PipelineSpec) String

func (this *PipelineSpec) String() string

func (*PipelineSpec) Unmarshal

func (m *PipelineSpec) Unmarshal(dAtA []byte) error

func (*PipelineSpec) XXX_DiscardUnknown

func (m *PipelineSpec) XXX_DiscardUnknown()

func (*PipelineSpec) XXX_Marshal

func (m *PipelineSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineSpec) XXX_Merge

func (m *PipelineSpec) XXX_Merge(src proto.Message)

func (*PipelineSpec) XXX_Size

func (m *PipelineSpec) XXX_Size() int

func (*PipelineSpec) XXX_Unmarshal

func (m *PipelineSpec) XXX_Unmarshal(b []byte) error

type PipelineStatus

type PipelineStatus struct {
	Phase      PipelinePhase      `json:"phase,omitempty" protobuf:"bytes,1,opt,name=phase,casttype=PipelinePhase"`
	Message    string             `json:"message,omitempty" protobuf:"bytes,2,opt,name=message"`
	Conditions []metav1.Condition `json:"conditions,omitempty" protobuf:"bytes,3,rep,name=conditions"`
}

func (*PipelineStatus) DeepCopy

func (in *PipelineStatus) DeepCopy() *PipelineStatus

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

func (*PipelineStatus) DeepCopyInto

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

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

func (*PipelineStatus) Descriptor

func (*PipelineStatus) Descriptor() ([]byte, []int)

func (*PipelineStatus) Marshal

func (m *PipelineStatus) Marshal() (dAtA []byte, err error)

func (*PipelineStatus) MarshalTo

func (m *PipelineStatus) MarshalTo(dAtA []byte) (int, error)

func (*PipelineStatus) MarshalToSizedBuffer

func (m *PipelineStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PipelineStatus) ProtoMessage

func (*PipelineStatus) ProtoMessage()

func (*PipelineStatus) Reset

func (m *PipelineStatus) Reset()

func (*PipelineStatus) Size

func (m *PipelineStatus) Size() (n int)

func (*PipelineStatus) String

func (this *PipelineStatus) String() string

func (*PipelineStatus) Unmarshal

func (m *PipelineStatus) Unmarshal(dAtA []byte) error

func (*PipelineStatus) XXX_DiscardUnknown

func (m *PipelineStatus) XXX_DiscardUnknown()

func (*PipelineStatus) XXX_Marshal

func (m *PipelineStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineStatus) XXX_Merge

func (m *PipelineStatus) XXX_Merge(src proto.Message)

func (*PipelineStatus) XXX_Size

func (m *PipelineStatus) XXX_Size() int

func (*PipelineStatus) XXX_Unmarshal

func (m *PipelineStatus) XXX_Unmarshal(b []byte) error

type Runtime

type Runtime string

+kubebuilder:validation:Enum=go1-16;java16;python3-9

type STAN

type STAN struct {
	// +kubebuilder:default=default
	Name          string        `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	NATSURL       string        `json:"natsUrl,omitempty" protobuf:"bytes,4,opt,name=natsUrl"`
	ClusterID     string        `json:"clusterId,omitempty" protobuf:"bytes,5,opt,name=clusterId"`
	Subject       string        `json:"subject" protobuf:"bytes,3,opt,name=subject"`
	SubjectPrefix SubjectPrefix `json:"subjectPrefix,omitempty" protobuf:"bytes,6,opt,name=subjectPrefix,casttype=SubjectPrefix"`
	// +kubebuilder:validation:Minimum=1
	// +kubebuilder:default=1
	Parallel uint32 `json:"parallel,omitempty" protobuf:"varint,7,opt,name=parallel"`
}

func (*STAN) DeepCopy

func (in *STAN) DeepCopy() *STAN

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

func (*STAN) DeepCopyInto

func (in *STAN) DeepCopyInto(out *STAN)

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

func (*STAN) Descriptor

func (*STAN) Descriptor() ([]byte, []int)

func (*STAN) Marshal

func (m *STAN) Marshal() (dAtA []byte, err error)

func (*STAN) MarshalTo

func (m *STAN) MarshalTo(dAtA []byte) (int, error)

func (*STAN) MarshalToSizedBuffer

func (m *STAN) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*STAN) ProtoMessage

func (*STAN) ProtoMessage()

func (*STAN) Reset

func (m *STAN) Reset()

func (*STAN) Size

func (m *STAN) Size() (n int)

func (*STAN) String

func (this *STAN) String() string

func (*STAN) Unmarshal

func (m *STAN) Unmarshal(dAtA []byte) error

func (*STAN) XXX_DiscardUnknown

func (m *STAN) XXX_DiscardUnknown()

func (*STAN) XXX_Marshal

func (m *STAN) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*STAN) XXX_Merge

func (m *STAN) XXX_Merge(src proto.Message)

func (*STAN) XXX_Size

func (m *STAN) XXX_Size() int

func (*STAN) XXX_Unmarshal

func (m *STAN) XXX_Unmarshal(b []byte) error

type Scale added in v0.0.9

type Scale struct {
	MinReplicas  int32   `json:"minReplicas" protobuf:"varint,1,opt,name=minReplicas"`
	MaxReplicas  *uint32 `json:"maxReplicas,omitempty" protobuf:"varint,2,opt,name=maxReplicas"` // takes precedence over min
	ReplicaRatio uint32  `json:"replicaRatio,omitempty" protobuf:"varint,3,opt,name=replicaRatio"`
}

func (Scale) Calculate added in v0.0.9

func (in Scale) Calculate(pending int) int

Used to calculate the number of replicas. min(r.max, max(r.min, pending/ratio)) Example: min=1, max=4, ratio=100 pending=0, replicas=1 pending=100, replicas=1 pending=200, replicas=2 pending=300, replicas=3 pending=400, replicas=4 pending=500, replicas=4

func (*Scale) DeepCopy added in v0.0.9

func (in *Scale) DeepCopy() *Scale

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

func (*Scale) DeepCopyInto added in v0.0.9

func (in *Scale) DeepCopyInto(out *Scale)

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

func (*Scale) Descriptor added in v0.0.9

func (*Scale) Descriptor() ([]byte, []int)

func (*Scale) Marshal added in v0.0.9

func (m *Scale) Marshal() (dAtA []byte, err error)

func (*Scale) MarshalTo added in v0.0.9

func (m *Scale) MarshalTo(dAtA []byte) (int, error)

func (*Scale) MarshalToSizedBuffer added in v0.0.9

func (m *Scale) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Scale) ProtoMessage added in v0.0.9

func (*Scale) ProtoMessage()

func (*Scale) Reset added in v0.0.9

func (m *Scale) Reset()

func (*Scale) Size added in v0.0.9

func (m *Scale) Size() (n int)

func (*Scale) String added in v0.0.9

func (this *Scale) String() string

func (*Scale) Unmarshal added in v0.0.9

func (m *Scale) Unmarshal(dAtA []byte) error

func (*Scale) XXX_DiscardUnknown added in v0.0.9

func (m *Scale) XXX_DiscardUnknown()

func (*Scale) XXX_Marshal added in v0.0.9

func (m *Scale) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Scale) XXX_Merge added in v0.0.9

func (m *Scale) XXX_Merge(src proto.Message)

func (*Scale) XXX_Size added in v0.0.9

func (m *Scale) XXX_Size() int

func (*Scale) XXX_Unmarshal added in v0.0.9

func (m *Scale) XXX_Unmarshal(b []byte) error

type Sink

type Sink struct {
	// +kubebuilder:default=default
	Name  string    `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	STAN  *STAN     `json:"stan,omitempty" protobuf:"bytes,2,opt,name=stan"`
	Kafka *Kafka    `json:"kafka,omitempty" protobuf:"bytes,3,opt,name=kafka"`
	Log   *Log      `json:"log,omitempty" protobuf:"bytes,4,opt,name=log"`
	HTTP  *HTTPSink `json:"http,omitempty" protobuf:"bytes,5,opt,name=http"`
}

func (*Sink) DeepCopy

func (in *Sink) DeepCopy() *Sink

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

func (*Sink) DeepCopyInto

func (in *Sink) DeepCopyInto(out *Sink)

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

func (*Sink) Descriptor

func (*Sink) Descriptor() ([]byte, []int)

func (*Sink) Marshal

func (m *Sink) Marshal() (dAtA []byte, err error)

func (*Sink) MarshalTo

func (m *Sink) MarshalTo(dAtA []byte) (int, error)

func (*Sink) MarshalToSizedBuffer

func (m *Sink) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Sink) ProtoMessage

func (*Sink) ProtoMessage()

func (*Sink) Reset

func (m *Sink) Reset()

func (*Sink) Size

func (m *Sink) Size() (n int)

func (*Sink) String

func (this *Sink) String() string

func (*Sink) Unmarshal

func (m *Sink) Unmarshal(dAtA []byte) error

func (*Sink) XXX_DiscardUnknown

func (m *Sink) XXX_DiscardUnknown()

func (*Sink) XXX_Marshal

func (m *Sink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Sink) XXX_Merge

func (m *Sink) XXX_Merge(src proto.Message)

func (*Sink) XXX_Size

func (m *Sink) XXX_Size() int

func (*Sink) XXX_Unmarshal

func (m *Sink) XXX_Unmarshal(b []byte) error

type SinkStatus

type SinkStatus struct {
	LastMessage *Message           `json:"lastMessage,omitempty" protobuf:"bytes,2,opt,name=lastMessage"`
	LastError   *Error             `json:"lastError,omitempty" protobuf:"bytes,4,opt,name=lastError"`
	Metrics     map[string]Metrics `json:"metrics,omitempty" protobuf:"bytes,3,rep,name=metrics"`
}

func (*SinkStatus) AnyErrors

func (in *SinkStatus) AnyErrors() bool

func (*SinkStatus) DeepCopy

func (in *SinkStatus) DeepCopy() *SinkStatus

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

func (*SinkStatus) DeepCopyInto

func (in *SinkStatus) DeepCopyInto(out *SinkStatus)

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

func (*SinkStatus) Descriptor

func (*SinkStatus) Descriptor() ([]byte, []int)

func (*SinkStatus) Marshal

func (m *SinkStatus) Marshal() (dAtA []byte, err error)

func (*SinkStatus) MarshalTo

func (m *SinkStatus) MarshalTo(dAtA []byte) (int, error)

func (*SinkStatus) MarshalToSizedBuffer

func (m *SinkStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SinkStatus) ProtoMessage

func (*SinkStatus) ProtoMessage()

func (*SinkStatus) Reset

func (m *SinkStatus) Reset()

func (*SinkStatus) Size

func (m *SinkStatus) Size() (n int)

func (*SinkStatus) String

func (this *SinkStatus) String() string

func (*SinkStatus) Unmarshal

func (m *SinkStatus) Unmarshal(dAtA []byte) error

func (*SinkStatus) XXX_DiscardUnknown

func (m *SinkStatus) XXX_DiscardUnknown()

func (*SinkStatus) XXX_Marshal

func (m *SinkStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SinkStatus) XXX_Merge

func (m *SinkStatus) XXX_Merge(src proto.Message)

func (*SinkStatus) XXX_Size

func (m *SinkStatus) XXX_Size() int

func (*SinkStatus) XXX_Unmarshal

func (m *SinkStatus) XXX_Unmarshal(b []byte) error

type SinkStatuses

type SinkStatuses map[string]SinkStatus

func (SinkStatuses) AnyErrors

func (in SinkStatuses) AnyErrors() bool

func (SinkStatuses) AnySunk

func (in SinkStatuses) AnySunk() bool

func (SinkStatuses) DeepCopy

func (in SinkStatuses) DeepCopy() SinkStatuses

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

func (SinkStatuses) DeepCopyInto

func (in SinkStatuses) DeepCopyInto(out *SinkStatuses)

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

func (SinkStatuses) IncErrors added in v0.0.4

func (in SinkStatuses) IncErrors(name string, replica int, err error)

func (SinkStatuses) Set

func (in SinkStatuses) Set(name string, replica int, msg string)

type Source

type Source struct {
	// +kubebuilder:default=default
	Name  string      `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	Cron  *Cron       `json:"cron,omitempty" protobuf:"bytes,2,opt,name=cron"`
	STAN  *STAN       `json:"stan,omitempty" protobuf:"bytes,3,opt,name=stan"`
	Kafka *Kafka      `json:"kafka,omitempty" protobuf:"bytes,4,opt,name=kafka"`
	HTTP  *HTTPSource `json:"http,omitempty" protobuf:"bytes,5,opt,name=http"`
}

func (*Source) DeepCopy

func (in *Source) DeepCopy() *Source

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

func (*Source) DeepCopyInto

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

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

func (*Source) Descriptor

func (*Source) Descriptor() ([]byte, []int)

func (*Source) Marshal

func (m *Source) Marshal() (dAtA []byte, err error)

func (*Source) MarshalTo

func (m *Source) MarshalTo(dAtA []byte) (int, error)

func (*Source) MarshalToSizedBuffer

func (m *Source) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Source) ProtoMessage

func (*Source) ProtoMessage()

func (*Source) Reset

func (m *Source) Reset()

func (*Source) Size

func (m *Source) Size() (n int)

func (*Source) String

func (this *Source) String() string

func (*Source) Unmarshal

func (m *Source) Unmarshal(dAtA []byte) error

func (*Source) XXX_DiscardUnknown

func (m *Source) XXX_DiscardUnknown()

func (*Source) XXX_Marshal

func (m *Source) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Source) XXX_Merge

func (m *Source) XXX_Merge(src proto.Message)

func (*Source) XXX_Size

func (m *Source) XXX_Size() int

func (*Source) XXX_Unmarshal

func (m *Source) XXX_Unmarshal(b []byte) error

type SourceStatus

type SourceStatus struct {
	LastMessage *Message           `json:"lastMessage,omitempty" protobuf:"bytes,2,opt,name=lastMessage"`
	LastError   *Error             `json:"lastError,omitempty" protobuf:"bytes,5,opt,name=lastError"`
	Pending     *uint64            `json:"pending,omitempty" protobuf:"varint,3,opt,name=pending"`
	Metrics     map[string]Metrics `json:"metrics,omitempty" protobuf:"bytes,4,rep,name=metrics"`
}

func (*SourceStatus) AnyErrors

func (in *SourceStatus) AnyErrors() bool

func (*SourceStatus) DeepCopy

func (in *SourceStatus) DeepCopy() *SourceStatus

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

func (*SourceStatus) DeepCopyInto

func (in *SourceStatus) DeepCopyInto(out *SourceStatus)

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

func (*SourceStatus) Descriptor

func (*SourceStatus) Descriptor() ([]byte, []int)

func (*SourceStatus) Marshal

func (m *SourceStatus) Marshal() (dAtA []byte, err error)

func (*SourceStatus) MarshalTo

func (m *SourceStatus) MarshalTo(dAtA []byte) (int, error)

func (*SourceStatus) MarshalToSizedBuffer

func (m *SourceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SourceStatus) ProtoMessage

func (*SourceStatus) ProtoMessage()

func (*SourceStatus) Reset

func (m *SourceStatus) Reset()

func (*SourceStatus) Size

func (m *SourceStatus) Size() (n int)

func (*SourceStatus) String

func (this *SourceStatus) String() string

func (*SourceStatus) Unmarshal

func (m *SourceStatus) Unmarshal(dAtA []byte) error

func (*SourceStatus) XXX_DiscardUnknown

func (m *SourceStatus) XXX_DiscardUnknown()

func (*SourceStatus) XXX_Marshal

func (m *SourceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SourceStatus) XXX_Merge

func (m *SourceStatus) XXX_Merge(src proto.Message)

func (*SourceStatus) XXX_Size

func (m *SourceStatus) XXX_Size() int

func (*SourceStatus) XXX_Unmarshal

func (m *SourceStatus) XXX_Unmarshal(b []byte) error

type SourceStatuses

type SourceStatuses map[string]SourceStatus // key is replica

func (SourceStatuses) AnyErrors

func (in SourceStatuses) AnyErrors() bool

func (SourceStatuses) DeepCopy

func (in SourceStatuses) DeepCopy() SourceStatuses

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

func (SourceStatuses) DeepCopyInto

func (in SourceStatuses) DeepCopyInto(out *SourceStatuses)

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

func (SourceStatuses) GetPending

func (in SourceStatuses) GetPending() int

func (SourceStatuses) IncErrors

func (in SourceStatuses) IncErrors(name string, replica int, err error)

func (SourceStatuses) Set

func (in SourceStatuses) Set(name string, replica int, msg string, rate uint64)

func (SourceStatuses) SetPending

func (in SourceStatuses) SetPending(name string, pending uint64)

type Sources added in v0.0.10

type Sources []Source

func (Sources) Any added in v0.0.10

func (ss Sources) Any(fn func(value Source) bool) bool

Any will return true if any callbacks return true. It follows the same logic as the any() function in Python.

If the list is empty then false is always returned.

func (Sources) DeepCopy added in v0.0.10

func (in Sources) DeepCopy() Sources

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

func (Sources) DeepCopyInto added in v0.0.10

func (in Sources) DeepCopyInto(out *Sources)

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

type Step

type Step struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Spec   StepSpec   `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	Status StepStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:subresource:scale:specpath=.spec.replicas,statuspath=.status.replicas,selectorpath=.status.selector +kubebuilder:printcolumn:name="Phase",type=string,JSONPath=`.status.phase` +kubebuilder:printcolumn:name="Reason",type=string,JSONPath=`.status.reason` +kubebuilder:printcolumn:name="Message",type=string,JSONPath=`.status.message` +kubebuilder:printcolumn:name="Desired",type=string,JSONPath=`.spec.replicas` +kubebuilder:printcolumn:name="Current",type=string,JSONPath=`.status.replicas`

func (*Step) DeepCopy

func (in *Step) DeepCopy() *Step

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

func (*Step) DeepCopyInto

func (in *Step) DeepCopyInto(out *Step)

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

func (*Step) DeepCopyObject

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

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

func (*Step) Descriptor

func (*Step) Descriptor() ([]byte, []int)

func (*Step) GetTargetReplicas

func (in *Step) GetTargetReplicas(currentReplicas int, scalingDelay, peekDelay time.Duration) int

func (*Step) Marshal

func (m *Step) Marshal() (dAtA []byte, err error)

func (*Step) MarshalTo

func (m *Step) MarshalTo(dAtA []byte) (int, error)

func (*Step) MarshalToSizedBuffer

func (m *Step) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Step) ProtoMessage

func (*Step) ProtoMessage()

func (*Step) Reset

func (m *Step) Reset()

func (*Step) Size

func (m *Step) Size() (n int)

func (*Step) String

func (this *Step) String() string

func (*Step) Unmarshal

func (m *Step) Unmarshal(dAtA []byte) error

func (*Step) XXX_DiscardUnknown

func (m *Step) XXX_DiscardUnknown()

func (*Step) XXX_Marshal

func (m *Step) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Step) XXX_Merge

func (m *Step) XXX_Merge(src proto.Message)

func (*Step) XXX_Size

func (m *Step) XXX_Size() int

func (*Step) XXX_Unmarshal

func (m *Step) XXX_Unmarshal(b []byte) error

type StepList

type StepList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []Step `json:"items" protobuf:"bytes,2,rep,name=items"`
}

func (*StepList) DeepCopy

func (in *StepList) DeepCopy() *StepList

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

func (*StepList) DeepCopyInto

func (in *StepList) DeepCopyInto(out *StepList)

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

func (*StepList) DeepCopyObject

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

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

func (*StepList) Descriptor

func (*StepList) Descriptor() ([]byte, []int)

func (*StepList) Marshal

func (m *StepList) Marshal() (dAtA []byte, err error)

func (*StepList) MarshalTo

func (m *StepList) MarshalTo(dAtA []byte) (int, error)

func (*StepList) MarshalToSizedBuffer

func (m *StepList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StepList) ProtoMessage

func (*StepList) ProtoMessage()

func (*StepList) Reset

func (m *StepList) Reset()

func (*StepList) Size

func (m *StepList) Size() (n int)

func (*StepList) String

func (this *StepList) String() string

func (*StepList) Unmarshal

func (m *StepList) Unmarshal(dAtA []byte) error

func (*StepList) XXX_DiscardUnknown

func (m *StepList) XXX_DiscardUnknown()

func (*StepList) XXX_Marshal

func (m *StepList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StepList) XXX_Merge

func (m *StepList) XXX_Merge(src proto.Message)

func (*StepList) XXX_Size

func (m *StepList) XXX_Size() int

func (*StepList) XXX_Unmarshal

func (m *StepList) XXX_Unmarshal(b []byte) error

type StepPhase

type StepPhase string

+kubebuilder:validation:Enum="";Pending;Running;Succeeded;Failed

const (
	StepUnknown   StepPhase = ""
	StepPending   StepPhase = "Pending"
	StepRunning   StepPhase = "Running"
	StepSucceeded StepPhase = "Succeeded"
	StepFailed    StepPhase = "Failed"
)

func (StepPhase) Completed

func (p StepPhase) Completed() bool

type StepPhaseMessage

type StepPhaseMessage string

func MinStepPhaseMessage

func MinStepPhaseMessage(v ...StepPhaseMessage) StepPhaseMessage

func NewStepPhaseMessage

func NewStepPhaseMessage(phase StepPhase, reason, message string) StepPhaseMessage

func (StepPhaseMessage) GetMessage

func (m StepPhaseMessage) GetMessage() string

func (StepPhaseMessage) GetPhase

func (m StepPhaseMessage) GetPhase() StepPhase

func (StepPhaseMessage) GetReason added in v0.0.15

func (m StepPhaseMessage) GetReason() string

type StepSpec

type StepSpec struct {
	// +kubebuilder:default=default
	Name      string     `json:"name" protobuf:"bytes,6,opt,name=name"`
	Cat       *Cat       `json:"cat,omitempty" protobuf:"bytes,15,opt,name=cat"`
	Container *Container `json:"container,omitempty" protobuf:"bytes,1,opt,name=container"`
	Handler   *Handler   `json:"handler,omitempty" protobuf:"bytes,7,opt,name=handler"`
	Git       *Git       `json:"git,omitempty" protobuf:"bytes,12,opt,name=git"`
	Filter    Filter     `json:"filter,omitempty" protobuf:"bytes,8,opt,name=filter,casttype=Filter"`
	Map       Map        `json:"map,omitempty" protobuf:"bytes,9,opt,name=map,casttype=Map"`
	Group     *Group     `json:"group,omitempty" protobuf:"bytes,11,opt,name=group"`
	Flatten   *Flatten   `json:"flatten,omitempty" protobuf:"bytes,25,opt,name=flatten"`
	Expand    *Expand    `json:"expand,omitempty" protobuf:"bytes,26,opt,name=expand"`

	Replicas *uint32 `json:"replicas,omitempty" protobuf:"varint,23,opt,name=replicas"`
	Scale    *Scale  `json:"scale,omitempty" protobuf:"bytes,24,opt,name=scale"`
	// +patchStrategy=merge
	// +patchMergeKey=name
	Sources Sources `json:"sources,omitempty" protobuf:"bytes,3,rep,name=sources"`
	// +patchStrategy=merge
	// +patchMergeKey=name
	Sinks []Sink `json:"sinks,omitempty" protobuf:"bytes,4,rep,name=sinks"`
	// +kubebuilder:default=OnFailure
	RestartPolicy corev1.RestartPolicy `json:"restartPolicy,omitempty" protobuf:"bytes,5,opt,name=restartPolicy,casttype=k8s.io/api/core/v1.RestartPolicy"`
	Terminator    bool                 `json:"terminator,omitempty" protobuf:"varint,10,opt,name=terminator"` // if this step terminates, terminate all steps in the pipeline
	// +patchStrategy=merge
	// +patchMergeKey=name
	Volumes []corev1.Volume `json:"volumes,omitempty" protobuf:"bytes,13,rep,name=volumes"`
	// +kubebuilder:default=pipeline
	ServiceAccountName string              `json:"serviceAccountName,omitempty" protobuf:"bytes,14,opt,name=serviceAccountName"`
	Metadata           *Metadata           `json:"metadata,omitempty" protobuf:"bytes,16,opt,name=metadata"`
	NodeSelector       map[string]string   `json:"nodeSelector,omitempty" protobuf:"bytes,17,rep,name=nodeSelector"`
	Affinity           *corev1.Affinity    `json:"affinity,omitempty" protobuf:"bytes,18,opt,name=affinity"`
	Tolerations        []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,19,rep,name=tolerations"`
}

func (*StepSpec) CalculateReplicas added in v0.0.9

func (in *StepSpec) CalculateReplicas(pending int) int

func (*StepSpec) DeepCopy

func (in *StepSpec) DeepCopy() *StepSpec

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

func (*StepSpec) DeepCopyInto

func (in *StepSpec) DeepCopyInto(out *StepSpec)

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

func (*StepSpec) Descriptor

func (*StepSpec) Descriptor() ([]byte, []int)

func (*StepSpec) GetContainer

func (in *StepSpec) GetContainer(imageFormat, runnerImage string, policy corev1.PullPolicy, mnt corev1.VolumeMount) corev1.Container

func (*StepSpec) GetIn

func (in *StepSpec) GetIn() *Interface

func (*StepSpec) GetPodSpec

func (in *StepSpec) GetPodSpec(req GetPodSpecReq) corev1.PodSpec

func (*StepSpec) Marshal

func (m *StepSpec) Marshal() (dAtA []byte, err error)

func (*StepSpec) MarshalTo

func (m *StepSpec) MarshalTo(dAtA []byte) (int, error)

func (*StepSpec) MarshalToSizedBuffer

func (m *StepSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StepSpec) ProtoMessage

func (*StepSpec) ProtoMessage()

func (*StepSpec) Reset

func (m *StepSpec) Reset()

func (*StepSpec) Size

func (m *StepSpec) Size() (n int)

func (*StepSpec) String

func (this *StepSpec) String() string

func (*StepSpec) Unmarshal

func (m *StepSpec) Unmarshal(dAtA []byte) error

func (*StepSpec) XXX_DiscardUnknown

func (m *StepSpec) XXX_DiscardUnknown()

func (*StepSpec) XXX_Marshal

func (m *StepSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StepSpec) XXX_Merge

func (m *StepSpec) XXX_Merge(src proto.Message)

func (*StepSpec) XXX_Size

func (m *StepSpec) XXX_Size() int

func (*StepSpec) XXX_Unmarshal

func (m *StepSpec) XXX_Unmarshal(b []byte) error

type StepStatus

type StepStatus struct {
	Phase          StepPhase      `json:"phase" protobuf:"bytes,1,opt,name=phase,casttype=StepPhase"`
	Reason         string         `json:"reason" protobuf:"bytes,8,opt,name=reason"`
	Message        string         `json:"message" protobuf:"bytes,2,opt,name=message"`
	Replicas       uint32         `json:"replicas" protobuf:"varint,5,opt,name=replicas"`
	Selector       string         `json:"selector,omitempty" protobuf:"bytes,7,opt,name=selector"`
	LastScaledAt   metav1.Time    `json:"lastScaledAt,omitempty" protobuf:"bytes,6,opt,name=lastScaledAt"`
	SourceStatuses SourceStatuses `json:"sourceStatuses" protobuf:"bytes,3,rep,name=sourceStatuses"`
	SinkStatues    SinkStatuses   `json:"sinkStatuses" protobuf:"bytes,4,rep,name=sinkStatuses"`
}

func (StepStatus) AnyErrors

func (in StepStatus) AnyErrors() bool

func (*StepStatus) DeepCopy

func (in *StepStatus) DeepCopy() *StepStatus

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

func (*StepStatus) DeepCopyInto

func (in *StepStatus) DeepCopyInto(out *StepStatus)

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

func (*StepStatus) Descriptor

func (*StepStatus) Descriptor() ([]byte, []int)

func (StepStatus) GetReplicas

func (m StepStatus) GetReplicas() int

func (*StepStatus) Marshal

func (m *StepStatus) Marshal() (dAtA []byte, err error)

func (*StepStatus) MarshalTo

func (m *StepStatus) MarshalTo(dAtA []byte) (int, error)

func (*StepStatus) MarshalToSizedBuffer

func (m *StepStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StepStatus) ProtoMessage

func (*StepStatus) ProtoMessage()

func (*StepStatus) Reset

func (m *StepStatus) Reset()

func (*StepStatus) Size

func (m *StepStatus) Size() (n int)

func (*StepStatus) String

func (this *StepStatus) String() string

func (*StepStatus) Unmarshal

func (m *StepStatus) Unmarshal(dAtA []byte) error

func (*StepStatus) XXX_DiscardUnknown

func (m *StepStatus) XXX_DiscardUnknown()

func (*StepStatus) XXX_Marshal

func (m *StepStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StepStatus) XXX_Merge

func (m *StepStatus) XXX_Merge(src proto.Message)

func (*StepStatus) XXX_Size

func (m *StepStatus) XXX_Size() int

func (*StepStatus) XXX_Unmarshal

func (m *StepStatus) XXX_Unmarshal(b []byte) error

type Storage

type Storage struct {
	Name    string `json:"name" protobuf:"bytes,1,opt,name=name"` // volume name
	SubPath string `json:"subPath,omitempty" protobuf:"bytes,2,opt,name=subPath"`
}

func (*Storage) DeepCopy

func (in *Storage) DeepCopy() *Storage

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

func (*Storage) DeepCopyInto

func (in *Storage) DeepCopyInto(out *Storage)

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

func (*Storage) Descriptor

func (*Storage) Descriptor() ([]byte, []int)

func (*Storage) Marshal

func (m *Storage) Marshal() (dAtA []byte, err error)

func (*Storage) MarshalTo

func (m *Storage) MarshalTo(dAtA []byte) (int, error)

func (*Storage) MarshalToSizedBuffer

func (m *Storage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Storage) ProtoMessage

func (*Storage) ProtoMessage()

func (*Storage) Reset

func (m *Storage) Reset()

func (*Storage) Size

func (m *Storage) Size() (n int)

func (*Storage) String

func (this *Storage) String() string

func (*Storage) Unmarshal

func (m *Storage) Unmarshal(dAtA []byte) error

func (*Storage) XXX_DiscardUnknown

func (m *Storage) XXX_DiscardUnknown()

func (*Storage) XXX_Marshal

func (m *Storage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Storage) XXX_Merge

func (m *Storage) XXX_Merge(src proto.Message)

func (*Storage) XXX_Size

func (m *Storage) XXX_Size() int

func (*Storage) XXX_Unmarshal

func (m *Storage) XXX_Unmarshal(b []byte) error

type SubjectPrefix

type SubjectPrefix string

+kubebuilder:validation:Enum="";None;NamespaceName;NamespacedPipelineName

const (
	SubjectPrefixNone                   SubjectPrefix = "None"
	SubjectPrefixNamespaceName          SubjectPrefix = "NamespaceName"
	SubjectPrefixNamespacedPipelineName SubjectPrefix = "NamespacedPipelineName"
)

func SubjectPrefixOr

func SubjectPrefixOr(a, b SubjectPrefix) SubjectPrefix

type TLS

type TLS struct{}

func (*TLS) DeepCopy

func (in *TLS) DeepCopy() *TLS

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

func (*TLS) DeepCopyInto

func (in *TLS) DeepCopyInto(out *TLS)

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

func (*TLS) Descriptor

func (*TLS) Descriptor() ([]byte, []int)

func (*TLS) Marshal

func (m *TLS) Marshal() (dAtA []byte, err error)

func (*TLS) MarshalTo

func (m *TLS) MarshalTo(dAtA []byte) (int, error)

func (*TLS) MarshalToSizedBuffer

func (m *TLS) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TLS) ProtoMessage

func (*TLS) ProtoMessage()

func (*TLS) Reset

func (m *TLS) Reset()

func (*TLS) Size

func (m *TLS) Size() (n int)

func (*TLS) String

func (this *TLS) String() string

func (*TLS) Unmarshal

func (m *TLS) Unmarshal(dAtA []byte) error

func (*TLS) XXX_DiscardUnknown

func (m *TLS) XXX_DiscardUnknown()

func (*TLS) XXX_Marshal

func (m *TLS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TLS) XXX_Merge

func (m *TLS) XXX_Merge(src proto.Message)

func (*TLS) XXX_Size

func (m *TLS) XXX_Size() int

func (*TLS) XXX_Unmarshal

func (m *TLS) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

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