v1alpha1

package
v0.0.75 Latest Latest
Warning

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

 Go to latest Published: Jul 27, 2021 License: Apache-2.0 Imports: 20 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
	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
	EnvBearerToken    = "ARGO_DATAFLOW_BEARER_TOKEN"
	EnvImagePrefix    = "ARGO_DATAFLOW_IMAGE_PREFIX"   // default "quay.io/argoproj"
	EnvDeletionDelay  = "ARGO_DATAFLOW_DELETION_DELAY" // default "720h" ~= "30d"
	EnvNamespace      = "ARGO_DATAFLOW_NAMESPACE"
	EnvPipelineName   = "ARGO_DATAFLOW_PIPELINE_NAME"
	EnvReplica        = "ARGO_DATAFLOW_REPLICA"
	EnvStep           = "ARGO_DATAFLOW_STEP"
	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 "1m"
	// label/annotation keys
	KeyDefaultContainer = "kubectl.kubernetes.io/default-container"
	KeyDescription      = "dataflow.argoproj.io/description"
	KeyFinalizer        = "dataflow.argoproj.io/finalizer"
	KeyOwner            = "dataflow.argoproj.io/owner"
	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"
	// other const
	CommitN = 20 // how many messages between commits, therefore potential duplicates during disruption
)

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 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 AWSCredentials added in v0.0.74 

type AWSCredentials struct {
	AccessKeyID     corev1.SecretKeySelector `json:"accessKeyId" protobuf:"bytes,1,opt,name=accessKeyId"`
	SecretAccessKey corev1.SecretKeySelector `json:"secretAccessKey" protobuf:"bytes,2,opt,name=secretAccessKey"`
}

func (*AWSCredentials) DeepCopy added in v0.0.74 

func (in *AWSCredentials) DeepCopy() *AWSCredentials

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

func (*AWSCredentials) DeepCopyInto added in v0.0.74 

func (in *AWSCredentials) DeepCopyInto(out *AWSCredentials)

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

func (*AWSCredentials) Descriptor added in v0.0.74 

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

func (*AWSCredentials) Marshal added in v0.0.74 

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

func (*AWSCredentials) MarshalTo added in v0.0.74 

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

func (*AWSCredentials) MarshalToSizedBuffer added in v0.0.74 

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

func (*AWSCredentials) ProtoMessage added in v0.0.74 

func (*AWSCredentials) ProtoMessage()

func (*AWSCredentials) Reset added in v0.0.74 

func (m *AWSCredentials) Reset()

func (*AWSCredentials) Size added in v0.0.74 

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

func (*AWSCredentials) String added in v0.0.74 

func (this *AWSCredentials) String() string

func (*AWSCredentials) Unmarshal added in v0.0.74 

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

func (*AWSCredentials) XXX_DiscardUnknown added in v0.0.74 

func (m *AWSCredentials) XXX_DiscardUnknown()

func (*AWSCredentials) XXX_Marshal added in v0.0.74 

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

func (*AWSCredentials) XXX_Merge added in v0.0.74 

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

func (*AWSCredentials) XXX_Size added in v0.0.74 

func (m *AWSCredentials) XXX_Size() int

func (*AWSCredentials) XXX_Unmarshal added in v0.0.74 

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

type AWSEndpoint added in v0.0.74 

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

func (*AWSEndpoint) DeepCopy added in v0.0.74 

func (in *AWSEndpoint) DeepCopy() *AWSEndpoint

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

func (*AWSEndpoint) DeepCopyInto added in v0.0.74 

func (in *AWSEndpoint) DeepCopyInto(out *AWSEndpoint)

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

func (*AWSEndpoint) Descriptor added in v0.0.74 

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

func (*AWSEndpoint) Marshal added in v0.0.74 

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

func (*AWSEndpoint) MarshalTo added in v0.0.74 

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

func (*AWSEndpoint) MarshalToSizedBuffer added in v0.0.74 

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

func (*AWSEndpoint) ProtoMessage added in v0.0.74 

func (*AWSEndpoint) ProtoMessage()

func (*AWSEndpoint) Reset added in v0.0.74 

