v1alpha1

package
v0.6.0 Latest Latest
Warning

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

Go to latest
Published: Nov 17, 2021 License: Apache-2.0 Imports: 23 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
	ConditionTerminating = "Terminating" // added if any terminator step terminated
	// container names.
	CtrInit    = "init"
	CtrMain    = "main"
	CtrSidecar = "sidecar"
	// env vars.
	EnvCluster          = "ARGO_DATAFLOW_CLUSTER"
	EnvDebug            = "ARGO_DATAFLOW_DEBUG"              // enable debug flags, maybe "true" or CSV, e.g. "pprof,kafka.generic"
	EnvUnixDomainSocket = "ARGO_DATAFLOW_UNIX_DOMAIN_SOCKET" // use Unix Domain Socket, default "true"
	EnvImagePrefix      = "ARGO_DATAFLOW_IMAGE_PREFIX"       // default "quay.io/argoproj"
	EnvNamespace        = "ARGO_DATAFLOW_NAMESPACE"
	EnvPipelineName     = "ARGO_DATAFLOW_PIPELINE_NAME"
	EnvPod              = "ARGO_DATAFLOW_POD"
	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 "15s"
	EnvImagePullSecrets = "ARGO_DATAFLOW_IMAGE_PULL_SECRETS" // allows providing a list of imagePullSecrets as a comma delimited string (eg. "secret1,secret2")
	// 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.
	PathAuthorization = "/var/run/argo-dataflow/authorization" // the authorization header which must be used by the main container to speak to the sidecar
	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 (
	// MetaID is a unique ID for the message.
	// Required.
	// https://github.com/cloudevents/spec/blob/master/spec.md#id
	MetaID = "dataflow-id"
	// MetaSource is the source of the messages as a Unique Resource Identifier (URI).
	// Required.
	// https://github.com/cloudevents/spec/blob/master/spec.md#source-1
	MetaSource = "dataflow-source"
	// MetaTime is the time of the message. As meta-data, this might be different to the event-time (which might be within the message).
	// For example, it might be the last-modified time of a file, but the file itself was created at another time.
	// Optional.
	// https://github.com/cloudevents/spec/blob/master/spec.md#time
	MetaTime = "dataflow-time"
)
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 ContextWithMeta added in v0.0.102

func ContextWithMeta(ctx context.Context, m Meta) context.Context

func MetaExtract added in v0.0.102

func MetaExtract(ctx context.Context, h http.Header) context.Context

func MetaInject added in v0.0.102

func MetaInject(ctx context.Context, h http.Header) error

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"`
	SessionToken    corev1.SecretKeySelector `json:"sessionToken" protobuf:"bytes,3,opt,name=sessionToken"`
}

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 AbstractStep added in v0.0.99

type AbstractStep struct {
	// +kubebuilder:default={limits: {"cpu": "500m", "memory": "256Mi"}, requests: {"cpu": "100m", "memory": "64Mi"}}
	Resources corev1.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,1,opt,name=resources"`
}

func (*AbstractStep) DeepCopy added in v0.0.99

func (in *AbstractStep) DeepCopy() *AbstractStep

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

func (*AbstractStep) DeepCopyInto added in v0.0.99

func (in *AbstractStep) DeepCopyInto(out *AbstractStep)

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

func (*AbstractStep) Descriptor added in v0.0.99

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

func (*AbstractStep) Marshal added in v0.0.99

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

func (*AbstractStep) MarshalTo added in v0.0.99

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

func (*AbstractStep) MarshalToSizedBuffer added in v0.0.99

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

func (*AbstractStep) ProtoMessage added in v0.0.99

func (*AbstractStep) ProtoMessage()

func (*AbstractStep) Reset added in v0.0.99

func (m *AbstractStep) Reset()

func (*AbstractStep) Size added in v0.0.99

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

func (*AbstractStep) String added in v0.0.99

func (this *AbstractStep) String() string

func (*AbstractStep) Unmarshal added in v0.0.99

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

func (*AbstractStep) XXX_DiscardUnknown added in v0.0.99

func (m *AbstractStep) XXX_DiscardUnknown()

func (*AbstractStep) XXX_Marshal added in v0.0.99

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

func (*AbstractStep) XXX_Merge added in v0.0.99

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

func (*AbstractStep) XXX_Size added in v0.0.99

func (m *AbstractStep) XXX_Size() int

func (*AbstractStep) XXX_Unmarshal added in v0.0.99

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

type AbstractVolumeSource added in v0.0.102

type AbstractVolumeSource corev1.VolumeSource

func (*AbstractVolumeSource) DeepCopy added in v0.0.102

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

func (*AbstractVolumeSource) DeepCopyInto added in v0.0.102

func (in *AbstractVolumeSource) DeepCopyInto(out *AbstractVolumeSource)

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

func (*AbstractVolumeSource) Descriptor added in v0.0.102

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

func (AbstractVolumeSource) GenURN added in v0.0.102

func (in AbstractVolumeSource) GenURN(cluster, namespace string) string

func (*AbstractVolumeSource) Marshal added in v0.0.102

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

func (*AbstractVolumeSource) MarshalTo added in v0.0.102

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

func (*AbstractVolumeSource) MarshalToSizedBuffer added in v0.0.102

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

func (*AbstractVolumeSource) ProtoMessage added in v0.0.102

func (*AbstractVolumeSource) ProtoMessage()

func (*AbstractVolumeSource) Reset added in v0.0.102

func (m *AbstractVolumeSource) Reset()

func (*AbstractVolumeSource) Size added in v0.0.102

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

func (*AbstractVolumeSource) String added in v0.0.102

func (this *AbstractVolumeSource) String() string

func (*AbstractVolumeSource) Unmarshal added in v0.0.102

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

func (*AbstractVolumeSource) XXX_DiscardUnknown added in v0.0.102

func (m *AbstractVolumeSource) XXX_DiscardUnknown()

func (*AbstractVolumeSource) XXX_Marshal added in v0.0.102

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

func (*AbstractVolumeSource) XXX_Merge added in v0.0.102

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

func (*AbstractVolumeSource) XXX_Size added in v0.0.102

func (m *AbstractVolumeSource) XXX_Size() int

func (*AbstractVolumeSource) XXX_Unmarshal added in v0.0.102

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

type Backoff added in v0.0.60