func (m *AWSEndpoint) Reset()

func (*AWSEndpoint) Size added in v0.0.74 

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

func (*AWSEndpoint) String added in v0.0.74 

func (this *AWSEndpoint) String() string

func (*AWSEndpoint) Unmarshal added in v0.0.74 

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

func (*AWSEndpoint) XXX_DiscardUnknown added in v0.0.74 

func (m *AWSEndpoint) XXX_DiscardUnknown()

func (*AWSEndpoint) XXX_Marshal added in v0.0.74 

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

func (*AWSEndpoint) XXX_Merge added in v0.0.74 

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

func (*AWSEndpoint) XXX_Size added in v0.0.74 

func (m *AWSEndpoint) XXX_Size() int

func (*AWSEndpoint) XXX_Unmarshal added in v0.0.74 

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

type Backoff added in v0.0.60 

type Backoff struct {
	// the number of backoff steps, zero means no retries
	Steps uint64 `json:"steps,omitempty" protobuf:"varint,1,opt,name=steps"`
	// the cap of the backoff, should be >100ms, otherwise backoff is capped immediately
	Cap metav1.Duration `json:"cap,omitempty" protobuf:"bytes,2,opt,name=cap"`
	// the amount of jitter per step, typically 10-20%, >100% is valid, but strange
	JitterPercentage uint32 `json:"jitterPercentage,omitempty" protobuf:"varint,3,opt,name=jitterPercentage"`
}

default backoff is 100ms

func (*Backoff) DeepCopy added in v0.0.60 

func (in *Backoff) DeepCopy() *Backoff

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

func (*Backoff) DeepCopyInto added in v0.0.60 

func (in *Backoff) DeepCopyInto(out *Backoff)

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

func (*Backoff) Descriptor added in v0.0.60 

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

func (*Backoff) Marshal added in v0.0.60 

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

func (*Backoff) MarshalTo added in v0.0.60 

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

func (*Backoff) MarshalToSizedBuffer added in v0.0.60 

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

func (*Backoff) ProtoMessage added in v0.0.60 

func (*Backoff) ProtoMessage()

func (*Backoff) Reset added in v0.0.60 

func (m *Backoff) Reset()

func (*Backoff) Size added in v0.0.60 

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

func (*Backoff) String added in v0.0.60 

func (this *Backoff) String() string

func (*Backoff) Unmarshal added in v0.0.60 

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

func (*Backoff) XXX_DiscardUnknown added in v0.0.60 

func (m *Backoff) XXX_DiscardUnknown()

func (*Backoff) XXX_Marshal added in v0.0.60 

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

func (*Backoff) XXX_Merge added in v0.0.60 

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

func (*Backoff) XXX_Size added in v0.0.60 

func (m *Backoff) XXX_Size() int

func (*Backoff) XXX_Unmarshal added in v0.0.60 

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

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 Code added in v0.0.71 

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

func (*Code) DeepCopy added in v0.0.71 

func (in *Code) DeepCopy() *Code

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

func (*Code) DeepCopyInto added in v0.0.71 

func (in *Code) DeepCopyInto(out *Code)

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

func (*Code) Descriptor added in v0.0.71 

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

func (*Code) Marshal added in v0.0.71 

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

func (*Code) MarshalTo added in v0.0.71 

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

func (*Code) MarshalToSizedBuffer added in v0.0.71 

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

func (*Code) ProtoMessage added in v0.0.71 

func (*Code) ProtoMessage()

func (*Code) Reset added in v0.0.71 

func (m *Code) Reset()

func (*Code) Size added in v0.0.71 

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

func (*Code) String added in v0.0.71 

func (this *Code) String() string

func (*Code) Unmarshal added in v0.0.71 

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

func (*Code) XXX_DiscardUnknown added in v0.0.71 

func (m *Code) XXX_DiscardUnknown()

func (*Code) XXX_Marshal added in v0.0.71 

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

func (*Code) XXX_Merge added in v0.0.71 

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

func (*Code) XXX_Size added in v0.0.71 

func (m *Code) XXX_Size() int

func (*Code) XXX_Unmarshal added in v0.0.71 