type Backoff struct {
	// +kubebuilder:default="100ms"
	Duration *metav1.Duration `json:"duration,omitempty" protobuf:"bytes,4,opt,name=duration"`
	// +kubebuilder:default=200
	FactorPercentage uint32 `json:"factorPercentage,omitempty" protobuf:"varint,5,opt,name=FactorPercentage"`
	// the number of backoff steps, zero means no retries
	// +kubebuilder:default=20
	Steps uint64 `json:"steps,omitempty" protobuf:"varint,1,opt,name=steps"`
	// +kubebuilder:default="0ms"
	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
	// +kubebuilder:default=10
	JitterPercentage uint32 `json:"jitterPercentage,omitempty" protobuf:"varint,3,opt,name=jitterPercentage"`
}

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 {
	AbstractStep `json:",inline" protobuf:"bytes,1,opt,name=abstractStep"`
}

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,omitempty" protobuf:"bytes,4,opt,name=runtime,casttype=Runtime"`
	// Image is used in preference to Runtime.
	Image  string `json:"image,omitempty" protobuf:"bytes,5,opt,name=image"`
	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) GenURN added in v0.0.102

func (in Cron) GenURN(cluster, namespace string) string

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 DBDataSource added in v0.0.89

type DBDataSource struct {
	Value     string            `json:"value,omitempty" protobuf:"bytes,1,opt,name=value"`
	ValueFrom *DBDataSourceFrom `json:"valueFrom,omitempty" protobuf:"bytes,2,opt,name=valueFrom"`
}

func (*DBDataSource) DeepCopy added in v0.0.89

func (in *DBDataSource) DeepCopy() *DBDataSource

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

func (*DBDataSource) DeepCopyInto added in v0.0.89

func (in *DBDataSource) DeepCopyInto(out *DBDataSource)

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

func (*DBDataSource) Descriptor added in v0.0.89

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

func (*DBDataSource) Marshal added in v0.0.89

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

func (*DBDataSource) MarshalTo added in v0.0.89

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

func (*DBDataSource) MarshalToSizedBuffer added in v0.0.89

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

func (*DBDataSource) ProtoMessage added in v0.0.89

func (*DBDataSource) ProtoMessage()

func (*DBDataSource) Reset added in v0.0.89

func (m *DBDataSource) Reset()

func (*DBDataSource) Size added in v0.0.89

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

func (*DBDataSource) String added in v0.0.89

func (this *DBDataSource) String() string

func (*DBDataSource) Unmarshal added in v0.0.89

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

func (*DBDataSource) XXX_DiscardUnknown added in v0.0.89

func (m *DBDataSource) XXX_DiscardUnknown()

func (*DBDataSource) XXX_Marshal added in v0.0.89

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

func (*DBDataSource) XXX_Merge added in v0.0.89

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

func (*DBDataSource) XXX_Size added in v0.0.89

func (m *DBDataSource) XXX_Size() int

func (*DBDataSource) XXX_Unmarshal added in v0.0.89

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

type DBDataSourceFrom added in v0.0.89

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

func (*DBDataSourceFrom) DeepCopy added in v0.0.89

func (in *DBDataSourceFrom) DeepCopy() *DBDataSourceFrom

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

func (*DBDataSourceFrom) DeepCopyInto added in v0.0.89

func (in *DBDataSourceFrom) DeepCopyInto(out *DBDataSourceFrom)

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

func (*DBDataSourceFrom) Descriptor added in v0.0.89

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

func (*DBDataSourceFrom) Marshal added in v0.0.89

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

func (*DBDataSourceFrom) MarshalTo added in v0.0.89

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

func (*DBDataSourceFrom) MarshalToSizedBuffer added in v0.0.89

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

func (*DBDataSourceFrom) ProtoMessage added in v0.0.89

func (*DBDataSourceFrom) ProtoMessage()

func (*DBDataSourceFrom) Reset added in v0.0.89

func (m *DBDataSourceFrom) Reset()

func (*DBDataSourceFrom) Size added in v0.0.89

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

func (*DBDataSourceFrom) String added in v0.0.89

func (this *DBDataSourceFrom) String() string

func (*DBDataSourceFrom) Unmarshal added in v0.0.89

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

func (*DBDataSourceFrom) XXX_DiscardUnknown added in v0.0.89

func (m *DBDataSourceFrom) XXX_DiscardUnknown()

func (*DBDataSourceFrom) XXX_Marshal added in v0.0.89

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

func (*DBDataSourceFrom) XXX_Merge added in v0.0.89

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

func (*DBDataSourceFrom) XXX_Size added in v0.0.89

func (m *DBDataSourceFrom) XXX_Size() int

func (*DBDataSourceFrom) XXX_Unmarshal added in v0.0.89

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

type DBSink added in v0.0.89

type DBSink struct {
	Database `json:",inline" protobuf:"bytes,1,opt,name=database"`
	Actions  []SQLAction `json:"actions,omitempty" protobuf:"bytes,2,rep,name=actions"`
}

func (*DBSink) DeepCopy added in v0.0.89

func (in *DBSink) DeepCopy() *DBSink

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

func (*DBSink) DeepCopyInto added in v0.0.89

func (in *DBSink) DeepCopyInto(out *DBSink)

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

func (*DBSink) Descriptor added in v0.0.89

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

func (*DBSink) Marshal added in v0.0.89

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

func (*DBSink) MarshalTo added in v0.0.89

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

func (*DBSink) MarshalToSizedBuffer added in v0.0.89

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

func (*DBSink) ProtoMessage added in v0.0.89

func (*DBSink) ProtoMessage()

func (*DBSink) Reset added in v0.0.89

func (m *DBSink) Reset()

func (*DBSink) Size added in v0.0.89

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

func (*DBSink) String added in v0.0.89

func (this *DBSink) String() string

func (*DBSink) Unmarshal added in v0.0.89

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

func (*DBSink) XXX_DiscardUnknown added in v0.0.89

func (m *DBSink) XXX_DiscardUnknown()

func (*DBSink) XXX_Marshal added in v0.0.89

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

func (*DBSink) XXX_Merge added in v0.0.89

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

func (*DBSink) XXX_Size added in v0.0.89

func (m *DBSink) XXX_Size() int

func (*DBSink) XXX_Unmarshal added in v0.0.89

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

type DBSource added in v0.0.89