func (m *Code) 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"`
	Resources    corev1.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,9,opt,name=resources"`
}

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 Dedupe added in v0.0.57 

type Dedupe struct {
	// +kubebuilder:default="sha1(msg)"
	UID string `json:"uid,omitempty" protobuf:"bytes,1,opt,name=uid"`
	// MaxSize is the maximum number of entries to keep in the in-memory database used to store recent UIDs.
	// Larger number mean bigger windows of time for dedupe, but greater memory usage.
	// +kubebuilder:default="1M"
	MaxSize resource.Quantity `json:"maxSize,omitempty" protobuf:"bytes,2,opt,name=maxSize"`
}

func (*Dedupe) DeepCopy added in v0.0.57 

func (in *Dedupe) DeepCopy() *Dedupe

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

func (*Dedupe) DeepCopyInto added in v0.0.57 

func (in *Dedupe) DeepCopyInto(out *Dedupe)

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

func (*Dedupe) Descriptor added in v0.0.57 

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

func (*Dedupe) Marshal added in v0.0.57 

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

func (*Dedupe) MarshalTo added in v0.0.57 

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

func (*Dedupe) MarshalToSizedBuffer added in v0.0.57 

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

func (*Dedupe) ProtoMessage added in v0.0.57 

func (*Dedupe) ProtoMessage()

func (*Dedupe) Reset added in v0.0.57 

func (m *Dedupe) Reset()

func (*Dedupe) Size added in v0.0.57 

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

func (*Dedupe) String added in v0.0.57 

func (this *Dedupe) String() string

func (*Dedupe) Unmarshal added in v0.0.57 

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

func (*Dedupe) XXX_DiscardUnknown added in v0.0.57 

func (m *Dedupe) XXX_DiscardUnknown()

func (*Dedupe) XXX_Marshal added in v0.0.57 

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

func (*Dedupe) XXX_Merge added in v0.0.57 

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

func (*Dedupe) XXX_Size added in v0.0.57 

func (m *Dedupe) XXX_Size() int

func (*Dedupe) XXX_Unmarshal added in v0.0.57 

func (m *Dedupe) 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"`
	BearerToken    string            `protobuf:"bytes,9,opt,name=bearerToken"`
}

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"`
	SSHPrivateKey *corev1.SecretKeySelector `json:"sshPrivateKey,omitempty" protobuf:"bytes,7,opt,name=sshPrivateKey"`
	// +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 HTTPHeader added in v0.0.60 

type HTTPHeader struct {
	Name      string            `json:"name" protobuf:"bytes,1,opt,name=name"`
	Value     string            `json:"value,omitempty" protobuf:"bytes,2,opt,name=value"`
	ValueFrom *HTTPHeaderSource `json:"valueFrom,omitempty" protobuf:"bytes,3,opt,name=valueFrom"`
}

func (*HTTPHeader) DeepCopy added in v0.0.60 

func (in *HTTPHeader) DeepCopy() *HTTPHeader

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

func (*HTTPHeader) DeepCopyInto added in v0.0.60 

func (in *HTTPHeader) DeepCopyInto(out *HTTPHeader)

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

func (*HTTPHeader) Descriptor added in v0.0.60 

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

func (*HTTPHeader) Marshal added in v0.0.60 

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

func (*HTTPHeader) MarshalTo added in v0.0.60 

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

func (*HTTPHeader) MarshalToSizedBuffer added in v0.0.60 

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

func (*HTTPHeader) ProtoMessage added in v0.0.60 

func (*HTTPHeader) ProtoMessage()

func (*HTTPHeader) Reset added in v0.0.60 

func (m *HTTPHeader) Reset()

func (*HTTPHeader) Size added in v0.0.60 

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

func (*HTTPHeader) String added in v0.0.60 

func (this *HTTPHeader) String() string

func (*HTTPHeader) Unmarshal added in v0.0.60 

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

func (*HTTPHeader) XXX_DiscardUnknown added in v0.0.60 

func (m *HTTPHeader) XXX_DiscardUnknown()

func (*HTTPHeader) XXX_Marshal added in v0.0.60 

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

func (*HTTPHeader) XXX_Merge added in v0.0.60 

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

func (*HTTPHeader) XXX_Size added in v0.0.60 

func (m *HTTPHeader) XXX_Size() int

func (*HTTPHeader) XXX_Unmarshal added in v0.0.60 

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

type HTTPHeaderSource added in v0.0.60 

type HTTPHeaderSource struct {
	SecretKeyRef corev1.SecretKeySelector `json:"secretKeyRef" protobuf:"bytes,1,opt,name=secretKeyRef"`
}

func (*HTTPHeaderSource) DeepCopy added in v0.0.60 

func (in *HTTPHeaderSource) DeepCopy() *HTTPHeaderSource

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

func (*HTTPHeaderSource) DeepCopyInto added in v0.0.60 

func (in *HTTPHeaderSource) DeepCopyInto(out *HTTPHeaderSource)

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

func (*HTTPHeaderSource) Descriptor added in v0.0.60 

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

func (*HTTPHeaderSource) Marshal added in v0.0.60 

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

func (*HTTPHeaderSource) MarshalTo added in v0.0.60 

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

func (*HTTPHeaderSource) MarshalToSizedBuffer added in v0.0.60 

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

func (*HTTPHeaderSource) ProtoMessage added in v0.0.60 

func (*HTTPHeaderSource) ProtoMessage()

func (*HTTPHeaderSource) Reset added in v0.0.60 

func (m *HTTPHeaderSource) Reset()

func (*HTTPHeaderSource) Size added in v0.0.60 

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

func (*HTTPHeaderSource) String added in v0.0.60 

func (this *HTTPHeaderSource) String() string

func (*HTTPHeaderSource) Unmarshal added in v0.0.60 

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

func (*HTTPHeaderSource) XXX_DiscardUnknown added in v0.0.60 

func (m *HTTPHeaderSource) XXX_DiscardUnknown()

func (*HTTPHeaderSource) XXX_Marshal added in v0.0.60 

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

func (*HTTPHeaderSource) XXX_Merge added in v0.0.60 

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

func (*HTTPHeaderSource) XXX_Size added in v0.0.60 

func (m *HTTPHeaderSource) XXX_Size() int

func (*HTTPHeaderSource) XXX_Unmarshal added in v0.0.60 

func (m *HTTPHeaderSource) 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"`
	Headers []HTTPHeader `json:"headers,omitempty" protobuf:"bytes,2,rep,name=headers"`
}

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 {
	ServiceName string `json:"serviceName,omitempty" protobuf:"bytes,1,opt,name=serviceName"` // the service name to create, defaults to `${pipelineName}-${stepName}`.
}

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 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"`
}

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"`
	SASL *SASL `json:"sasl,omitempty" protobuf:"bytes,2,opt,name=sasl"`
}

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 KafkaOffset added in v0.0.68 

type KafkaOffset string

+kubebuilder:validation:Enum=First;Last

type KafkaSource added in v0.0.68 

type KafkaSource struct {
	Kafka `json:",inline" protobuf:"bytes,1,opt,name=kafka"`
	// +kubebuilder:default=Last
	StartOffset KafkaOffset `json:"startOffset,omitempty" protobuf:"bytes,2,opt,name=startOffset,casttype=KafkaOffset"`
}

func (*KafkaSource) DeepCopy added in v0.0.68 

func (in *KafkaSource) DeepCopy() *KafkaSource

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

func (*KafkaSource) DeepCopyInto added in v0.0.68 

func (in *KafkaSource) DeepCopyInto(out *KafkaSource)

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

func (*KafkaSource) Descriptor added in v0.0.68 

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

func (*KafkaSource) Marshal added in v0.0.68 

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

func (*KafkaSource) MarshalTo added in v0.0.68 

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

func (*KafkaSource) MarshalToSizedBuffer added in v0.0.68 

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

func (*KafkaSource) ProtoMessage added in v0.0.68 

func (*KafkaSource) ProtoMessage()

func (*KafkaSource) Reset added in v0.0.68 

func (m *KafkaSource) Reset()