type DBSource struct {
	Database     `json:",inline" protobuf:"bytes,1,opt,name=database"`
	Query        string `json:"query,omitempty" protobuf:"bytes,2,opt,name=query"`
	OffsetColumn string `json:"offsetColumn,omitempty" protobuf:"bytes,3,opt,name=offsetColumn"`
	// +kubebuilder:default="1s"
	PollInterval metav1.Duration `json:"pollInterval,omitempty" protobuf:"bytes,4,opt,name=pollInterval"`
	// +kubebuilder:default="5s"
	CommitInterval metav1.Duration `json:"commitInterval,omitempty" protobuf:"bytes,5,opt,name=commitInterval"`
	// +kubebuilder:default=true
	InitSchema bool `json:"initSchema,omitempty" protobuf:"bytes,6,opt,name=initSchema"`
}

func (*DBSource) DeepCopy added in v0.0.89

func (in *DBSource) DeepCopy() *DBSource

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

func (*DBSource) DeepCopyInto added in v0.0.89

func (in *DBSource) DeepCopyInto(out *DBSource)

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

func (*DBSource) Descriptor added in v0.0.89

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

func (*DBSource) Marshal added in v0.0.89

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

func (*DBSource) MarshalTo added in v0.0.89

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

func (*DBSource) MarshalToSizedBuffer added in v0.0.89

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

func (*DBSource) ProtoMessage added in v0.0.89

func (*DBSource) ProtoMessage()

func (*DBSource) Reset added in v0.0.89

func (m *DBSource) Reset()

func (*DBSource) Size added in v0.0.89

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

func (*DBSource) String added in v0.0.89

func (this *DBSource) String() string

func (*DBSource) Unmarshal added in v0.0.89

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

func (*DBSource) XXX_DiscardUnknown added in v0.0.89

func (m *DBSource) XXX_DiscardUnknown()

func (*DBSource) XXX_Marshal added in v0.0.89

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

func (*DBSource) XXX_Merge added in v0.0.89

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

func (*DBSource) XXX_Size added in v0.0.89

func (m *DBSource) XXX_Size() int

func (*DBSource) XXX_Unmarshal added in v0.0.89

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

type Database added in v0.0.89

type Database struct {
	// +kubebuilder:default=default
	Driver     string        `json:"driver,omitempty" protobuf:"bytes,1,opt,name=driver"`
	DataSource *DBDataSource `json:"dataSource,omitempty" protobuf:"bytes,2,opt,name=dataSource"`
}

func (*Database) DeepCopy added in v0.0.89

func (in *Database) DeepCopy() *Database

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

func (*Database) DeepCopyInto added in v0.0.89

func (in *Database) DeepCopyInto(out *Database)

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

func (*Database) Descriptor added in v0.0.89

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

func (Database) GenURN added in v0.0.102

func (in Database) GenURN(cluster, namespace string) string

func (*Database) Marshal added in v0.0.89

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

func (*Database) MarshalTo added in v0.0.89

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

func (*Database) MarshalToSizedBuffer added in v0.0.89

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

func (*Database) ProtoMessage added in v0.0.89

func (*Database) ProtoMessage()

func (*Database) Reset added in v0.0.89

func (m *Database) Reset()

func (*Database) Size added in v0.0.89

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

func (*Database) String added in v0.0.89

func (this *Database) String() string

func (*Database) Unmarshal added in v0.0.89

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

func (*Database) XXX_DiscardUnknown added in v0.0.89

func (m *Database) XXX_DiscardUnknown()

func (*Database) XXX_Marshal added in v0.0.89

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

func (*Database) XXX_Merge added in v0.0.89

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

func (*Database) XXX_Size added in v0.0.89

func (m *Database) XXX_Size() int

func (*Database) XXX_Unmarshal added in v0.0.89

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

type Dedupe added in v0.0.57

type Dedupe struct {
	AbstractStep `json:",inline" protobuf:"bytes,1,opt,name=abstractStep"`

	// +kubebuilder:default="sha1(msg)"
	UID string `json:"uid,omitempty" protobuf:"bytes,2,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,3,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 {
	AbstractStep `json:",inline" protobuf:"bytes,1,opt,name=abstractStep"`
}

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 struct {
	AbstractStep `json:",inline" protobuf:"bytes,1,opt,name=abstractStep"`
	Expression   string `json:"expression" protobuf:"bytes,2,opt,name=expression"`
}

func (*Filter) DeepCopy added in v0.0.97

func (in *Filter) DeepCopy() *Filter

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

func (*Filter) DeepCopyInto added in v0.0.97

func (in *Filter) DeepCopyInto(out *Filter)

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

func (*Filter) Descriptor added in v0.0.97

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

func (*Filter) Marshal added in v0.0.97

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

func (*Filter) MarshalTo added in v0.0.97

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

func (*Filter) MarshalToSizedBuffer added in v0.0.97

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

func (*Filter) ProtoMessage added in v0.0.97

func (*Filter) ProtoMessage()

func (*Filter) Reset added in v0.0.97

func (m *Filter) Reset()

func (*Filter) Size added in v0.0.97

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

func (*Filter) String added in v0.0.97

func (this *Filter) String() string

func (*Filter) Unmarshal added in v0.0.97

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

func (*Filter) XXX_DiscardUnknown added in v0.0.97

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal added in v0.0.97

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

func (*Filter) XXX_Merge added in v0.0.97

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

func (*Filter) XXX_Size added in v0.0.97

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal added in v0.0.97

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

type Flatten added in v0.0.9

type Flatten struct {
	AbstractStep `json:",inline" protobuf:"bytes,1,opt,name=abstractStep"`
}

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 {
	Cluster          string                        `protobuf:"bytes,1,opt,name=cluster"`
	PipelineName     string                        `protobuf:"bytes,3,opt,name=pipelineName"`
	Replica          int32                         `protobuf:"varint,4,opt,name=replica"`
	ImageFormat      string                        `protobuf:"bytes,5,opt,name=imageFormat"`
	RunnerImage      string                        `protobuf:"bytes,6,opt,name=runnerImage"`
	PullPolicy       corev1.PullPolicy             `protobuf:"bytes,7,opt,name=pullPolicy,casttype=k8s.io/api/core/v1.PullPolicy"`
	UpdateInterval   time.Duration                 `protobuf:"varint,8,opt,name=updateInterval,casttype=time.Duration"`
	StepStatus       StepStatus                    `protobuf:"bytes,9,opt,name=stepStatus"`
	Sidecar          Sidecar                       `protobuf:"bytes,10,opt,name=sidecar"`
	ImagePullSecrets []corev1.LocalObjectReference `protobuf:"bytes,11,rep,name=imagePullSecrets"`
	Hostname         string                        `protobuf:"bytes,12,opt,name=hostname"`
	Subdomain        string                        `protobuf:"bytes,13,opt,name=subdomain"`
}

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

	// UsernameSecret is the secret selector to the repository username
	UsernameSecret *corev1.SecretKeySelector `json:"usernameSecret,omitempty" protobuf:"bytes,7,opt,name=usernameSecret"`

	// PasswordSecret is the secret selector to the repository password
	PasswordSecret *corev1.SecretKeySelector `json:"passwordSecret,omitempty" protobuf:"bytes,8,opt,name=passwordSecret"`

	// SSHPrivateKeySecret is the secret selector to the repository ssh private key
	SSHPrivateKeySecret *corev1.SecretKeySelector `json:"sshPrivateKeySecret,omitempty" protobuf:"bytes,9,opt,name=sshPrivateKeySecret"`
	// +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"`
	InsecureSkipVerify bool         `json:"insecureSkipVerify,omitempty" protobuf:"varint,3,opt,name=insecureSkipVerify"`
}

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) GenURN added in v0.0.102