func (*KafkaSource) Size added in v0.0.68 

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

func (*KafkaSource) String added in v0.0.68 

func (this *KafkaSource) String() string

func (*KafkaSource) Unmarshal added in v0.0.68 

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

func (*KafkaSource) XXX_DiscardUnknown added in v0.0.68 

func (m *KafkaSource) XXX_DiscardUnknown()

func (*KafkaSource) XXX_Marshal added in v0.0.68 

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

func (*KafkaSource) XXX_Merge added in v0.0.68 

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

func (*KafkaSource) XXX_Size added in v0.0.68 

func (m *KafkaSource) XXX_Size() int

func (*KafkaSource) XXX_Unmarshal added in v0.0.68 

func (m *KafkaSource) 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 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,2,opt,name=errors"`
	Rate    resource.Quantity `json:"rate,omitempty" protobuf:"bytes,3,opt,name=rate"` // current rate of messages per second
	Retries uint64            `json:"retries,omitempty" protobuf:"bytes,4,opt,name=retries"`
}

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"`
	LastUpdated metav1.Time        `json:"lastUpdated,omitempty" protobuf:"bytes,4,opt,name=lastUpdated"`
}

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=golang1-16;java16;python3-9

type S3 added in v0.0.75 

type S3 struct {
	// +kubebuilder:default=default
	Name        string          `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	Bucket      string          `json:"bucket" protobuf:"bytes,2,opt,name=bucket"`
	Region      string          `json:"region,omitempty" protobuf:"bytes,3,opt,name=region"`
	Credentials *AWSCredentials `json:"credentials,omitempty" protobuf:"bytes,4,opt,name=credentials"`
	Endpoint    *AWSEndpoint    `json:"endpoint,omitempty" protobuf:"bytes,5,opt,name=endpoint"`
}

func (*S3) DeepCopy added in v0.0.75 

func (in *S3) DeepCopy() *S3

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

func (*S3) DeepCopyInto added in v0.0.75 

func (in *S3) DeepCopyInto(out *S3)

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

func (*S3) Descriptor added in v0.0.75 

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

func (*S3) Marshal added in v0.0.75 

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

func (*S3) MarshalTo added in v0.0.75 

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

func (*S3) MarshalToSizedBuffer added in v0.0.75 

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

func (*S3) ProtoMessage added in v0.0.75 

func (*S3) ProtoMessage()

func (*S3) Reset added in v0.0.75 

func (m *S3) Reset()

func (*S3) Size added in v0.0.75 

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

func (*S3) String added in v0.0.75 

func (this *S3) String() string

func (*S3) Unmarshal added in v0.0.75 

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

func (*S3) XXX_DiscardUnknown added in v0.0.75 

func (m *S3) XXX_DiscardUnknown()

func (*S3) XXX_Marshal added in v0.0.75 

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

func (*S3) XXX_Merge added in v0.0.75 

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

func (*S3) XXX_Size added in v0.0.75 

func (m *S3) XXX_Size() int

func (*S3) XXX_Unmarshal added in v0.0.75 

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

type S3Sink added in v0.0.75 

type S3Sink struct {
	S3 `json:",inline" protobuf:"bytes,4,opt,name=s3"`
	// an expression over the message, e.g. `"subpath/"+string(msg)`
	Key string `json:"key" protobuf:"bytes,3,opt,name=bucket"`
}

func (*S3Sink) DeepCopy added in v0.0.75 

func (in *S3Sink) DeepCopy() *S3Sink

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

func (*S3Sink) DeepCopyInto added in v0.0.75 

func (in *S3Sink) DeepCopyInto(out *S3Sink)

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

func (*S3Sink) Descriptor added in v0.0.75 

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

func (*S3Sink) Marshal added in v0.0.75 

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

func (*S3Sink) MarshalTo added in v0.0.75 

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

func (*S3Sink) MarshalToSizedBuffer added in v0.0.75 

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

func (*S3Sink) ProtoMessage added in v0.0.75 

func (*S3Sink) ProtoMessage()

func (*S3Sink) Reset added in v0.0.75 

func (m *S3Sink) Reset()

func (*S3Sink) Size added in v0.0.75 

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

func (*S3Sink) String added in v0.0.75 

func (this *S3Sink) String() string

func (*S3Sink) Unmarshal added in v0.0.75 

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

func (*S3Sink) XXX_DiscardUnknown added in v0.0.75 

func (m *S3Sink) XXX_DiscardUnknown()

func (*S3Sink) XXX_Marshal added in v0.0.75 

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

func (*S3Sink) XXX_Merge added in v0.0.75 

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

func (*S3Sink) XXX_Size added in v0.0.75 

func (m *S3Sink) XXX_Size() int

func (*S3Sink) XXX_Unmarshal added in v0.0.75 

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

type S3Source added in v0.0.74 

type S3Source struct {
	S3 `json:",inline" protobuf:"bytes,7,opt,name=s3"`
	// +kubebuilder:default="1m"
	PollPeriod metav1.Duration `json:"pollPeriod,omitempty" protobuf:"bytes,6,opt,name=pollPeriod"`
}

func (*S3Source) DeepCopy added in v0.0.74 

func (in *S3Source) DeepCopy() *S3Source

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

func (*S3Source) DeepCopyInto added in v0.0.74 

func (in *S3Source) DeepCopyInto(out *S3Source)

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

func (*S3Source) Descriptor added in v0.0.74 

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

func (*S3Source) Marshal added in v0.0.74 

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

func (*S3Source) MarshalTo added in v0.0.74 

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

func (*S3Source) MarshalToSizedBuffer added in v0.0.74 

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

func (*S3Source) ProtoMessage added in v0.0.74 

func (*S3Source) ProtoMessage()

func (*S3Source) Reset added in v0.0.74 

func (m *S3Source) Reset()

func (*S3Source) Size added in v0.0.74 

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

func (*S3Source) String added in v0.0.74 

func (this *S3Source) String() string

func (*S3Source) Unmarshal added in v0.0.74 

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

func (*S3Source) XXX_DiscardUnknown added in v0.0.74 

func (m *S3Source) XXX_DiscardUnknown()

func (*S3Source) XXX_Marshal added in v0.0.74 

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

func (*S3Source) XXX_Merge added in v0.0.74 

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

func (*S3Source) XXX_Size added in v0.0.74 

func (m *S3Source) XXX_Size() int

func (*S3Source) XXX_Unmarshal added in v0.0.74 

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

type SASL added in v0.0.73 

type SASL struct {
	// SASLMechanism is the name of the enabled SASL mechanism.
	// Possible values: OAUTHBEARER, PLAIN (defaults to PLAIN).
	// +optional
	Mechanism SASLMechanism `json:"mechanism,omitempty" protobuf:"bytes,1,opt,name=mechanism"`
	// User is the authentication identity (authcid) to present for
	// SASL/PLAIN or SASL/SCRAM authentication
	UserSecret *corev1.SecretKeySelector `json:"userSecret,omitempty" protobuf:"bytes,2,opt,name=user"`
	// Password for SASL/PLAIN authentication
	PasswordSecret *corev1.SecretKeySelector `json:"passwordSecret,omitempty" protobuf:"bytes,3,opt,name=password"`
}

func (*SASL) DeepCopy added in v0.0.73 

func (in *SASL) DeepCopy() *SASL

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

func (*SASL) DeepCopyInto added in v0.0.73 

func (in *SASL) DeepCopyInto(out *SASL)

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

func (*SASL) Descriptor added in v0.0.73 

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

func (SASL) GetMechanism added in v0.0.73 

func (s SASL) GetMechanism() SASLMechanism

func (*SASL) Marshal added in v0.0.73 

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

func (*SASL) MarshalTo added in v0.0.73 

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

func (*SASL) MarshalToSizedBuffer added in v0.0.73 

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

func (*SASL) ProtoMessage added in v0.0.73 

func (*SASL) ProtoMessage()

func (*SASL) Reset added in v0.0.73 

func (m *SASL) Reset()

func (*SASL) Size added in v0.0.73 

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

func (*SASL) String added in v0.0.73 

func (this *SASL) String() string

func (*SASL) Unmarshal added in v0.0.73 

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

func (*SASL) XXX_DiscardUnknown added in v0.0.73 

func (m *SASL) XXX_DiscardUnknown()

func (*SASL) XXX_Marshal added in v0.0.73 

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

func (*SASL) XXX_Merge added in v0.0.73 

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

func (*SASL) XXX_Size added in v0.0.73 

func (m *SASL) XXX_Size() int

func (*SASL) XXX_Unmarshal added in v0.0.73 

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

type SASLMechanism added in v0.0.73 

type SASLMechanism string
var (
	OAUTHBEARER SASLMechanism = "SASLMechanism"
	SCRAMSHA256 SASLMechanism = "SCRAM-SHA-256"
	SCRAMSHA512 SASLMechanism = "SCRAM-SHA-512"
	GSSAPI      SASLMechanism = "GSSAPI"
	PLAIN       SASLMechanism = "PLAIN"
)

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"`
	NATSMonitoringURL string        `json:"natsMonitoringUrl,omitempty" protobuf:"bytes,8,opt,name=natsMonitoringUrl"`
	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"`
	Auth              *STANAuth     `json:"auth,omitempty" protobuf:"bytes,7,opt,name=auth"`
	// Max inflight messages when subscribing to the stan server, which means how many messages
	// between commits, therefore potential duplicates during disruption
	// +kubebuilder:default=20
	MaxInflight uint32 `json:"maxInflight,omitempty" protobuf:"bytes,9,opt,name=maxInflight"`
}

func (*STAN) AuthStrategy added in v0.0.60 

func (s *STAN) AuthStrategy() STANAuthStrategy

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) GetMaxInflight added in v0.0.68 

func (s *STAN) GetMaxInflight() 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 STANAuth added in v0.0.60 

type STANAuth struct {
	Token *corev1.SecretKeySelector `json:"token,omitempty" protobuf:"bytes,1,opt,name=token"`
}

func (*STANAuth) DeepCopy added in v0.0.60 

func (in *STANAuth) DeepCopy() *STANAuth

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

func (*STANAuth) DeepCopyInto added in v0.0.60 

func (in *STANAuth) DeepCopyInto(out *STANAuth)

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

func (*STANAuth) Descriptor added in v0.0.60 

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

func (*STANAuth) Marshal added in v0.0.60 

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

func (*STANAuth) MarshalTo added in v0.0.60 

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

func (*STANAuth) MarshalToSizedBuffer added in v0.0.60 

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

func (*STANAuth) ProtoMessage added in v0.0.60 

func (*STANAuth) ProtoMessage()

func (*STANAuth) Reset added in v0.0.60 

func (m *STANAuth) Reset()

func (*STANAuth) Size added in v0.0.60 

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

func (*STANAuth) String added in v0.0.60 

func (this *STANAuth) String() string