func (in HTTPSource) GenURN(cluster, namespace string) string

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 JetStream added in v0.0.125

type JetStream struct {
	// +kubebuilder:default=default
	Name    string    `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	NATSURL string    `json:"natsUrl,omitempty" protobuf:"bytes,2,opt,name=natsUrl"`
	Subject string    `json:"subject" protobuf:"bytes,3,opt,name=subject"`
	Auth    *NATSAuth `json:"auth,omitempty" protobuf:"bytes,4,opt,name=auth"`
}

func (*JetStream) DeepCopy added in v0.0.125

func (in *JetStream) DeepCopy() *JetStream

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

func (*JetStream) DeepCopyInto added in v0.0.125

func (in *JetStream) DeepCopyInto(out *JetStream)

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

func (*JetStream) Descriptor added in v0.0.125

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

func (*JetStream) Marshal added in v0.0.125

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

func (*JetStream) MarshalTo added in v0.0.125

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

func (*JetStream) MarshalToSizedBuffer added in v0.0.125

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

func (*JetStream) ProtoMessage added in v0.0.125

func (*JetStream) ProtoMessage()

func (*JetStream) Reset added in v0.0.125

func (m *JetStream) Reset()

func (*JetStream) Size added in v0.0.125

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

func (*JetStream) String added in v0.0.125

func (this *JetStream) String() string

func (*JetStream) Unmarshal added in v0.0.125

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

func (*JetStream) XXX_DiscardUnknown added in v0.0.125

func (m *JetStream) XXX_DiscardUnknown()

func (*JetStream) XXX_Marshal added in v0.0.125

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

func (*JetStream) XXX_Merge added in v0.0.125

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

func (*JetStream) XXX_Size added in v0.0.125

func (m *JetStream) XXX_Size() int

func (*JetStream) XXX_Unmarshal added in v0.0.125

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

type JetStreamSink added in v0.0.125

type JetStreamSink struct {
	JetStream `json:",inline" protobuf:"bytes,1,opt,name=jetstream"`
}

func (*JetStreamSink) DeepCopy added in v0.0.125

func (in *JetStreamSink) DeepCopy() *JetStreamSink

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

func (*JetStreamSink) DeepCopyInto added in v0.0.125

func (in *JetStreamSink) DeepCopyInto(out *JetStreamSink)

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

func (*JetStreamSink) Descriptor added in v0.0.125

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

func (*JetStreamSink) Marshal added in v0.0.125

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

func (*JetStreamSink) MarshalTo added in v0.0.125

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

func (*JetStreamSink) MarshalToSizedBuffer added in v0.0.125

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

func (*JetStreamSink) ProtoMessage added in v0.0.125

func (*JetStreamSink) ProtoMessage()

func (*JetStreamSink) Reset added in v0.0.125

func (m *JetStreamSink) Reset()

func (*JetStreamSink) Size added in v0.0.125

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

func (*JetStreamSink) String added in v0.0.125

func (this *JetStreamSink) String() string

func (*JetStreamSink) Unmarshal added in v0.0.125

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

func (*JetStreamSink) XXX_DiscardUnknown added in v0.0.125

func (m *JetStreamSink) XXX_DiscardUnknown()

func (*JetStreamSink) XXX_Marshal added in v0.0.125

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

func (*JetStreamSink) XXX_Merge added in v0.0.125

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

func (*JetStreamSink) XXX_Size added in v0.0.125

func (m *JetStreamSink) XXX_Size() int

func (*JetStreamSink) XXX_Unmarshal added in v0.0.125

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

type JetStreamSource added in v0.0.125

type JetStreamSource struct {
	JetStream `json:",inline" protobuf:"bytes,1,opt,name=jetstream"`
}

func (*JetStreamSource) DeepCopy added in v0.0.125

func (in *JetStreamSource) DeepCopy() *JetStreamSource

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

func (*JetStreamSource) DeepCopyInto added in v0.0.125

func (in *JetStreamSource) DeepCopyInto(out *JetStreamSource)

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

func (*JetStreamSource) Descriptor added in v0.0.125

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

func (JetStreamSource) GenURN added in v0.0.125

func (j JetStreamSource) GenURN(cluster, namespace string) string

func (*JetStreamSource) Marshal added in v0.0.125

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

func (*JetStreamSource) MarshalTo added in v0.0.125

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

func (*JetStreamSource) MarshalToSizedBuffer added in v0.0.125

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

func (*JetStreamSource) ProtoMessage added in v0.0.125

func (*JetStreamSource) ProtoMessage()

func (*JetStreamSource) Reset added in v0.0.125

func (m *JetStreamSource) Reset()

func (*JetStreamSource) Size added in v0.0.125

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

func (*JetStreamSource) String added in v0.0.125

func (this *JetStreamSource) String() string

func (*JetStreamSource) Unmarshal added in v0.0.125

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

func (*JetStreamSource) XXX_DiscardUnknown added in v0.0.125

func (m *JetStreamSource) XXX_DiscardUnknown()

func (*JetStreamSource) XXX_Marshal added in v0.0.125

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

func (*JetStreamSource) XXX_Merge added in v0.0.125

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

func (*JetStreamSource) XXX_Size added in v0.0.125

func (m *JetStreamSource) XXX_Size() int

func (*JetStreamSource) XXX_Unmarshal added in v0.0.125

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

type Kafka

type Kafka struct {
	// +kubebuilder:default=default
	Name        string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	KafkaConfig `json:",inline" protobuf:"bytes,4,opt,name=kafkaConfig"`
	Topic       string `json:"topic" protobuf:"bytes,3,opt,name=topic"`
}

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) GenURN added in v0.0.102

func (in Kafka) GenURN(cluster, namespace string) string

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 KafkaConfig added in v0.0.89

type KafkaConfig struct {
	Brokers         []string  `json:"brokers,omitempty" protobuf:"bytes,1,rep,name=brokers"`
	NET             *KafkaNET `json:"net,omitempty" protobuf:"bytes,3,opt,name=net"`
	MaxMessageBytes int32     `json:"maxMessageBytes,omitempty" protobuf:"varint,4,opt,name=maxMessageBytes"`
}

func (*KafkaConfig) DeepCopy added in v0.0.89

func (in *KafkaConfig) DeepCopy() *KafkaConfig

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

func (*KafkaConfig) DeepCopyInto added in v0.0.89

func (in *KafkaConfig) DeepCopyInto(out *KafkaConfig)

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

func (*KafkaConfig) Descriptor added in v0.0.89

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

func (*KafkaConfig) GetMessageMaxBytes added in v0.0.125

func (m *KafkaConfig) GetMessageMaxBytes() int

func (*KafkaConfig) Marshal added in v0.0.89

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

func (*KafkaConfig) MarshalTo added in v0.0.89

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

func (*KafkaConfig) MarshalToSizedBuffer added in v0.0.89

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

func (*KafkaConfig) ProtoMessage added in v0.0.89

func (*KafkaConfig) ProtoMessage()

func (*KafkaConfig) Reset added in v0.0.89

func (m *KafkaConfig) Reset()

func (*KafkaConfig) Size added in v0.0.89

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

func (*KafkaConfig) String added in v0.0.89

func (this *KafkaConfig) String() string

func (*KafkaConfig) Unmarshal added in v0.0.89

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

func (*KafkaConfig) XXX_DiscardUnknown added in v0.0.89

func (m *KafkaConfig) XXX_DiscardUnknown()

func (*KafkaConfig) XXX_Marshal added in v0.0.89

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

func (*KafkaConfig) XXX_Merge added in v0.0.89

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

func (*KafkaConfig) XXX_Size added in v0.0.89

func (m *KafkaConfig) XXX_Size() int

func (*KafkaConfig) XXX_Unmarshal added in v0.0.89

func (m *KafkaConfig) 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) GetSecurityProtocol added in v0.0.117

func (in *KafkaNET) GetSecurityProtocol() string

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

func (KafkaOffset) GetAutoOffsetReset added in v0.0.124

func (k KafkaOffset) GetAutoOffsetReset() string

type KafkaSink added in v0.0.89

type KafkaSink struct {
	Kafka `json:",inline" protobuf:"bytes,1,opt,name=kafka"`
	Async bool `json:"async,omitempty" protobuf:"varint,2,opt,name=async"`
	// +kubebuilder:default="100Ki"
	BatchSize *resource.Quantity `json:"batchSize,omitempty" protobuf:"bytes,3,opt,name=batchSize"`
	Linger    *metav1.Duration   `json:"linger,omitempty" protobuf:"bytes,4,opt,name=linger"`
	// +kubebuilder:default="lz4"
	CompressionType string `json:"compressionType,omitempty" protobuf:"bytes,5,opt,name=compressionType"`
	// +kubebuilder:default="all"
	Acks *intstr.IntOrString `json:"acks,omitempty" protobuf:"bytes,6,opt,name=acks"`
	// +kubebuilder:default=true
	EnableIdempotence bool `json:"enableIdempotence,omitempty" protobuf:"varint,7,opt,name=enableIdempotence"`
}

func (*KafkaSink) DeepCopy added in v0.0.89

func (in *KafkaSink) DeepCopy() *KafkaSink

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

func (*KafkaSink) DeepCopyInto added in v0.0.89

func (in *KafkaSink) DeepCopyInto(out *KafkaSink)

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

func (*KafkaSink) Descriptor added in v0.0.89

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

func (*KafkaSink) GetAcks added in v0.0.124

func (m *KafkaSink) GetAcks() interface{}

func (*KafkaSink) GetBatchSize added in v0.0.124

func (m *KafkaSink) GetBatchSize() int

func (*KafkaSink) GetLingerMs added in v0.0.124

func (m *KafkaSink) GetLingerMs() int

func (*KafkaSink) GetMessageMaxBytes added in v0.0.124

func (m *KafkaSink) GetMessageMaxBytes() int

func (*KafkaSink) Marshal added in v0.0.89

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

func (*KafkaSink) MarshalTo added in v0.0.89

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

func (*KafkaSink) MarshalToSizedBuffer added in v0.0.89

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

func (*KafkaSink) ProtoMessage added in v0.0.89

func (*KafkaSink) ProtoMessage()

func (*KafkaSink) Reset added in v0.0.89

func (m *KafkaSink) Reset()

func (*KafkaSink) Size added in v0.0.89

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

func (*KafkaSink) String added in v0.0.89

func (this *KafkaSink) String() string

func (*KafkaSink) Unmarshal added in v0.0.89

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

func (*KafkaSink) XXX_DiscardUnknown added in v0.0.89

func (m *KafkaSink) XXX_DiscardUnknown()

func (*KafkaSink) XXX_Marshal added in v0.0.89

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

func (*KafkaSink) XXX_Merge added in v0.0.89

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

func (*KafkaSink) XXX_Size added in v0.0.89

func (m *KafkaSink) XXX_Size() int

func (*KafkaSink) XXX_Unmarshal added in v0.0.89

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

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"`
	// +kubebuilder:default="100Ki"
	FetchMin *resource.Quantity `json:"fetchMin,omitempty" protobuf:"bytes,3,opt,name=fetchMin"`
	// +kubebuilder:default="500ms"
	FetchWaitMax *metav1.Duration `json:"fetchWaitMax,omitempty" protobuf:"bytes,4,opt,name=fetchWaitMax"`
	// GroupID is the consumer group ID. If not specified, a unique deterministic group ID is generated.
	GroupID string `json:"groupId,omitempty" protobuf:"bytes,5,opt,name=groupId"`
}

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) GetAutoOffsetReset added in v0.0.124

func (m *KafkaSource) GetAutoOffsetReset() string

func (*KafkaSource) GetFetchMinBytes added in v0.0.124

func (m *KafkaSource) GetFetchMinBytes() int

func (*KafkaSource) GetFetchWaitMaxMs added in v0.0.124

func (m *KafkaSource) GetFetchWaitMaxMs() int

func (*KafkaSource) GetGroupID added in v0.4.0

func (m *KafkaSource) GetGroupID(defaultGroupID string) string

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 {
	Truncate *uint64 `json:"truncate,omitempty" protobuf:"varint,1,opt,name=truncate"`
}

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 struct {
	AbstractStep `json:",inline" protobuf:"bytes,1,opt,name=abstractStep"`
	Expression   string `json:"expression" protobuf:"bytes,2,opt,name=expression"`
}

func (*Map) DeepCopy added in v0.0.97

func (in *Map) DeepCopy() *Map

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

func (*Map) DeepCopyInto added in v0.0.97

func (in *Map) DeepCopyInto(out *Map)

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

func (*Map) Descriptor added in v0.0.97

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

func (*Map) Marshal added in v0.0.97

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

func (*Map) MarshalTo added in v0.0.97

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

func (*Map) MarshalToSizedBuffer added in v0.0.97

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

func (*Map) ProtoMessage added in v0.0.97