func (*STANAuth) Unmarshal added in v0.0.60 

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

func (*STANAuth) XXX_DiscardUnknown added in v0.0.60 

func (m *STANAuth) XXX_DiscardUnknown()

func (*STANAuth) XXX_Marshal added in v0.0.60 

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

func (*STANAuth) XXX_Merge added in v0.0.60 

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

func (*STANAuth) XXX_Size added in v0.0.60 

func (m *STANAuth) XXX_Size() int

func (*STANAuth) XXX_Unmarshal added in v0.0.60 

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

type STANAuthStrategy added in v0.0.60 

type STANAuthStrategy string
var (
	STANAuthNone  STANAuthStrategy = "None"
	STANAuthToken STANAuthStrategy = "Token"
)

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"`
	S3    *S3Sink   `json:"s3,omitempty" protobuf:"bytes,6,opt,name=s3"`
}

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 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 *KafkaSource `json:"kafka,omitempty" protobuf:"bytes,4,opt,name=kafka"`
	HTTP  *HTTPSource  `json:"http,omitempty" protobuf:"bytes,5,opt,name=http"`
	S3    *S3Source    `json:"s3,omitempty" protobuf:"bytes,8,opt,name=s3"`
	// +kubebuilder:default={steps: 2, jitterPercentage: 10}
	Retry Backoff `json:"retry,omitempty" protobuf:"bytes,7,opt,name=retry"`
}

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 {
	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) AnySunk added in v0.0.35 