func (*Map) ProtoMessage()

func (*Map) Reset added in v0.0.97

func (m *Map) Reset()

func (*Map) Size added in v0.0.97

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

func (*Map) String added in v0.0.97

func (this *Map) String() string

func (*Map) Unmarshal added in v0.0.97

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

func (*Map) XXX_DiscardUnknown added in v0.0.97

func (m *Map) XXX_DiscardUnknown()

func (*Map) XXX_Marshal added in v0.0.97

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

func (*Map) XXX_Merge added in v0.0.97

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

func (*Map) XXX_Size added in v0.0.97

func (m *Map) XXX_Size() int

func (*Map) XXX_Unmarshal added in v0.0.97

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

type Meta added in v0.0.116

type Meta struct {
	Source string `json:"source" protobuf:"bytes,1,opt,name=source"`
	ID     string `json:"id" protobuf:"bytes,2,opt,name=id"`
	// UnixTime
	Time int64 `json:"time,omitempty" protobuf:"varint,3,opt,name=time"`
}

func MetaFromContext added in v0.0.102

func MetaFromContext(ctx context.Context) (Meta, error)

func (*Meta) DeepCopy added in v0.0.116

func (in *Meta) DeepCopy() *Meta

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

func (*Meta) DeepCopyInto added in v0.0.116

func (in *Meta) DeepCopyInto(out *Meta)

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

func (*Meta) Descriptor added in v0.0.116

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

func (*Meta) Marshal added in v0.0.116

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

func (*Meta) MarshalTo added in v0.0.116

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

func (*Meta) MarshalToSizedBuffer added in v0.0.116

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

func (*Meta) ProtoMessage added in v0.0.116

func (*Meta) ProtoMessage()

func (*Meta) Reset added in v0.0.116

func (m *Meta) Reset()

func (*Meta) Size added in v0.0.116

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

func (*Meta) String added in v0.0.116

func (this *Meta) String() string

func (*Meta) Unmarshal added in v0.0.116

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

func (*Meta) XXX_DiscardUnknown added in v0.0.116

func (m *Meta) XXX_DiscardUnknown()

func (*Meta) XXX_Marshal added in v0.0.116

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

func (*Meta) XXX_Merge added in v0.0.116

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

func (*Meta) XXX_Size added in v0.0.116

func (m *Meta) XXX_Size() int

func (*Meta) XXX_Unmarshal added in v0.0.116

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

type Metadata

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

func (*Metadata) DeepCopy

func (in *Metadata) DeepCopy() *Metadata

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

func (*Metadata) DeepCopyInto

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

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

func (*Metadata) Descriptor

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

func (*Metadata) Marshal

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

func (*Metadata) MarshalTo

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

func (*Metadata) MarshalToSizedBuffer

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

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) Reset

func (m *Metadata) Reset()

func (*Metadata) Size

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

func (*Metadata) String

func (this *Metadata) String() string

func (*Metadata) Unmarshal

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

func (*Metadata) XXX_DiscardUnknown

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal

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

func (*Metadata) XXX_Merge

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

func (*Metadata) XXX_Size

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal

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

type NATSAuth added in v0.0.125

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

func (*NATSAuth) DeepCopy added in v0.0.125

func (in *NATSAuth) DeepCopy() *NATSAuth

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

func (*NATSAuth) DeepCopyInto added in v0.0.125

func (in *NATSAuth) DeepCopyInto(out *NATSAuth)

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

func (*NATSAuth) Descriptor added in v0.0.125

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

func (*NATSAuth) Marshal added in v0.0.125

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

func (*NATSAuth) MarshalTo added in v0.0.125

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

func (*NATSAuth) MarshalToSizedBuffer added in v0.0.125

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

func (*NATSAuth) ProtoMessage added in v0.0.125

func (*NATSAuth) ProtoMessage()

func (*NATSAuth) Reset added in v0.0.125

func (m *NATSAuth) Reset()

func (*NATSAuth) Size added in v0.0.125

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

func (*NATSAuth) String added in v0.0.125

func (this *NATSAuth) String() string

func (*NATSAuth) Unmarshal added in v0.0.125

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

func (*NATSAuth) XXX_DiscardUnknown added in v0.0.125

func (m *NATSAuth) XXX_DiscardUnknown()

func (*NATSAuth) XXX_Marshal added in v0.0.125

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

func (*NATSAuth) XXX_Merge added in v0.0.125

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

func (*NATSAuth) XXX_Size added in v0.0.125

func (m *NATSAuth) XXX_Size() int

func (*NATSAuth) XXX_Unmarshal added in v0.0.125

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

type NATSAuthStrategy added in v0.0.125

type NATSAuthStrategy string
var (
	NATSAuthNone  NATSAuthStrategy = "None"
	NATSAuthToken NATSAuthStrategy = "Token"
)

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"`
	// +kubebuilder:default="72h"
	DeletionDelay *metav1.Duration `json:"deletionDelay,omitempty" protobuf:"bytes,2,opt,name=deletionDelay"`
}

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;golang1-17;java16;python3-9;node16

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) GenURN added in v0.0.102

func (in S3) GenURN(cluster, namespace string) string

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

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"`
	// +kubebuilder:default=1
	Concurrency uint32 `json:"concurrency,omitempty" protobuf:"varint,8,opt,name=concurrency"`
}

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 SQLAction added in v0.0.89

type SQLAction struct {
	SQLStatement     `json:",inline" protobuf:"bytes,1,opt,name=statement"`
	OnRecordNotFound *SQLStatement `json:"onRecordNotFound,omitempty" protobuf:"bytes,2,opt,name=onRecordNotFound"`
	OnError          *SQLStatement `json:"onError,omitempty" protobuf:"bytes,3,opt,name=onError"`
}

func (*SQLAction) DeepCopy added in v0.0.89

func (in *SQLAction) DeepCopy() *SQLAction

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

func (*SQLAction) DeepCopyInto added in v0.0.89

func (in *SQLAction) DeepCopyInto(out *SQLAction)

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

func (*SQLAction) Descriptor added in v0.0.89

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

func (*SQLAction) Marshal added in v0.0.89

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

func (*SQLAction) MarshalTo added in v0.0.89

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

func (*SQLAction) MarshalToSizedBuffer added in v0.0.89

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

func (*SQLAction) ProtoMessage added in v0.0.89

func (*SQLAction) ProtoMessage()

func (*SQLAction) Reset added in v0.0.89

func (m *SQLAction) Reset()

func (*SQLAction) Size added in v0.0.89

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

func (*SQLAction) String added in v0.0.89

func (this *SQLAction) String() string

func (*SQLAction) Unmarshal added in v0.0.89

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

func (*SQLAction) XXX_DiscardUnknown added in v0.0.89

func (m *SQLAction) XXX_DiscardUnknown()

func (*SQLAction) XXX_Marshal added in v0.0.89

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

func (*SQLAction) XXX_Merge added in v0.0.89

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

func (*SQLAction) XXX_Size added in v0.0.89

func (m *SQLAction) XXX_Size() int

func (*SQLAction) XXX_Unmarshal added in v0.0.89

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

type SQLStatement added in v0.0.89

type SQLStatement struct {
	SQL  string   `json:"sql,omitempty" protobuf:"bytes,1,opt,name=sql"`
	Args []string `json:"args,omitempty" protobuf:"bytes,2,rep,name=args"`
}

func (*SQLStatement) DeepCopy added in v0.0.89

func (in *SQLStatement) DeepCopy() *SQLStatement

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

func (*SQLStatement) DeepCopyInto added in v0.0.89

func (in *SQLStatement) DeepCopyInto(out *SQLStatement)

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

func (*SQLStatement) Descriptor added in v0.0.89

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

func (*SQLStatement) Marshal added in v0.0.89

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

func (*SQLStatement) MarshalTo added in v0.0.89

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

func (*SQLStatement) MarshalToSizedBuffer added in v0.0.89

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

func (*SQLStatement) ProtoMessage added in v0.0.89

func (*SQLStatement) ProtoMessage()

func (*SQLStatement) Reset added in v0.0.89

func (m *SQLStatement) Reset()

func (*SQLStatement) Size added in v0.0.89

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

func (*SQLStatement) String added in v0.0.89

func (this *SQLStatement) String() string

func (*SQLStatement) Unmarshal added in v0.0.89

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

func (*SQLStatement) XXX_DiscardUnknown added in v0.0.89

func (m *SQLStatement) XXX_DiscardUnknown()

func (*SQLStatement) XXX_Marshal added in v0.0.89

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

func (*SQLStatement) XXX_Merge added in v0.0.89

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

func (*SQLStatement) XXX_Size added in v0.0.89

func (m *SQLStatement) XXX_Size() int

func (*SQLStatement) XXX_Unmarshal added in v0.0.89

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

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              *NATSAuth     `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() NATSAuthStrategy

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) GenURN added in v0.0.102

func (s STAN) GenURN(cluster, namespace string) string

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 Scale added in v0.0.9

type Scale struct {
	// An expression to determine the number of replicas. Must evaluation to an `int`.
	DesiredReplicas string `json:"desiredReplicas,omitempty" protobuf:"bytes,1,opt,name=desiredReplicas"`
	// An expression to determine the delay for peeking. Maybe string or duration, e.g. `"4m"`
	// +kubebuilder:default="defaultPeekDelay"
	PeekDelay string `json:"peekDelay,omitempty" protobuf:"bytes,2,opt,name=peekDelay"`
	// An expression to determine the delay for scaling. Maybe string or duration, e.g. `"1m"`
	// +kubebuilder:default="defaultScalingDelay"
	ScalingDelay string `json:"scalingDelay,omitempty" protobuf:"bytes,3,opt,name=scalingDelay"`
}

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 Sidecar added in v0.0.89

type Sidecar struct {
	// +kubebuilder:default={limits: {"cpu": "500m", "memory": "256Mi"}, requests: {"cpu": "100m", "memory": "64Mi"}}
	Resources corev1.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,1,opt,name=resources"`
}

func (*Sidecar) DeepCopy added in v0.0.89

func (in *Sidecar) DeepCopy() *Sidecar

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

func (*Sidecar) DeepCopyInto added in v0.0.89

func (in *Sidecar) DeepCopyInto(out *Sidecar)

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

func (*Sidecar) Descriptor added in v0.0.89

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

func (*Sidecar) Marshal added in v0.0.89

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

func (*Sidecar) MarshalTo added in v0.0.89

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

func (*Sidecar) MarshalToSizedBuffer added in v0.0.89

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

func (*Sidecar) ProtoMessage added in v0.0.89

func (*Sidecar) ProtoMessage()

func (*Sidecar) Reset added in v0.0.89

func (m *Sidecar) Reset()

func (*Sidecar) Size added in v0.0.89

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

func (*Sidecar) String added in v0.0.89

func (this *Sidecar) String() string

func (*Sidecar) Unmarshal added in v0.0.89

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

func (*Sidecar) XXX_DiscardUnknown added in v0.0.89

func (m *Sidecar) XXX_DiscardUnknown()

func (*Sidecar) XXX_Marshal added in v0.0.89

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

func (*Sidecar) XXX_Merge added in v0.0.89

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

func (*Sidecar) XXX_Size added in v0.0.89

func (m *Sidecar) XXX_Size() int

func (*Sidecar) XXX_Unmarshal added in v0.0.89