func (in SourceStatus) AnySunk() 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) GetErrors added in v0.0.32 

func (in SourceStatus) GetErrors() uint64

func (SourceStatus) GetPending added in v0.0.32 

func (in SourceStatus) GetPending() uint64

GetPending returns pending counts

func (SourceStatus) GetRetries added in v0.0.65 

func (in SourceStatus) GetRetries() uint64

GetRetries returns total Retries metrics

func (SourceStatus) GetTotal added in v0.0.32 

func (in SourceStatus) GetTotal() uint64

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 source name

func (SourceStatuses) AnySunk added in v0.0.32 

func (in SourceStatuses) AnySunk() 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) Get added in v0.0.35 

func (in SourceStatuses) Get(name string) SourceStatus

func (SourceStatuses) GetErrors added in v0.0.72 

func (in SourceStatuses) GetErrors() uint64

func (SourceStatuses) GetPending 

func (in SourceStatuses) GetPending() uint64

func (SourceStatuses) GetTotal added in v0.0.32 

func (in SourceStatuses) GetTotal() uint64

func (SourceStatuses) IncrErrors added in v0.0.43 

func (in SourceStatuses) IncrErrors(name string, replica int)

func (SourceStatuses) IncrRetries added in v0.0.65 

func (in SourceStatuses) IncrRetries(name string, replica int)

IncrRetries increase the retry_count metrics by 1

func (SourceStatuses) IncrTotal added in v0.0.43 

func (in SourceStatuses) IncrTotal(name string, replica int, rate resource.Quantity)

func (SourceStatuses) SetPending 

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

type Sources added in v0.0.10 

type Sources []Source

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) GetPodSpec added in v0.0.41 

func (in Step) GetPodSpec(req GetPodSpecReq) corev1.PodSpec

func (Step) GetTargetReplicas 

func (in Step) GetTargetReplicas(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"`
	Dedupe    *Dedupe    `json:"dedupe,omitempty" protobuf:"bytes,27,opt,name=dedupe"`
	Expand    *Expand    `json:"expand,omitempty" protobuf:"bytes,26,opt,name=expand"`
	Filter    Filter     `json:"filter,omitempty" protobuf:"bytes,8,opt,name=filter,casttype=Filter"`
	Flatten   *Flatten   `json:"flatten,omitempty" protobuf:"bytes,25,opt,name=flatten"`
	Git       *Git       `json:"git,omitempty" protobuf:"bytes,12,opt,name=git"`
	Group     *Group     `json:"group,omitempty" protobuf:"bytes,11,opt,name=group"`
	Code      *Code      `json:"code,omitempty" protobuf:"bytes,7,opt,name=code"`
	Map       Map        `json:"map,omitempty" protobuf:"bytes,9,opt,name=map,casttype=Map"`

	// +kubebuilder:default=1
	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) GetIn 

func (in StepSpec) GetIn() *Interface

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,omitempty" protobuf:"bytes,8,opt,name=reason"`
	Message        string         `json:"message,omitempty" 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,omitempty" protobuf:"bytes,3,rep,name=sourceStatuses"`
	SinkStatues    SourceStatuses `json:"sinkStatuses,omitempty" protobuf:"bytes,4,rep,name=sinkStatuses"`
}

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 {
	// CACertSecret refers to the secret that contains the CA cert
	CACertSecret *corev1.SecretKeySelector `json:"caCertSecret,omitempty" protobuf:"bytes,1,opt,name=caCertSecret"`
	// CertSecret refers to the secret that contains the cert
	CertSecret *corev1.SecretKeySelector `json:"clientCertSecret,omitempty" protobuf:"bytes,2,opt,name=certSecret"`
	// KeySecret refers to the secret that contains the key
	KeySecret *corev1.SecretKeySelector `json:"clientKeySecret,omitempty" protobuf:"bytes,3,opt,name=keySecret"`
}

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

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.