func (m *Sidecar) 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           *KafkaSink     `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"`
	DB              *DBSink        `json:"db,omitempty" protobuf:"bytes,7,opt,name=db"`
	Volume          *VolumeSink    `json:"volume,omitempty" protobuf:"bytes,8,opt,name=volume"`
	JetStream       *JetStreamSink `json:"jetstream,omitempty" protobuf:"bytes,9,opt,name=jetstream"`
	DeadLetterQueue bool           `json:"deadLetterQueue,omitempty" protobuf:"varint,10,opt,name=deadLetterQueue"`
}

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"`
	DB        *DBSource        `json:"db,omitempty" protobuf:"bytes,6,opt,name=db"`
	Volume    *VolumeSource    `json:"volume,omitempty" protobuf:"bytes,9,opt,name=volume"`
	JetStream *JetStreamSource `json:"jetstream,omitempty" protobuf:"bytes,10,opt,name=jetstream"`
	// +kubebuilder:default={duration: "100ms", steps: 20, factorPercentage: 200, 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) GenURN added in v0.0.102

func (s Source) GenURN(cluster, namespace string) string

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 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) GetHeadlessServiceName added in v0.0.102

func (in Step) GetHeadlessServiceName() string

func (Step) GetPodSpec added in v0.0.41

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

func (Step) GetServiceObj added in v0.0.102

func (in Step) GetServiceObj(serviceName, pipelineName string, isHeadless bool) *corev1.Service

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

	// +kubebuilder:default=1
	Replicas uint32 `json:"replicas,omitempty" protobuf:"varint,23,opt,name=replicas"`
	// +kubebuilder:default={peekDelay: "defaultPeekDelay", scalingDelay: "defaultScalingDelay", desiredReplicas: ""}
	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"`
	// +kubebuilder:default={resources: {limits: {"cpu": "500m", "memory": "256Mi"}, requests: {"cpu": "100m", "memory": "64Mi"}}}
	Sidecar Sidecar `json:"sidecar,omitempty" protobuf:"bytes,28,opt,name=sidecar"`
	// ImagePullSecrets is a list of references to secrets in the same namespace to use for pulling any images
	// in pods that reference this ServiceAccount. ImagePullSecrets are distinct from Secrets because Secrets
	// can be mounted in the pod, but ImagePullSecrets are only accessed by the kubelet.
	// More info: https://kubernetes.io/docs/concepts/containers/images/#specifying-imagepullsecrets-on-a-pod
	// +patchStrategy=merge
	// +patchMergeKey=name
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,20,opt,name=imagePullSecrets"`
}

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) WithOutReplicas added in v0.0.89

func (in StepSpec) WithOutReplicas() StepSpec

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,6,opt,name=reason"`
	Message      string      `json:"message,omitempty" protobuf:"bytes,2,opt,name=message"`
	Replicas     uint32      `json:"replicas" protobuf:"varint,3,opt,name=replicas"`
	Selector     string      `json:"selector,omitempty" protobuf:"bytes,5,opt,name=selector"`
	LastScaledAt metav1.Time `json:"lastScaledAt,omitempty" protobuf:"bytes,4,opt,name=lastScaledAt"`
}

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

type VolumeSink added in v0.0.91

type VolumeSink struct {
	AbstractVolumeSource `json:",inline" protobuf:"bytes,1,opt,name=abstractVolumeSource"`
}

func (*VolumeSink) DeepCopy added in v0.0.91

func (in *VolumeSink) DeepCopy() *VolumeSink

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

func (*VolumeSink) DeepCopyInto added in v0.0.91

func (in *VolumeSink) DeepCopyInto(out *VolumeSink)

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

func (*VolumeSink) Descriptor added in v0.0.91

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

func (*VolumeSink) Marshal added in v0.0.91

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

func (*VolumeSink) MarshalTo added in v0.0.91

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

func (*VolumeSink) MarshalToSizedBuffer added in v0.0.91

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

func (*VolumeSink) ProtoMessage added in v0.0.91

func (*VolumeSink) ProtoMessage()

func (*VolumeSink) Reset added in v0.0.91

func (m *VolumeSink) Reset()

func (*VolumeSink) Size added in v0.0.91

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

func (*VolumeSink) String added in v0.0.91

func (this *VolumeSink) String() string

func (*VolumeSink) Unmarshal added in v0.0.91

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

func (*VolumeSink) XXX_DiscardUnknown added in v0.0.91

func (m *VolumeSink) XXX_DiscardUnknown()

func (*VolumeSink) XXX_Marshal added in v0.0.91

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

func (*VolumeSink) XXX_Merge added in v0.0.91

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

func (*VolumeSink) XXX_Size added in v0.0.91

func (m *VolumeSink) XXX_Size() int

func (*VolumeSink) XXX_Unmarshal added in v0.0.91

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

type VolumeSource added in v0.0.91

type VolumeSource struct {
	AbstractVolumeSource `json:",inline" protobuf:"bytes,9,opt,name=abstractVolumeSource"`
	// +kubebuilder:default="1m"
	PollPeriod *metav1.Duration `json:"pollPeriod,omitempty" protobuf:"bytes,6,opt,name=pollPeriod"`
	// +kubebuilder:default=1
	Concurrency uint32 `json:"concurrency,omitempty" protobuf:"varint,8,opt,name=concurrency"`
	ReadOnly    bool   `json:"readOnly,omitempty" protobuf:"varint,10,opt,name=readOnly"`
}

func (*VolumeSource) DeepCopy added in v0.0.91

func (in *VolumeSource) DeepCopy() *VolumeSource

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

func (*VolumeSource) DeepCopyInto added in v0.0.91

func (in *VolumeSource) DeepCopyInto(out *VolumeSource)

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

func (*VolumeSource) Descriptor added in v0.0.91

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

func (*VolumeSource) Marshal added in v0.0.91

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

func (*VolumeSource) MarshalTo added in v0.0.91

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

func (*VolumeSource) MarshalToSizedBuffer added in v0.0.91

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

func (*VolumeSource) ProtoMessage added in v0.0.91

func (*VolumeSource) ProtoMessage()

func (*VolumeSource) Reset added in v0.0.91

func (m *VolumeSource) Reset()

func (*VolumeSource) Size added in v0.0.91

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

func (*VolumeSource) String added in v0.0.91

func (this *VolumeSource) String() string

func (*VolumeSource) Unmarshal added in v0.0.91

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

func (*VolumeSource) XXX_DiscardUnknown added in v0.0.91

func (m *VolumeSource) XXX_DiscardUnknown()

func (*VolumeSource) XXX_Marshal added in v0.0.91

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

func (*VolumeSource) XXX_Merge added in v0.0.91

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

func (*VolumeSource) XXX_Size added in v0.0.91

func (m *VolumeSource) XXX_Size() int

func (*VolumeSource) XXX_Unmarshal added in v0.0.91

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

Jump to

Keyboard shortcuts

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