v1alpha1

package
v1.1.6 Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2024 License: Apache-2.0 Imports: 26 Imported by: 7

Documentation

Overview

+kubebuilder:object:generate=true +groupName=numaflow.numaproj.io +k8s:deepcopy-gen=package,register +k8s:openapi-gen=true

Index

Constants

View Source 
const (
	Project = "numaflow"

	// label/annotation keys.
	KeyHash             = "numaflow.numaproj.io/hash" // hash of the object
	KeyComponent        = "app.kubernetes.io/component"
	KeyPartOf           = "app.kubernetes.io/part-of"
	KeyManagedBy        = "app.kubernetes.io/managed-by"
	KeyAppName          = "app.kubernetes.io/name"
	KeyISBSvcName       = "numaflow.numaproj.io/isbsvc-name"
	KeyISBSvcType       = "numaflow.numaproj.io/isbsvc-type"
	KeyPipelineName     = "numaflow.numaproj.io/pipeline-name"
	KeyVertexName       = "numaflow.numaproj.io/vertex-name"
	KeyReplica          = "numaflow.numaproj.io/replica"
	KeySideInputName    = "numaflow.numaproj.io/side-input-name"
	KeyPauseTimestamp   = "numaflow.numaproj.io/pause-timestamp"
	KeyDefaultContainer = "kubectl.kubernetes.io/default-container"

	RemovePauseTimestampPatch = `[{"op": "remove", "path": "/metadata/annotations/numaflow.numaproj.io~1pause-timestamp"}]`

	// ID key in the header of sources like http
	KeyMetaID        = "x-numaflow-id"
	KeyMetaEventTime = "x-numaflow-event-time"

	DefaultISBSvcName = "default"

	DefaultRedisSentinelMasterName = "mymaster"
	RedisAuthSecretKey             = "redis-password" // Redis password secret key

	JetStreamServerSecretAuthKey         = "auth"                 // key for auth server secret
	JetStreamServerSecretEncryptionKey   = "encryption"           // key for encryption server secret
	JetStreamServerPrivateKeyKey         = "private-key"          // key for server private key
	JetStreamServerCertKey               = "cert"                 // key for server TLS certificate
	JetStreamServerCACertKey             = "ca-cert"              // key for server CA certificate
	JetStreamClusterPrivateKeyKey        = "cluster-private-key"  // key for server private key
	JetStreamClusterCertKey              = "cluster-cert"         // key for server TLS certificate
	JetStreamClusterCACertKey            = "cluster-ca-cert"      // key for server CA certificate
	JetStreamClientAuthSecretUserKey     = "client-auth-user"     // key for client auth user secret
	JetStreamClientAuthSecretPasswordKey = "client-auth-password" // key for client auth password secret
	JetStreamConfigMapKey                = "nats-js"              // key for nats-js.conf in the configmap

	// container names.
	CtrInit              = "init"
	CtrMain              = "numa"
	CtrUdf               = "udf"
	CtrUdsink            = "udsink"
	CtrUdsource          = "udsource"
	CtrUdtransformer     = "transformer"
	CtrUdSideInput       = "udsi"
	CtrInitSideInputs    = "init-side-inputs"
	CtrSideInputsWatcher = "side-inputs-synchronizer"

	// components
	ComponentISBSvc           = "isbsvc"
	ComponentDaemon           = "daemon"
	ComponentVertex           = "vertex"
	ComponentJob              = "job"
	ComponentSideInputManager = "side-inputs-manager"
	ComponentUXServer         = "numaflow-ux"

	// controllers
	ControllerISBSvc   = "isbsvc-controller"
	ControllerPipeline = "pipeline-controller"
	ControllerVertex   = "vertex-controller"

	// ENV vars
	EnvNamespace                      = "NUMAFLOW_NAMESPACE"
	EnvPipelineName                   = "NUMAFLOW_PIPELINE_NAME"
	EnvVertexName                     = "NUMAFLOW_VERTEX_NAME"
	EnvPod                            = "NUMAFLOW_POD"
	EnvReplica                        = "NUMAFLOW_REPLICA"
	EnvVertexObject                   = "NUMAFLOW_VERTEX_OBJECT"
	EnvPipelineObject                 = "NUMAFLOW_PIPELINE_OBJECT"
	EnvSideInputObject                = "NUMAFLOW_SIDE_INPUT_OBJECT"
	EnvImage                          = "NUMAFLOW_IMAGE"
	EnvImagePullPolicy                = "NUMAFLOW_IMAGE_PULL_POLICY"
	EnvISBSvcRedisSentinelURL         = "NUMAFLOW_ISBSVC_REDIS_SENTINEL_URL"
	EnvISBSvcSentinelMaster           = "NUMAFLOW_ISBSVC_REDIS_SENTINEL_MASTER"
	EnvISBSvcRedisURL                 = "NUMAFLOW_ISBSVC_REDIS_URL"
	EnvISBSvcRedisUser                = "NUMAFLOW_ISBSVC_REDIS_USER"
	EnvISBSvcRedisPassword            = "NUMAFLOW_ISBSVC_REDIS_PASSWORD"
	EnvISBSvcRedisSentinelPassword    = "NUMAFLOW_ISBSVC_REDIS_SENTINEL_PASSWORD"
	EnvISBSvcRedisClusterMaxRedirects = "NUMAFLOW_ISBSVC_REDIS_CLUSTER_MAX_REDIRECTS"
	EnvISBSvcJetStreamUser            = "NUMAFLOW_ISBSVC_JETSTREAM_USER"
	EnvISBSvcJetStreamPassword        = "NUMAFLOW_ISBSVC_JETSTREAM_PASSWORD"
	EnvISBSvcJetStreamURL             = "NUMAFLOW_ISBSVC_JETSTREAM_URL"
	EnvISBSvcJetStreamTLSEnabled      = "NUMAFLOW_ISBSVC_JETSTREAM_TLS_ENABLED"
	EnvISBSvcConfig                   = "NUMAFLOW_ISBSVC_CONFIG"
	EnvLeaderElectionDisabled         = "NUMAFLOW_LEADER_ELECTION_DISABLED"
	EnvDebug                          = "NUMAFLOW_DEBUG"
	EnvPPROF                          = "NUMAFLOW_PPROF"
	EnvHealthCheckDisabled            = "NUMAFLOW_HEALTH_CHECK_DISABLED"
	EnvGRPCMaxMessageSize             = "NUMAFLOW_GRPC_MAX_MESSAGE_SIZE"
	EnvCPURequest                     = "NUMAFLOW_CPU_REQUEST"
	EnvCPULimit                       = "NUMAFLOW_CPU_LIMIT"
	EnvMemoryRequest                  = "NUMAFLOW_MEMORY_REQUEST"
	EnvMemoryLimit                    = "NUMAFLOW_MEMORY_LIMIT"
	EnvGoDebug                        = "GODEBUG"

	PathVarRun            = "/var/run/numaflow"
	VertexMetricsPort     = 2469
	VertexMetricsPortName = "metrics"
	VertexHTTPSPort       = 8443
	VertexHTTPSPortName   = "https"
	DaemonServicePort     = 4327

	DefaultRequeueAfter = 10 * time.Second

	PathSideInputsMount = "/var/numaflow/side-inputs"

	// ISB
	DefaultBufferLength     = 30000
	DefaultBufferUsageLimit = 0.8
	DefaultReadBatchSize    = 500

	// Auto scaling
	DefaultLookbackSeconds          = 120 // Default lookback seconds for calculating avg rate and pending
	DefaultCooldownSeconds          = 90  // Default cooldown seconds after a scaling operation
	DefaultZeroReplicaSleepSeconds  = 120 // Default sleep time in seconds after scaling down to 0, before peeking
	DefaultMaxReplicas              = 50  // Default max replicas
	DefaultTargetProcessingSeconds  = 20  // Default targeted time in seconds to finish processing all the pending messages for a source
	DefaultTargetBufferAvailability = 50  // Default targeted percentage of buffer availability
	DefaultReplicasPerScale         = 2   // Default maximum replicas to be scaled up or down at once

	// Default persistent buffer queue options
	DefaultPBQChannelBufferSize = 100             // Default channel size in int (what should be right value?)
	DefaultPBQReadTimeout       = 1 * time.Second // Default read timeout for pbq
	DefaultPBQReadBatchSize     = 100             // Default read batch size for pbq

	// PVC mount path for PBQ
	PathPBQMount = "/var/numaflow/pbq"

	// Default persistent store options
	DefaultStoreSyncDuration  = 2 * time.Second        // Default sync duration for pbq
	DefaultStoreMaxBufferSize = 100000                 // Default buffer size for pbq in bytes
	DefaultStorePath          = PathPBQMount + "/wals" // Default store path

	// DefaultKeyForNonKeyedData Default key for non keyed stream
	DefaultKeyForNonKeyedData = "NON_KEYED_STREAM"

	// UDF map streaming
	MapUdfStreamKey = "numaflow.numaproj.io/map-stream"
)
View Source 
const (
	ISBSvcPhaseUnknown ISBSvcPhase = ""
	ISBSvcPhasePending ISBSvcPhase = "Pending"
	ISBSvcPhaseRunning ISBSvcPhase = "Running"
	ISBSvcPhaseFailed  ISBSvcPhase = "Failed"

	// ISBSvcConditionConfigured has the status True when the InterStepBufferService
	// has valid configuration.
	ISBSvcConditionConfigured ConditionType = "Configured"
	// ISBSvcConditionDeployed has the status True when the InterStepBufferService
	// has its RestfulSet/Deployment as well as services created.
	ISBSvcConditionDeployed ConditionType = "Deployed"
)
View Source 
const (
	PipelinePhaseUnknown   PipelinePhase = ""
	PipelinePhaseRunning   PipelinePhase = "Running"
	PipelinePhaseSucceeded PipelinePhase = "Succeeded"
	PipelinePhaseFailed    PipelinePhase = "Failed"
	PipelinePhasePausing   PipelinePhase = "Pausing"
	PipelinePhasePaused    PipelinePhase = "Paused"
	PipelinePhaseDeleting  PipelinePhase = "Deleting"

	// PipelineConditionConfigured has the status True when the Pipeline
	// has valid configuration.
	PipelineConditionConfigured ConditionType = "Configured"
	// PipelineConditionDeployed has the status True when the Pipeline
	// has its Vertices and Jobs created.
	PipelineConditionDeployed ConditionType = "Deployed"
)

Variables

View Source 
var (
	MessageTagDrop = fmt.Sprintf("%U__DROP__", '\\') // U+005C__DROP__
	MessageTagAll  = fmt.Sprintf("%U__ALL__", '\\')  // U+005C__ALL__
)
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 (
	// SchemeGroupVersion is group version used to register these objects.
	SchemeGroupVersion = schema.GroupVersion{Group: "numaflow.numaproj.io", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme.
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

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

	ISBGroupVersionKind          = SchemeGroupVersion.WithKind("InterStepBufferService")
	ISBGroupVersionResource      = SchemeGroupVersion.WithResource("interstepbufferservices")
	PipelineGroupVersionKind     = SchemeGroupVersion.WithKind("Pipeline")
	PipelineGroupVersionResource = SchemeGroupVersion.WithResource("pipelines")
	VertexGroupVersionKind       = SchemeGroupVersion.WithKind("Vertex")
	VertexGroupVersionResource   = SchemeGroupVersion.WithResource("vertices")
)
View Source 
var DefaultAccessMode = corev1.ReadWriteOnce
View Source 
var DefaultVolumeSize = apiresource.MustParse("20Gi")

Functions

func GenerateBufferName 

func GenerateBufferName(namespace, pipelineName, vertex string, index int) string

func GenerateBufferNames added in v0.8.1 

func GenerateBufferNames(namespace, pipelineName, vertex string, numOfPartitions int) []string

func GenerateEdgeBucketName added in v0.8.1 

func GenerateEdgeBucketName(namespace, pipeline, from, to string) string

func GeneratePBQStoragePVCName added in v0.6.2 

func GeneratePBQStoragePVCName(pipelineName, vertex string, index int) string

GeneratePBQStoragePVCName generates pvc name used by reduce vertex.

func GenerateSinkBucketName added in v0.8.1 

func GenerateSinkBucketName(namespace, pipelineName, vertex string) string

func GenerateSourceBucketName added in v0.8.1 

func GenerateSourceBucketName(namespace, pipeline, vertex string) string

func GetOpenAPIDefinitions added in v0.6.0 

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

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type AbstractPodTemplate added in v0.6.2 

type AbstractPodTemplate struct {
	// Metadata sets the pods's metadata, i.e. annotations and labels
	// +optional
	Metadata *Metadata `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	// NodeSelector is a selector which must be true for the pod to fit on a node.
	// Selector which must match a node's labels for the pod to be scheduled on that node.
	// More info: https://kubernetes.io/docs/concepts/configuration/assign-pod-node/
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,2,rep,name=nodeSelector"`
	// If specified, the pod's tolerations.
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,3,rep,name=tolerations"`
	// SecurityContext holds pod-level security attributes and common container settings.
	// Optional: Defaults to empty.  See type description for default values of each field.
	// +optional
	SecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,4,opt,name=securityContext"`
	// ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling any of the images used by this PodSpec.
	// If specified, these secrets will be passed to individual puller implementations for them to use. For example,
	// in the case of docker, only DockerConfig type secrets are honored.
	// More info: https://kubernetes.io/docs/concepts/containers/images#specifying-imagepullsecrets-on-a-pod
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,5,rep,name=imagePullSecrets"`
	// If specified, indicates the Redis pod's priority. "system-node-critical"
	// and "system-cluster-critical" are two special keywords which indicate the
	// highest priorities with the former being the highest priority. Any other
	// name must be defined by creating a PriorityClass object with that name.
	// If not specified, the pod priority will be default or zero if there is no
	// default.
	// More info: https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/
	// +optional
	PriorityClassName string `json:"priorityClassName,omitempty" protobuf:"bytes,6,opt,name=priorityClassName"`
	// The priority value. Various system components use this field to find the
	// priority of the Redis pod. When Priority Admission Controller is enabled,
	// it prevents users from setting this field. The admission controller populates
	// this field from PriorityClassName.
	// The higher the value, the higher the priority.
	// More info: https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/
	// +optional
	Priority *int32 `json:"priority,omitempty" protobuf:"bytes,7,opt,name=priority"`
	// The pod's scheduling constraints
	// More info: https://kubernetes.io/docs/concepts/scheduling-eviction/assign-pod-node/
	// +optional
	Affinity *corev1.Affinity `json:"affinity,omitempty" protobuf:"bytes,8,opt,name=affinity"`
	// ServiceAccountName applied to the pod
	// +optional
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,9,opt,name=serviceAccountName"`
	// RuntimeClassName refers to a RuntimeClass object in the node.k8s.io group, which should be used
	// to run this pod.  If no RuntimeClass resource matches the named class, the pod will not be run.
	// If unset or empty, the "legacy" RuntimeClass will be used, which is an implicit class with an
	// empty definition that uses the default runtime handler.
	// More info: https://git.k8s.io/enhancements/keps/sig-node/585-runtime-class
	// +optional
	RuntimeClassName *string `json:"runtimeClassName,omitempty" protobuf:"bytes,10,opt,name=runtimeClassName"`
	// AutomountServiceAccountToken indicates whether a service account token should be automatically mounted.
	// +optional
	AutomountServiceAccountToken *bool `json:"automountServiceAccountToken,omitempty" protobuf:"bytes,11,opt,name=automountServiceAccountToken"`
	// Set DNS policy for the pod.
	// Defaults to "ClusterFirst".
	// Valid values are 'ClusterFirstWithHostNet', 'ClusterFirst', 'Default' or 'None'.
	// DNS parameters given in DNSConfig will be merged with the policy selected with DNSPolicy.
	// To have DNS options set along with hostNetwork, you have to specify DNS policy
	// explicitly to 'ClusterFirstWithHostNet'.
	// +optional
	DNSPolicy corev1.DNSPolicy `json:"dnsPolicy,omitempty" protobuf:"bytes,12,opt,name=dnsPolicy,casttype=DNSPolicy"`
	// Specifies the DNS parameters of a pod.
	// Parameters specified here will be merged to the generated DNS
	// configuration based on DNSPolicy.
	// +optional
	DNSConfig *corev1.PodDNSConfig `json:"dnsConfig,omitempty" protobuf:"bytes,13,opt,name=dnsConfig"`
}

AbstractPodTemplate provides a template for pod customization in vertices, daemon deployments and so on.

func (*AbstractPodTemplate) ApplyToPodSpec added in v0.6.2 

func (apt *AbstractPodTemplate) ApplyToPodSpec(ps *corev1.PodSpec)

ApplyToPodSpec updates the PodSpec with the values in the AbstractPodTemplate

func (*AbstractPodTemplate) ApplyToPodTemplateSpec added in v0.6.2 

func (apt *AbstractPodTemplate) ApplyToPodTemplateSpec(p *corev1.PodTemplateSpec)

ApplyToPodTemplateSpec updates the PodTemplateSpec with the values in the AbstractPodTemplate Labels and Annotations will be appended, individual labels or annotations in original PodTemplateSpec will not be overridden

func (*AbstractPodTemplate) DeepCopy added in v0.6.2 

func (in *AbstractPodTemplate) DeepCopy() *AbstractPodTemplate

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

func (*AbstractPodTemplate) DeepCopyInto added in v0.6.2 

func (in *AbstractPodTemplate) DeepCopyInto(out *AbstractPodTemplate)

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

func (*AbstractPodTemplate) Descriptor added in v0.6.2 

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

func (*AbstractPodTemplate) Marshal added in v0.6.2 

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

func (*AbstractPodTemplate) MarshalTo added in v0.6.2 

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

func (*AbstractPodTemplate) MarshalToSizedBuffer added in v0.6.2 

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

func (*AbstractPodTemplate) ProtoMessage added in v0.6.2 

func (*AbstractPodTemplate) ProtoMessage()

func (*AbstractPodTemplate) Reset added in v0.6.2 

func (m *AbstractPodTemplate) Reset()

func (*AbstractPodTemplate) Size added in v0.6.2 

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

func (*AbstractPodTemplate) String added in v0.6.2 

func (this *AbstractPodTemplate) String() string

func (*AbstractPodTemplate) Unmarshal added in v0.6.2 

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

func (*AbstractPodTemplate) XXX_DiscardUnknown added in v0.6.2 

func (m *AbstractPodTemplate) XXX_DiscardUnknown()

func (*AbstractPodTemplate) XXX_Marshal added in v0.6.2 

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

func (*AbstractPodTemplate) XXX_Merge added in v0.6.2 

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

func (*AbstractPodTemplate) XXX_Size added in v0.6.2 

func (m *AbstractPodTemplate) XXX_Size() int

func (*AbstractPodTemplate) XXX_Unmarshal added in v0.6.2 

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

type AbstractVertex 

type AbstractVertex struct {
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// +optional
	Source *Source `json:"source,omitempty" protobuf:"bytes,2,opt,name=source"`
	// +optional
	Sink *Sink `json:"sink,omitempty" protobuf:"bytes,3,opt,name=sink"`
	// +optional
	UDF *UDF `json:"udf,omitempty" protobuf:"bytes,4,opt,name=udf"`
	// Container template for the main numa container.
	// +optional
	ContainerTemplate *ContainerTemplate `json:"containerTemplate,omitempty" protobuf:"bytes,5,opt,name=containerTemplate"`
	// Container template for all the vertex pod init containers spawned by numaflow, excluding the ones specified by the user.
	// +optional
	InitContainerTemplate *ContainerTemplate `json:"initContainerTemplate,omitempty" protobuf:"bytes,6,opt,name=initContainerTemplate"`
	// +optional
	AbstractPodTemplate `json:",inline" protobuf:"bytes,7,opt,name=abstractPodTemplate"`
	// +optional
	// +patchStrategy=merge
	// +patchMergeKey=name
	Volumes []corev1.Volume `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,8,rep,name=volumes"`
	// Limits define the limitations such as buffer read batch size for all the vertices of a pipeline, will override pipeline level settings
	// +optional
	Limits *VertexLimits `json:"limits,omitempty" protobuf:"bytes,9,opt,name=limits"`
	// Settings for autoscaling
	// +optional
	Scale Scale `json:"scale,omitempty" protobuf:"bytes,10,opt,name=scale"`
	// List of customized init containers belonging to the pod.
	// More info: https://kubernetes.io/docs/concepts/workloads/pods/init-containers/
	// +optional
	InitContainers []corev1.Container `json:"initContainers,omitempty" protobuf:"bytes,11,rep,name=initContainers"`
	// List of customized sidecar containers belonging to the pod.
	// +optional
	Sidecars []corev1.Container `json:"sidecars,omitempty" protobuf:"bytes,12,rep,name=sidecars"`
	// Number of partitions of the vertex owned buffers.
	// It applies to udf and sink vertices only.
	// +optional
	Partitions *int32 `json:"partitions,omitempty" protobuf:"bytes,13,opt,name=partitions"`
	// Names of the side inputs used in this vertex.
	// +optional
	SideInputs []string `json:"sideInputs,omitempty" protobuf:"bytes,14,rep,name=sideInputs"`
	// Container template for the side inputs watcher container.
	// +optional
	SideInputsContainerTemplate *ContainerTemplate `json:"sideInputsContainerTemplate,omitempty" protobuf:"bytes,15,opt,name=sideInputsContainerTemplate"`
}

func (*AbstractVertex) DeepCopy 

func (in *AbstractVertex) DeepCopy() *AbstractVertex

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

func (*AbstractVertex) DeepCopyInto 

func (in *AbstractVertex) DeepCopyInto(out *AbstractVertex)

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

func (*AbstractVertex) Descriptor 

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

func (AbstractVertex) GetPartitionCount added in v0.9.0 

func (av AbstractVertex) GetPartitionCount() int

func (AbstractVertex) GetVertexType added in v0.8.1 

func (av AbstractVertex) GetVertexType() VertexType

func (AbstractVertex) HasUDTransformer added in v0.8.1 

func (av AbstractVertex) HasUDTransformer() bool

func (AbstractVertex) IsASink added in v0.8.1 

func (av AbstractVertex) IsASink() bool

func (AbstractVertex) IsASource added in v0.8.1 

func (av AbstractVertex) IsASource() bool

func (AbstractVertex) IsMapUDF added in v0.8.1 

func (av AbstractVertex) IsMapUDF() bool

func (AbstractVertex) IsReduceUDF added in v0.8.1 

func (av AbstractVertex) IsReduceUDF() bool

func (AbstractVertex) IsUDSink added in v0.8.1 

func (av AbstractVertex) IsUDSink() bool

func (AbstractVertex) IsUDSource added in v0.10.0 

func (av AbstractVertex) IsUDSource() bool

func (*AbstractVertex) Marshal 

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

func (*AbstractVertex) MarshalTo 

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

func (*AbstractVertex) MarshalToSizedBuffer 

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

func (AbstractVertex) OwnedBufferNames added in v0.8.1 

func (av AbstractVertex) OwnedBufferNames(namespace, pipeline string) []string

func (*AbstractVertex) ProtoMessage 

func (*AbstractVertex) ProtoMessage()

func (*AbstractVertex) Reset 

func (m *AbstractVertex) Reset()

func (*AbstractVertex) Size 

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

func (*AbstractVertex) String 

func (this *AbstractVertex) String() string

func (*AbstractVertex) Unmarshal 

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

func (*AbstractVertex) XXX_DiscardUnknown 

func (m *AbstractVertex) XXX_DiscardUnknown()

func (*AbstractVertex) XXX_Marshal 

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

func (*AbstractVertex) XXX_Merge 

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

func (*AbstractVertex) XXX_Size 

func (m *AbstractVertex) XXX_Size() int

func (*AbstractVertex) XXX_Unmarshal 

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

type Authorization 

type Authorization struct {
	// A secret selector which contains bearer token
	// To use this, the client needs to add "Authorization: Bearer <token>" in the header
	// +optional
	Token *corev1.SecretKeySelector `json:"token" protobuf:"bytes,1,opt,name=token"`
}

func (*Authorization) DeepCopy 

func (in *Authorization) DeepCopy() *Authorization

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

func (*Authorization) DeepCopyInto 

func (in *Authorization) DeepCopyInto(out *Authorization)

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

func (*Authorization) Descriptor 

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

func (*Authorization) Marshal 

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

func (*Authorization) MarshalTo 

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

func (*Authorization) MarshalToSizedBuffer 

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

func (*Authorization) ProtoMessage 

func (*Authorization) ProtoMessage()

func (*Authorization) Reset 

func (m *Authorization) Reset()

func (*Authorization) Size 

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

func (*Authorization) String 

func (this *Authorization) String() string

func (*Authorization) Unmarshal 

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

func (*Authorization) XXX_DiscardUnknown 

func (m *Authorization) XXX_DiscardUnknown()

func (*Authorization) XXX_Marshal 

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

func (*Authorization) XXX_Merge 

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

func (*Authorization) XXX_Size 

func (m *Authorization) XXX_Size() int

func (*Authorization) XXX_Unmarshal 

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

type BasicAuth added in v0.7.0 

type BasicAuth struct {
	// Secret for auth user
	// +optional
	User *corev1.SecretKeySelector `json:"user,omitempty" protobuf:"bytes,1,opt,name=user"`
	// Secret for auth password
	// +optional
	Password *corev1.SecretKeySelector `json:"password,omitempty" protobuf:"bytes,2,opt,name=password"`
}

BasicAuth represents the basic authentication approach which contains a user name and a password.

func (*BasicAuth) DeepCopy added in v0.7.0 

func (in *BasicAuth) DeepCopy() *BasicAuth

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

func (*BasicAuth) DeepCopyInto added in v0.7.0 

func (in *BasicAuth) DeepCopyInto(out *BasicAuth)

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

func (*BasicAuth) Descriptor added in v0.7.0 

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

func (*BasicAuth) Marshal added in v0.7.0 

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

func (*BasicAuth) MarshalTo added in v0.7.0 

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

func (*BasicAuth) MarshalToSizedBuffer added in v0.7.0 

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

func (*BasicAuth) ProtoMessage added in v0.7.0 

func (*BasicAuth) ProtoMessage()

func (*BasicAuth) Reset added in v0.7.0 

func (m *BasicAuth) Reset()

func (*BasicAuth) Size added in v0.7.0 

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

func (*BasicAuth) String added in v0.7.0 

func (this *BasicAuth) String() string

func (*BasicAuth) Unmarshal added in v0.7.0 

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

func (*BasicAuth) XXX_DiscardUnknown added in v0.7.0 

func (m *BasicAuth) XXX_DiscardUnknown()

func (*BasicAuth) XXX_Marshal added in v0.7.0 

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

func (*BasicAuth) XXX_Merge added in v0.7.0 

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

func (*BasicAuth) XXX_Size added in v0.7.0 

func (m *BasicAuth) XXX_Size() int

func (*BasicAuth) XXX_Unmarshal added in v0.7.0 

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

type Blackhole added in v0.6.3 

type Blackhole struct {
}

Blackhole is a sink to emulate /dev/null

func (*Blackhole) DeepCopy added in v0.6.3 

func (in *Blackhole) DeepCopy() *Blackhole

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

func (*Blackhole) DeepCopyInto added in v0.6.3 

func (in *Blackhole) DeepCopyInto(out *Blackhole)

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

func (*Blackhole) Descriptor added in v0.6.3 

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

func (*Blackhole) Marshal added in v0.6.3 

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

func (*Blackhole) MarshalTo added in v0.6.3 

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

func (*Blackhole) MarshalToSizedBuffer added in v0.6.3 

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

func (*Blackhole) ProtoMessage added in v0.6.3 

func (*Blackhole) ProtoMessage()

func (*Blackhole) Reset added in v0.6.3 

func (m *Blackhole) Reset()

func (*Blackhole) Size added in v0.6.3 

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

func (*Blackhole) String added in v0.6.3 

func (this *Blackhole) String() string

func (*Blackhole) Unmarshal added in v0.6.3 

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

func (*Blackhole) XXX_DiscardUnknown added in v0.6.3 

func (m *Blackhole) XXX_DiscardUnknown()

func (*Blackhole) XXX_Marshal added in v0.6.3 

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

func (*Blackhole) XXX_Merge added in v0.6.3 

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

func (*Blackhole) XXX_Size added in v0.6.3 

func (m *Blackhole) XXX_Size() int

func (*Blackhole) XXX_Unmarshal added in v0.6.3 

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

type BufferFullWritingStrategy added in v0.7.3 

type BufferFullWritingStrategy string
const (
	RetryUntilSuccess BufferFullWritingStrategy = "retryUntilSuccess"
	DiscardLatest     BufferFullWritingStrategy = "discardLatest"
)

type BufferServiceConfig 

type BufferServiceConfig struct {
	Redis     *RedisConfig     `json:"redis,omitempty" protobuf:"bytes,1,opt,name=redis"`
	JetStream *JetStreamConfig `json:"jetstream,omitempty" protobuf:"bytes,2,opt,name=jetstream"`
}

func (*BufferServiceConfig) DeepCopy 

func (in *BufferServiceConfig) DeepCopy() *BufferServiceConfig

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

func (*BufferServiceConfig) DeepCopyInto 

func (in *BufferServiceConfig) DeepCopyInto(out *BufferServiceConfig)

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

func (*BufferServiceConfig) Descriptor 

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

func (*BufferServiceConfig) Marshal 

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

func (*BufferServiceConfig) MarshalTo 

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

func (*BufferServiceConfig) MarshalToSizedBuffer 

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

func (*BufferServiceConfig) ProtoMessage 

func (*BufferServiceConfig) ProtoMessage()

func (*BufferServiceConfig) Reset 

func (m *BufferServiceConfig) Reset()

func (*BufferServiceConfig) Size 

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

func (*BufferServiceConfig) String 

func (this *BufferServiceConfig) String() string

func (*BufferServiceConfig) Unmarshal 

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

func (*BufferServiceConfig) XXX_DiscardUnknown 

func (m *BufferServiceConfig) XXX_DiscardUnknown()

func (*BufferServiceConfig) XXX_Marshal 

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

func (*BufferServiceConfig) XXX_Merge 

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

func (*BufferServiceConfig) XXX_Size 

func (m *BufferServiceConfig) XXX_Size() int

func (*BufferServiceConfig) XXX_Unmarshal 

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

type CombinedEdge added in v0.8.1 

type CombinedEdge struct {
	Edge `json:",inline" protobuf:"bytes,1,opt,name=edge"`
	// From vertex type.
	FromVertexType VertexType `json:"fromVertexType" protobuf:"bytes,2,opt,name=fromVertexType"`
	// The number of partitions of the from vertex, if not provided, the default value is set to "1".
	// +optional
	FromVertexPartitionCount *int32 `json:"fromVertexPartitionCount,omitempty" protobuf:"bytes,3,opt,name=fromVertexPartitionCount"`
	// +optional
	FromVertexLimits *VertexLimits `json:"fromVertexLimits,omitempty" protobuf:"bytes,4,opt,name=fromVertexLimits"`
	// To vertex type.
	ToVertexType VertexType `json:"toVertexType" protobuf:"bytes,5,opt,name=toVertexType"`
	// The number of partitions of the to vertex, if not provided, the default value is set to "1".
	// +optional
	ToVertexPartitionCount *int32 `json:"toVertexPartitionCount,omitempty" protobuf:"bytes,6,opt,name=toVertexPartitionCount"`
	// +optional
	ToVertexLimits *VertexLimits `json:"toVertexLimits,omitempty" protobuf:"bytes,7,opt,name=toVertexLimits"`
}

CombinedEdge is a combination of Edge and some other properties such as vertex type, partitions, limits. It's used to decorate the fromEdges and toEdges of the generated Vertex objects, so that in the vertex pod, it knows the properties of the connected vertices, for example, how many partitioned buffers I should write to, what is the write buffer length, etc.

func (*CombinedEdge) DeepCopy added in v0.8.1 

func (in *CombinedEdge) DeepCopy() *CombinedEdge

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

func (*CombinedEdge) DeepCopyInto added in v0.8.1 

func (in *CombinedEdge) DeepCopyInto(out *CombinedEdge)

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

func (*CombinedEdge) Descriptor added in v0.8.1 

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

func (CombinedEdge) GetFromVertexPartitions added in v0.8.1 

func (ce CombinedEdge) GetFromVertexPartitions() int

func (CombinedEdge) GetToVertexPartitionCount added in v0.9.0 

func (ce CombinedEdge) GetToVertexPartitionCount() int

func (*CombinedEdge) Marshal added in v0.8.1 

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

func (*CombinedEdge) MarshalTo added in v0.8.1 

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

func (*CombinedEdge) MarshalToSizedBuffer added in v0.8.1 

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

func (*CombinedEdge) ProtoMessage added in v0.8.1 

func (*CombinedEdge) ProtoMessage()

func (*CombinedEdge) Reset added in v0.8.1 

func (m *CombinedEdge) Reset()

func (*CombinedEdge) Size added in v0.8.1 

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

func (*CombinedEdge) String added in v0.8.1 

func (this *CombinedEdge) String() string

func (*CombinedEdge) Unmarshal added in v0.8.1 

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

func (*CombinedEdge) XXX_DiscardUnknown added in v0.8.1 

func (m *CombinedEdge) XXX_DiscardUnknown()

func (*CombinedEdge) XXX_Marshal added in v0.8.1 

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

func (*CombinedEdge) XXX_Merge added in v0.8.1 

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

func (*CombinedEdge) XXX_Size added in v0.8.1 

func (m *CombinedEdge) XXX_Size() int

func (*CombinedEdge) XXX_Unmarshal added in v0.8.1 

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

type ConditionType 

type ConditionType string

ConditionType is a valid value of Condition.Type 

const (
	// ConditionReady indicates the resource is ready.
	ConditionReady ConditionType = "Ready"
)

type Container 

type Container struct {
	// +optional
	Image string `json:"image" protobuf:"bytes,1,opt,name=image"`
	// +optional
	Command []string `json:"command,omitempty" protobuf:"bytes,2,rep,name=command"`
	// +optional
	Args []string `json:"args,omitempty" protobuf:"bytes,3,rep,name=args"`
	// +optional
	Env []corev1.EnvVar `json:"env,omitempty" protobuf:"bytes,4,rep,name=env"`
	// +optional
	EnvFrom []corev1.EnvFromSource `json:"envFrom,omitempty" protobuf:"bytes,5,rep,name=envFrom"`
	// +optional
	VolumeMounts []corev1.VolumeMount `json:"volumeMounts,omitempty" protobuf:"bytes,6,rep,name=volumeMounts"`
	// +optional
	Resources corev1.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,7,opt,name=resources"`
	// +optional
	SecurityContext *corev1.SecurityContext `json:"securityContext,omitempty" protobuf:"bytes,8,opt,name=securityContext"`
	// +optional
	ImagePullPolicy *corev1.PullPolicy `json:"imagePullPolicy,omitempty" protobuf:"bytes,9,opt,name=imagePullPolicy,casttype=PullPolicy"`
}

Container is used to define the container properties for user defined functions, sinks, etc.

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) 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 ContainerTemplate 

type ContainerTemplate struct {
	// +optional
	Resources corev1.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,1,opt,name=resources"`
	// +optional
	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty" protobuf:"bytes,2,opt,name=imagePullPolicy,casttype=PullPolicy"`
	// +optional
	SecurityContext *corev1.SecurityContext `json:"securityContext,omitempty" protobuf:"bytes,3,opt,name=securityContext"`
	// +optional
	Env []corev1.EnvVar `json:"env,omitempty" protobuf:"bytes,4,rep,name=env"`
	// +optional
	EnvFrom []corev1.EnvFromSource `json:"envFrom,omitempty" protobuf:"bytes,5,rep,name=envFrom"`
}

ContainerTemplate defines customized spec for a container

func (*ContainerTemplate) ApplyToContainer added in v0.6.2 

func (ct *ContainerTemplate) ApplyToContainer(c *corev1.Container)

ApplyToContainer updates the Container with the values from the ContainerTemplate

func (*ContainerTemplate) ApplyToNumaflowContainers added in v0.6.2 

func (ct *ContainerTemplate) ApplyToNumaflowContainers(containers []corev1.Container)

ApplyToNumaflowContainers updates any numa or init containers with the values from the ContainerTemplate

func (*ContainerTemplate) DeepCopy 

func (in *ContainerTemplate) DeepCopy() *ContainerTemplate

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

func (*ContainerTemplate) DeepCopyInto 

func (in *ContainerTemplate) DeepCopyInto(out *ContainerTemplate)

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

func (*ContainerTemplate) Descriptor 

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

func (*ContainerTemplate) Marshal 

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

func (*ContainerTemplate) MarshalTo 

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

func (*ContainerTemplate) MarshalToSizedBuffer 

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

func (*ContainerTemplate) ProtoMessage 

func (*ContainerTemplate) ProtoMessage()

func (*ContainerTemplate) Reset 

func (m *ContainerTemplate) Reset()

func (*ContainerTemplate) Size 

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

func (*ContainerTemplate) String 

func (this *ContainerTemplate) String() string

func (*ContainerTemplate) Unmarshal 

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

func (*ContainerTemplate) XXX_DiscardUnknown 

func (m *ContainerTemplate) XXX_DiscardUnknown()

func (*ContainerTemplate) XXX_Marshal 

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

func (*ContainerTemplate) XXX_Merge 

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

func (*ContainerTemplate) XXX_Size 

func (m *ContainerTemplate) XXX_Size() int

func (*ContainerTemplate) XXX_Unmarshal 

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

type DaemonTemplate added in v0.6.2 

type DaemonTemplate struct {
	// +optional
	AbstractPodTemplate `json:",inline" protobuf:"bytes,1,opt,name=abstractPodTemplate"`
	// Replicas is the number of desired replicas of the Deployment.
	// This is a pointer to distinguish between explicit zero and unspecified.
	// Defaults to 1.
	// More info: https://kubernetes.io/docs/concepts/workloads/controllers/replicationcontroller#what-is-a-replicationcontroller
	// +optional
	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,2,opt,name=replicas"`
	// +optional
	ContainerTemplate *ContainerTemplate `json:"containerTemplate,omitempty" protobuf:"bytes,3,opt,name=containerTemplate"`
	// +optional
	InitContainerTemplate *ContainerTemplate `json:"initContainerTemplate,omitempty" protobuf:"bytes,4,opt,name=initContainerTemplate"`
}

func (*DaemonTemplate) DeepCopy added in v0.6.2 

func (in *DaemonTemplate) DeepCopy() *DaemonTemplate

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

func (*DaemonTemplate) DeepCopyInto added in v0.6.2 

func (in *DaemonTemplate) DeepCopyInto(out *DaemonTemplate)

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

func (*DaemonTemplate) Descriptor added in v0.6.2 

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

func (*DaemonTemplate) Marshal added in v0.6.2 

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

func (*DaemonTemplate) MarshalTo added in v0.6.2 

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

func (*DaemonTemplate) MarshalToSizedBuffer added in v0.6.2 

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

func (*DaemonTemplate) ProtoMessage added in v0.6.2 

func (*DaemonTemplate) ProtoMessage()

func (*DaemonTemplate) Reset added in v0.6.2 

func (m *DaemonTemplate) Reset()

func (*DaemonTemplate) Size added in v0.6.2 

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

func (*DaemonTemplate) String added in v0.6.2 

func (this *DaemonTemplate) String() string

func (*DaemonTemplate) Unmarshal added in v0.6.2 

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

func (*DaemonTemplate) XXX_DiscardUnknown added in v0.6.2 

func (m *DaemonTemplate) XXX_DiscardUnknown()

func (*DaemonTemplate) XXX_Marshal added in v0.6.2 

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

func (*DaemonTemplate) XXX_Merge added in v0.6.2 

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

func (*DaemonTemplate) XXX_Size added in v0.6.2 

func (m *DaemonTemplate) XXX_Size() int

func (*DaemonTemplate) XXX_Unmarshal added in v0.6.2 

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

type Edge 

type Edge struct {
	From string `json:"from" protobuf:"bytes,1,opt,name=from"`
	To   string `json:"to" protobuf:"bytes,2,opt,name=to"`
	// Conditional forwarding, only allowed when "From" is a Sink or UDF.
	// +optional
	Conditions *ForwardConditions `json:"conditions" protobuf:"bytes,3,opt,name=conditions"`
	// OnFull specifies the behaviour for the write actions when the inter step buffer is full.
	// There are currently two options, retryUntilSuccess and discardLatest.
	// if not provided, the default value is set to "retryUntilSuccess"
	// +kubebuilder:validation:Enum=retryUntilSuccess;discardLatest
	// +optional
	OnFull *BufferFullWritingStrategy `json:"onFull,omitempty" protobuf:"bytes,4,opt,name=onFull"`
}

func (Edge) BufferFullWritingStrategy added in v0.7.3 

func (e Edge) BufferFullWritingStrategy() BufferFullWritingStrategy

func (*Edge) DeepCopy 

func (in *Edge) DeepCopy() *Edge

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

func (*Edge) DeepCopyInto 

func (in *Edge) DeepCopyInto(out *Edge)

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

func (*Edge) Descriptor 

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

func (Edge) GetEdgeName added in v0.9.0 

func (e Edge) GetEdgeName() string

func (*Edge) Marshal 

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

func (*Edge) MarshalTo 

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

func (*Edge) MarshalToSizedBuffer 

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

func (*Edge) ProtoMessage 

func (*Edge) ProtoMessage()

func (*Edge) Reset 

func (m *Edge) Reset()

func (*Edge) Size 

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

func (*Edge) String 

func (this *Edge) String() string

func (*Edge) Unmarshal 

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

func (*Edge) XXX_DiscardUnknown 

func (m *Edge) XXX_DiscardUnknown()

func (*Edge) XXX_Marshal 

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

func (*Edge) XXX_Merge 

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

func (*Edge) XXX_Size 

func (m *Edge) XXX_Size() int

func (*Edge) XXX_Unmarshal 

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

type FixedWindow added in v0.6.1 

type FixedWindow struct {
	Length *metav1.Duration `json:"length,omitempty" protobuf:"bytes,1,opt,name=length"`
}

FixedWindow describes a fixed window

func (*FixedWindow) DeepCopy added in v0.6.1 

func (in *FixedWindow) DeepCopy() *FixedWindow

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

func (*FixedWindow) DeepCopyInto added in v0.6.1 

func (in *FixedWindow) DeepCopyInto(out *FixedWindow)

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

func (*FixedWindow) Descriptor added in v0.6.1 

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

func (*FixedWindow) Marshal added in v0.6.1 

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

func (*FixedWindow) MarshalTo added in v0.6.1 

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

func (*FixedWindow) MarshalToSizedBuffer added in v0.6.1 

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

func (*FixedWindow) ProtoMessage added in v0.6.1 

func (*FixedWindow) ProtoMessage()

func (*FixedWindow) Reset added in v0.6.1 

func (m *FixedWindow) Reset()

func (*FixedWindow) Size added in v0.6.1 

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

func (*FixedWindow) String added in v0.6.1 

func (this *FixedWindow) String() string

func (*FixedWindow) Unmarshal added in v0.6.1 

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

func (*FixedWindow) XXX_DiscardUnknown added in v0.6.1 

func (m *FixedWindow) XXX_DiscardUnknown()

func (*FixedWindow) XXX_Marshal added in v0.6.1 

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

func (*FixedWindow) XXX_Merge added in v0.6.1 

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

func (*FixedWindow) XXX_Size added in v0.6.1 

func (m *FixedWindow) XXX_Size() int

func (*FixedWindow) XXX_Unmarshal added in v0.6.1 

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

type ForwardConditions 

type ForwardConditions struct {
	// Tags used to specify tags for conditional forwarding
	Tags *TagConditions `json:"tags" protobuf:"bytes,1,opt,name=tags"`
}

func (*ForwardConditions) DeepCopy 

func (in *ForwardConditions) DeepCopy() *ForwardConditions

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

func (*ForwardConditions) DeepCopyInto 

func (in *ForwardConditions) DeepCopyInto(out *ForwardConditions)

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

func (*ForwardConditions) Descriptor 

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

func (*ForwardConditions) Marshal 

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

func (*ForwardConditions) MarshalTo 

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

func (*ForwardConditions) MarshalToSizedBuffer 

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

func (*ForwardConditions) ProtoMessage 

func (*ForwardConditions) ProtoMessage()

func (*ForwardConditions) Reset 

func (m *ForwardConditions) Reset()

func (*ForwardConditions) Size 

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

func (*ForwardConditions) String 

func (this *ForwardConditions) String() string

func (*ForwardConditions) Unmarshal 

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

func (*ForwardConditions) XXX_DiscardUnknown 

func (m *ForwardConditions) XXX_DiscardUnknown()

func (*ForwardConditions) XXX_Marshal 

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

func (*ForwardConditions) XXX_Merge 

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

func (*ForwardConditions) XXX_Size 

func (m *ForwardConditions) XXX_Size() int

func (*ForwardConditions) XXX_Unmarshal 

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

type Function 

type Function struct {
	// +kubebuilder:validation:Enum=cat;filter
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// +optional
	Args []string `json:"args,omitempty" protobuf:"bytes,2,rep,name=args"`
	// +optional
	KWArgs map[string]string `json:"kwargs,omitempty" protobuf:"bytes,3,rep,name=kwargs"`
}

func (*Function) DeepCopy 

func (in *Function) DeepCopy() *Function

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

func (*Function) DeepCopyInto 

func (in *Function) DeepCopyInto(out *Function)

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

func (*Function) Descriptor 

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

func (*Function) Marshal 

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

func (*Function) MarshalTo 

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

func (*Function) MarshalToSizedBuffer 

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

func (*Function) ProtoMessage 

func (*Function) ProtoMessage()

func (*Function) Reset 

func (m *Function) Reset()

func (*Function) Size 

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

func (*Function) String 

func (this *Function) String() string

func (*Function) Unmarshal 

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

func (*Function) XXX_DiscardUnknown 

func (m *Function) XXX_DiscardUnknown()

func (*Function) XXX_Marshal 

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

func (*Function) XXX_Merge 

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

func (*Function) XXX_Size 

func (m *Function) XXX_Size() int

func (*Function) XXX_Unmarshal 

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

type GSSAPI added in v0.7.3 

type GSSAPI struct {
	ServiceName string `json:"serviceName" protobuf:"bytes,1,opt,name=serviceName"`
	Realm       string `json:"realm" protobuf:"bytes,2,opt,name=realm"`
	// UsernameSecret refers to the secret that contains the username
	UsernameSecret *corev1.SecretKeySelector `json:"usernameSecret" protobuf:"bytes,3,opt,name=usernameSecret"`
	// valid inputs - KRB5_USER_AUTH, KRB5_KEYTAB_AUTH
	AuthType *KRB5AuthType `json:"authType" protobuf:"bytes,4,opt,name=authType,casttype=KRB5AuthType"`
	// PasswordSecret refers to the secret that contains the password
	// +optional
	PasswordSecret *corev1.SecretKeySelector `json:"passwordSecret,omitempty" protobuf:"bytes,5,opt,name=passwordSecret"`
	// KeytabSecret refers to the secret that contains the keytab
	// +optional
	KeytabSecret *corev1.SecretKeySelector `json:"keytabSecret,omitempty" protobuf:"bytes,6,opt,name=keytabSecret"`
	// KerberosConfigSecret refers to the secret that contains the kerberos config
	// +optional
	KerberosConfigSecret *corev1.SecretKeySelector `json:"kerberosConfigSecret,omitempty" protobuf:"bytes,7,opt,name=kerberosConfigSecret"`
}

GSSAPI represents a SASL GSSAPI config

func (*GSSAPI) DeepCopy added in v0.7.3 

func (in *GSSAPI) DeepCopy() *GSSAPI

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

func (*GSSAPI) DeepCopyInto added in v0.7.3 

func (in *GSSAPI) DeepCopyInto(out *GSSAPI)

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

func (*GSSAPI) Descriptor added in v0.7.3 

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

func (*GSSAPI) Marshal added in v0.7.3 

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

func (*GSSAPI) MarshalTo added in v0.7.3 

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

func (*GSSAPI) MarshalToSizedBuffer added in v0.7.3 

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

func (*GSSAPI) ProtoMessage added in v0.7.3 

func (*GSSAPI) ProtoMessage()

func (*GSSAPI) Reset added in v0.7.3 

func (m *GSSAPI) Reset()

func (*GSSAPI) Size added in v0.7.3 

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

func (*GSSAPI) String added in v0.7.3 

func (this *GSSAPI) String() string

func (*GSSAPI) Unmarshal added in v0.7.3 

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

func (*GSSAPI) XXX_DiscardUnknown added in v0.7.3 

func (m *GSSAPI) XXX_DiscardUnknown()

func (*GSSAPI) XXX_Marshal added in v0.7.3 

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

func (*GSSAPI) XXX_Merge added in v0.7.3 

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

func (*GSSAPI) XXX_Size added in v0.7.3 

func (m *GSSAPI) XXX_Size() int

func (*GSSAPI) XXX_Unmarshal added in v0.7.3 

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

type GeneratorSource 

type GeneratorSource struct {
	// +kubebuilder:default=5
	// +optional
	RPU *int64 `json:"rpu,omitempty" protobuf:"bytes,1,opt,name=rpu"`
	// +kubebuilder:default="1s"
	// +optional
	Duration *metav1.Duration `json:"duration,omitempty" protobuf:"bytes,2,opt,name=duration"`
	// Size of each generated message
	// +kubebuilder:default=8
	// +optional
	MsgSize *int32 `json:"msgSize,omitempty" protobuf:"bytes,3,opt,name=msgSize"`
	// KeyCount is the number of unique keys in the payload
	KeyCount *int32 `json:"keyCount,omitempty" protobuf:"bytes,4,opt,name=keyCount"`
	// Value is an optional uint64 value to be written in to the payload
	Value *uint64 `json:"value,omitempty" protobuf:"bytes,5,opt,name=value"`
}

func (*GeneratorSource) DeepCopy 

func (in *GeneratorSource) DeepCopy() *GeneratorSource

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

func (*GeneratorSource) DeepCopyInto 

func (in *GeneratorSource) DeepCopyInto(out *GeneratorSource)

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

func (*GeneratorSource) Descriptor 

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

func (*GeneratorSource) Marshal 

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

func (*GeneratorSource) MarshalTo 

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

func (*GeneratorSource) MarshalToSizedBuffer 

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

func (*GeneratorSource) ProtoMessage 

func (*GeneratorSource) ProtoMessage()

func (*GeneratorSource) Reset 

func (m *GeneratorSource) Reset()

func (*GeneratorSource) Size 

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

func (*GeneratorSource) String 

func (this *GeneratorSource) String() string

func (*GeneratorSource) Unmarshal 

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

func (*GeneratorSource) XXX_DiscardUnknown 

func (m *GeneratorSource) XXX_DiscardUnknown()

func (*GeneratorSource) XXX_Marshal 

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

func (*GeneratorSource) XXX_Merge 

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

func (*GeneratorSource) XXX_Size 

func (m *GeneratorSource) XXX_Size() int

func (*GeneratorSource) XXX_Unmarshal 

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

type GetDaemonDeploymentReq 

type GetDaemonDeploymentReq struct {
	ISBSvcType       ISBSvcType                  `protobuf:"bytes,1,opt,name=isbSvcType"`
	Image            string                      `protobuf:"bytes,2,opt,name=image"`
	PullPolicy       corev1.PullPolicy           `protobuf:"bytes,3,opt,name=pullPolicy,casttype=k8s.io/api/core/v1.PullPolicy"`
	Env              []corev1.EnvVar             `protobuf:"bytes,4,rep,name=env"`
	DefaultResources corev1.ResourceRequirements `protobuf:"bytes,5,opt,name=defaultResources"`
}

func (*GetDaemonDeploymentReq) DeepCopy 

func (in *GetDaemonDeploymentReq) DeepCopy() *GetDaemonDeploymentReq

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

func (*GetDaemonDeploymentReq) DeepCopyInto 

func (in *GetDaemonDeploymentReq) DeepCopyInto(out *GetDaemonDeploymentReq)

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

func (*GetDaemonDeploymentReq) Descriptor 

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

func (*GetDaemonDeploymentReq) Marshal 

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

func (*GetDaemonDeploymentReq) MarshalTo 

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

func (*GetDaemonDeploymentReq) MarshalToSizedBuffer 

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

func (*GetDaemonDeploymentReq) ProtoMessage 

func (*GetDaemonDeploymentReq) ProtoMessage()

func (*GetDaemonDeploymentReq) Reset 

func (m *GetDaemonDeploymentReq) Reset()

func (*GetDaemonDeploymentReq) Size 

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

func (*GetDaemonDeploymentReq) String 

func (this *GetDaemonDeploymentReq) String() string

func (*GetDaemonDeploymentReq) Unmarshal 

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

func (*GetDaemonDeploymentReq) XXX_DiscardUnknown 

func (m *GetDaemonDeploymentReq) XXX_DiscardUnknown()

func (*GetDaemonDeploymentReq) XXX_Marshal 

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

func (*GetDaemonDeploymentReq) XXX_Merge 

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

func (*GetDaemonDeploymentReq) XXX_Size 

func (m *GetDaemonDeploymentReq) XXX_Size() int

func (*GetDaemonDeploymentReq) XXX_Unmarshal 

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

type GetJetStreamServiceSpecReq 

type GetJetStreamServiceSpecReq struct {
	Labels      map[string]string `protobuf:"bytes,1,rep,name=labels"`
	ClusterPort int32             `protobuf:"bytes,2,opt,name=clusterPort"`
	ClientPort  int32             `protobuf:"bytes,3,opt,name=clientPort"`
	MonitorPort int32             `protobuf:"bytes,4,opt,name=monitorPort"`
	MetricsPort int32             `protobuf:"bytes,5,opt,name=metricsPort"`
}

func (*GetJetStreamServiceSpecReq) DeepCopy 

func (in *GetJetStreamServiceSpecReq) DeepCopy() *GetJetStreamServiceSpecReq

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

func (*GetJetStreamServiceSpecReq) DeepCopyInto 

func (in *GetJetStreamServiceSpecReq) DeepCopyInto(out *GetJetStreamServiceSpecReq)

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

func (*GetJetStreamServiceSpecReq) Descriptor 

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

func (*GetJetStreamServiceSpecReq) Marshal 

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

func (*GetJetStreamServiceSpecReq) MarshalTo 

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

func (*GetJetStreamServiceSpecReq) MarshalToSizedBuffer 

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

func (*GetJetStreamServiceSpecReq) ProtoMessage 

func (*GetJetStreamServiceSpecReq) ProtoMessage()

func (*GetJetStreamServiceSpecReq) Reset 

func (m *GetJetStreamServiceSpecReq) Reset()

func (*GetJetStreamServiceSpecReq) Size 

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

func (*GetJetStreamServiceSpecReq) String 

func (this *GetJetStreamServiceSpecReq) String() string

func (*GetJetStreamServiceSpecReq) Unmarshal 

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

func (*GetJetStreamServiceSpecReq) XXX_DiscardUnknown 

func (m *GetJetStreamServiceSpecReq) XXX_DiscardUnknown()

func (*GetJetStreamServiceSpecReq) XXX_Marshal 

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

func (*GetJetStreamServiceSpecReq) XXX_Merge 

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

func (*GetJetStreamServiceSpecReq) XXX_Size 

func (m *GetJetStreamServiceSpecReq) XXX_Size() int

func (*GetJetStreamServiceSpecReq) XXX_Unmarshal 

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

type GetJetStreamStatefulSetSpecReq 

type GetJetStreamStatefulSetSpecReq struct {
	ServiceName                string                      `protobuf:"bytes,1,rep,name=serviceName"`
	Labels                     map[string]string           `protobuf:"bytes,2,rep,name=labels"`
	NatsImage                  string                      `protobuf:"bytes,3,opt,name=natsImage"`
	MetricsExporterImage       string                      `protobuf:"bytes,4,opt,name=metricsExporterImage"`
	ConfigReloaderImage        string                      `protobuf:"bytes,5,opt,name=configReloaderImage"`
	ClusterPort                int32                       `protobuf:"bytes,6,opt,name=clusterPort"`
	ClientPort                 int32                       `protobuf:"bytes,7,opt,name=clientPort"`
	MonitorPort                int32                       `protobuf:"bytes,8,opt,name=monitorPort"`
	MetricsPort                int32                       `protobuf:"bytes,9,opt,name=metricsPort"`
	ServerAuthSecretName       string                      `protobuf:"bytes,10,opt,name=serverAuthSecretName"`
	ServerEncryptionSecretName string                      `protobuf:"bytes,11,opt,name=serverEncryptionSecretName"`
	ConfigMapName              string                      `protobuf:"bytes,12,opt,name=configMapName"`
	PvcNameIfNeeded            string                      `protobuf:"bytes,13,opt,name=pvcNameIfNeeded"`
	StartCommand               string                      `protobuf:"bytes,14,opt,name=startCommand"`
	DefaultResources           corev1.ResourceRequirements `protobuf:"bytes,15,opt,name=defaultResources"`
}

func (*GetJetStreamStatefulSetSpecReq) DeepCopy 

func (in *GetJetStreamStatefulSetSpecReq) DeepCopy() *GetJetStreamStatefulSetSpecReq

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

func (*GetJetStreamStatefulSetSpecReq) DeepCopyInto 

func (in *GetJetStreamStatefulSetSpecReq) DeepCopyInto(out *GetJetStreamStatefulSetSpecReq)

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

func (*GetJetStreamStatefulSetSpecReq) Descriptor 

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

func (*GetJetStreamStatefulSetSpecReq) Marshal 

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

func (*GetJetStreamStatefulSetSpecReq) MarshalTo 

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

func (*GetJetStreamStatefulSetSpecReq) MarshalToSizedBuffer 

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

func (*GetJetStreamStatefulSetSpecReq) ProtoMessage 

func (*GetJetStreamStatefulSetSpecReq) ProtoMessage()

func (*GetJetStreamStatefulSetSpecReq) Reset 

func (m *GetJetStreamStatefulSetSpecReq) Reset()

func (*GetJetStreamStatefulSetSpecReq) Size 

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

func (*GetJetStreamStatefulSetSpecReq) String 

func (this *GetJetStreamStatefulSetSpecReq) String() string

func (*GetJetStreamStatefulSetSpecReq) Unmarshal 

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

func (*GetJetStreamStatefulSetSpecReq) XXX_DiscardUnknown 

func (m *GetJetStreamStatefulSetSpecReq) XXX_DiscardUnknown()

func (*GetJetStreamStatefulSetSpecReq) XXX_Marshal 

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

func (*GetJetStreamStatefulSetSpecReq) XXX_Merge 

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

func (*GetJetStreamStatefulSetSpecReq) XXX_Size 

func (m *GetJetStreamStatefulSetSpecReq) XXX_Size() int

func (*GetJetStreamStatefulSetSpecReq) XXX_Unmarshal 

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

type GetRedisServiceSpecReq 

type GetRedisServiceSpecReq struct {
	Labels                map[string]string `protobuf:"bytes,1,rep,name=labels"`
	RedisContainerPort    int32             `protobuf:"bytes,2,opt,name=redisContainerPort"`
	SentinelContainerPort int32             `protobuf:"bytes,3,opt,name=sentinelContainerPort"`
}

func (*GetRedisServiceSpecReq) DeepCopy 

func (in *GetRedisServiceSpecReq) DeepCopy() *GetRedisServiceSpecReq

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

func (*GetRedisServiceSpecReq) DeepCopyInto 

func (in *GetRedisServiceSpecReq) DeepCopyInto(out *GetRedisServiceSpecReq)

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

func (*GetRedisServiceSpecReq) Descriptor 

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

func (*GetRedisServiceSpecReq) Marshal 

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

func (*GetRedisServiceSpecReq) MarshalTo 

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

func (*GetRedisServiceSpecReq) MarshalToSizedBuffer 

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

func (*GetRedisServiceSpecReq) ProtoMessage 

func (*GetRedisServiceSpecReq) ProtoMessage()

func (*GetRedisServiceSpecReq) Reset 

func (m *GetRedisServiceSpecReq) Reset()

func (*GetRedisServiceSpecReq) Size 

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

func (*GetRedisServiceSpecReq) String 

func (this *GetRedisServiceSpecReq) String() string

func (*GetRedisServiceSpecReq) Unmarshal 

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

func (*GetRedisServiceSpecReq) XXX_DiscardUnknown 

func (m *GetRedisServiceSpecReq) XXX_DiscardUnknown()

func (*GetRedisServiceSpecReq) XXX_Marshal 

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

func (*GetRedisServiceSpecReq) XXX_Merge 

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

func (*GetRedisServiceSpecReq) XXX_Size 

func (m *GetRedisServiceSpecReq) XXX_Size() int

func (*GetRedisServiceSpecReq) XXX_Unmarshal 

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

type GetRedisStatefulSetSpecReq 

type GetRedisStatefulSetSpecReq struct {
	ServiceName               string                      `protobuf:"bytes,1,opt,name=serviceName"`
	Labels                    map[string]string           `protobuf:"bytes,2,rep,name=labels"`
	RedisImage                string                      `protobuf:"bytes,3,opt,name=redisImage"`
	SentinelImage             string                      `protobuf:"bytes,4,opt,name=sentinelImage"`
	MetricsExporterImage      string                      `protobuf:"bytes,5,opt,name=metricsExporterImage"`
	InitContainerImage        string                      `protobuf:"bytes,6,opt,name=initContainerImage"`
	RedisContainerPort        int32                       `protobuf:"bytes,7,opt,name=redisContainerPort"`
	SentinelContainerPort     int32                       `protobuf:"bytes,8,opt,name=sentinelContainerPort"`
	RedisMetricsContainerPort int32                       `protobuf:"bytes,9,opt,name=redisMetricsContainerPort"`
	CredentialSecretName      string                      `protobuf:"bytes,10,opt,name=credentialSecretName"`
	TLSEnabled                bool                        `protobuf:"bytes,11,opt,name=tlsEnabled"`
	PvcNameIfNeeded           string                      `protobuf:"bytes,12,opt,name=pvcNameIfNeeded"`
	ConfConfigMapName         string                      `protobuf:"bytes,13,opt,name=confConfigMapName"`
	ScriptsConfigMapName      string                      `protobuf:"bytes,14,opt,name=scriptsConfigMapName"`
	HealthConfigMapName       string                      `protobuf:"bytes,15,opt,name=healthConfigMapName"`
	DefaultResources          corev1.ResourceRequirements `protobuf:"bytes,16,opt,name=defaultResources"`
}

func (*GetRedisStatefulSetSpecReq) DeepCopy 

func (in *GetRedisStatefulSetSpecReq) DeepCopy() *GetRedisStatefulSetSpecReq

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

func (*GetRedisStatefulSetSpecReq) DeepCopyInto 

func (in *GetRedisStatefulSetSpecReq) DeepCopyInto(out *GetRedisStatefulSetSpecReq)

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

func (*GetRedisStatefulSetSpecReq) Descriptor 

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

func (*GetRedisStatefulSetSpecReq) Marshal 

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

func (*GetRedisStatefulSetSpecReq) MarshalTo 

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

func (*GetRedisStatefulSetSpecReq) MarshalToSizedBuffer 

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

func (*GetRedisStatefulSetSpecReq) ProtoMessage 

func (*GetRedisStatefulSetSpecReq) ProtoMessage()

func (*GetRedisStatefulSetSpecReq) Reset 

func (m *GetRedisStatefulSetSpecReq) Reset()

func (*GetRedisStatefulSetSpecReq) Size 

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

func (*GetRedisStatefulSetSpecReq) String 

func (this *GetRedisStatefulSetSpecReq) String() string

func (*GetRedisStatefulSetSpecReq) Unmarshal 

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

func (*GetRedisStatefulSetSpecReq) XXX_DiscardUnknown 

func (m *GetRedisStatefulSetSpecReq) XXX_DiscardUnknown()

func (*GetRedisStatefulSetSpecReq) XXX_Marshal 

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

func (*GetRedisStatefulSetSpecReq) XXX_Merge 

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

func (*GetRedisStatefulSetSpecReq) XXX_Size 

func (m *GetRedisStatefulSetSpecReq) XXX_Size() int

func (*GetRedisStatefulSetSpecReq) XXX_Unmarshal 

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

type GetSideInputDeploymentReq added in v0.10.0 

type GetSideInputDeploymentReq struct {
	ISBSvcType       ISBSvcType                  `protobuf:"bytes,1,opt,name=isbSvcType"`
	Image            string                      `protobuf:"bytes,2,opt,name=image"`
	PullPolicy       corev1.PullPolicy           `protobuf:"bytes,3,opt,name=pullPolicy,casttype=k8s.io/api/core/v1.PullPolicy"`
	Env              []corev1.EnvVar             `protobuf:"bytes,4,rep,name=env"`
	DefaultResources corev1.ResourceRequirements `protobuf:"bytes,5,opt,name=defaultResources"`
}

func (*GetSideInputDeploymentReq) DeepCopy added in v0.10.0 

func (in *GetSideInputDeploymentReq) DeepCopy() *GetSideInputDeploymentReq

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

func (*GetSideInputDeploymentReq) DeepCopyInto added in v0.10.0 

func (in *GetSideInputDeploymentReq) DeepCopyInto(out *GetSideInputDeploymentReq)

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

func (*GetSideInputDeploymentReq) Descriptor added in v0.10.0 

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

func (*GetSideInputDeploymentReq) Marshal added in v0.10.0 

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

func (*GetSideInputDeploymentReq) MarshalTo added in v0.10.0 

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

func (*GetSideInputDeploymentReq) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetSideInputDeploymentReq) ProtoMessage added in v0.10.0 

func (*GetSideInputDeploymentReq) ProtoMessage()

func (*GetSideInputDeploymentReq) Reset added in v0.10.0 

func (m *GetSideInputDeploymentReq) Reset()

func (*GetSideInputDeploymentReq) Size added in v0.10.0 

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

func (*GetSideInputDeploymentReq) String added in v0.10.0 

func (this *GetSideInputDeploymentReq) String() string

func (*GetSideInputDeploymentReq) Unmarshal added in v0.10.0 

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

func (*GetSideInputDeploymentReq) XXX_DiscardUnknown added in v0.10.0 

func (m *GetSideInputDeploymentReq) XXX_DiscardUnknown()

func (*GetSideInputDeploymentReq) XXX_Marshal added in v0.10.0 

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

func (*GetSideInputDeploymentReq) XXX_Merge added in v0.10.0 

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

func (*GetSideInputDeploymentReq) XXX_Size added in v0.10.0 

func (m *GetSideInputDeploymentReq) XXX_Size() int

func (*GetSideInputDeploymentReq) XXX_Unmarshal added in v0.10.0 

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

type GetVertexPodSpecReq 

type GetVertexPodSpecReq struct {
	ISBSvcType          ISBSvcType                  `protobuf:"bytes,1,opt,name=isbSvcType"`
	Image               string                      `protobuf:"bytes,2,opt,name=image"`
	PullPolicy          corev1.PullPolicy           `protobuf:"bytes,3,opt,name=pullPolicy,casttype=k8s.io/api/core/v1.PullPolicy"`
	Env                 []corev1.EnvVar             `protobuf:"bytes,4,rep,name=env"`
	SideInputsStoreName string                      `protobuf:"bytes,5,opt,name=sideInputsStoreName"`
	DefaultResources    corev1.ResourceRequirements `protobuf:"bytes,6,opt,name=defaultResources"`
}

func (*GetVertexPodSpecReq) DeepCopy 

func (in *GetVertexPodSpecReq) DeepCopy() *GetVertexPodSpecReq

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

func (*GetVertexPodSpecReq) DeepCopyInto 

func (in *GetVertexPodSpecReq) DeepCopyInto(out *GetVertexPodSpecReq)

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

func (*GetVertexPodSpecReq) Descriptor 

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

func (*GetVertexPodSpecReq) Marshal 

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

func (*GetVertexPodSpecReq) MarshalTo 

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

func (*GetVertexPodSpecReq) MarshalToSizedBuffer 

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

func (*GetVertexPodSpecReq) ProtoMessage 

func (*GetVertexPodSpecReq) ProtoMessage()

func (*GetVertexPodSpecReq) Reset 

func (m *GetVertexPodSpecReq) Reset()

func (*GetVertexPodSpecReq) Size 

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

func (*GetVertexPodSpecReq) String 

func (this *GetVertexPodSpecReq) String() string

func (*GetVertexPodSpecReq) Unmarshal 

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

func (*GetVertexPodSpecReq) XXX_DiscardUnknown 

func (m *GetVertexPodSpecReq) XXX_DiscardUnknown()

func (*GetVertexPodSpecReq) XXX_Marshal 

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

func (*GetVertexPodSpecReq) XXX_Merge 

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

func (*GetVertexPodSpecReq) XXX_Size 

func (m *GetVertexPodSpecReq) XXX_Size() int

func (*GetVertexPodSpecReq) XXX_Unmarshal 

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

type GroupBy added in v0.6.1 

type GroupBy struct {
	// Window describes the windowing strategy.
	Window Window `json:"window" protobuf:"bytes,1,opt,name=window"`
	// +optional
	Keyed bool `json:"keyed" protobuf:"bytes,2,opt,name=keyed"`
	// AllowedLateness allows late data to be included for the Reduce operation as long as the late data is not later
	// than (Watermark - AllowedLateness).
	// +optional
	AllowedLateness *metav1.Duration `json:"allowedLateness,omitempty" protobuf:"bytes,3,opt,name=allowedLateness"`
	// Storage is used to define the PBQ storage for a reduce vertex.
	Storage *PBQStorage `json:"storage,omitempty" protobuf:"bytes,4,opt,name=storage"`
}

GroupBy indicates it is a reducer UDF

func (*GroupBy) DeepCopy added in v0.6.1 

func (in *GroupBy) DeepCopy() *GroupBy

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

func (*GroupBy) DeepCopyInto added in v0.6.1 

func (in *GroupBy) DeepCopyInto(out *GroupBy)

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

func (*GroupBy) Descriptor added in v0.6.1 

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

func (*GroupBy) Marshal added in v0.6.1 

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

func (*GroupBy) MarshalTo added in v0.6.1 

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

func (*GroupBy) MarshalToSizedBuffer added in v0.6.1 

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

func (*GroupBy) ProtoMessage added in v0.6.1 

func (*GroupBy) ProtoMessage()

func (*GroupBy) Reset added in v0.6.1 

func (m *GroupBy) Reset()

func (*GroupBy) Size added in v0.6.1 

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

func (*GroupBy) String added in v0.6.1 

func (this *GroupBy) String() string

func (*GroupBy) Unmarshal added in v0.6.1 

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

func (*GroupBy) XXX_DiscardUnknown added in v0.6.1 

func (m *GroupBy) XXX_DiscardUnknown()

func (*GroupBy) XXX_Marshal added in v0.6.1 

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

func (*GroupBy) XXX_Merge added in v0.6.1 

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

func (*GroupBy) XXX_Size added in v0.6.1 

func (m *GroupBy) XXX_Size() int

func (*GroupBy) XXX_Unmarshal added in v0.6.1 

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

type HTTPSource 

type HTTPSource struct {
	// +optional
	Auth *Authorization `json:"auth" protobuf:"bytes,1,opt,name=auth"`
	// Whether to create a ClusterIP Service
	// +optional
	Service bool `json:"service" protobuf:"bytes,2,opt,name=service"`
}

func (*HTTPSource) DeepCopy 

func (in *HTTPSource) DeepCopy() *HTTPSource

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

func (*HTTPSource) DeepCopyInto 

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 

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

func (*HTTPSource) Marshal 

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

func (*HTTPSource) MarshalTo 

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

func (*HTTPSource) MarshalToSizedBuffer 

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

func (*HTTPSource) ProtoMessage 

func (*HTTPSource) ProtoMessage()

func (*HTTPSource) Reset 

func (m *HTTPSource) Reset()

func (*HTTPSource) Size 

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

func (*HTTPSource) String 

func (this *HTTPSource) String() string

func (*HTTPSource) Unmarshal 

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

func (*HTTPSource) XXX_DiscardUnknown 

func (m *HTTPSource) XXX_DiscardUnknown()

func (*HTTPSource) XXX_Marshal 

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

func (*HTTPSource) XXX_Merge 

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

func (*HTTPSource) XXX_Size 

func (m *HTTPSource) XXX_Size() int

func (*HTTPSource) XXX_Unmarshal 

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

type ISBSvcPhase 

type ISBSvcPhase string

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

type ISBSvcType 

type ISBSvcType string
const (
	ISBSvcTypeUnknown   ISBSvcType = ""
	ISBSvcTypeRedis     ISBSvcType = "redis"
	ISBSvcTypeJetStream ISBSvcType = "jetstream"
)

type IdleSource added in v1.1.0 

type IdleSource struct {
	// Threshold is the duration after which a source is marked as Idle due to lack of data.
	// Ex: If watermark found to be idle after the Threshold duration then the watermark is progressed by `IncrementBy`.
	Threshold *metav1.Duration `json:"threshold,omitempty" protobuf:"bytes,1,opt,name=threshold"`
	// StepInterval is the duration between the subsequent increment of the watermark as long the source remains Idle.
	// The default value is 0s which means that once we detect idle source, we will be incrementing the watermark by
	// `IncrementBy` for time we detect that we source is empty (in other words, this will be a very frequent update).
	// +kubebuilder:default="0s"
	// +optional
	StepInterval *metav1.Duration `json:"stepInterval,omitempty" protobuf:"bytes,2,opt,name=stepInterval"`
	// IncrementBy is the duration to be added to the current watermark to progress the watermark when source is idling.
	IncrementBy *metav1.Duration `json:"incrementBy,omitempty" protobuf:"bytes,3,opt,name=incrementBy"`
}

func (*IdleSource) DeepCopy added in v1.1.0 

func (in *IdleSource) DeepCopy() *IdleSource

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

func (*IdleSource) DeepCopyInto added in v1.1.0 

func (in *IdleSource) DeepCopyInto(out *IdleSource)

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

func (*IdleSource) Descriptor added in v1.1.0 

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

func (IdleSource) GetIncrementBy added in v1.1.0 

func (is IdleSource) GetIncrementBy() time.Duration

func (IdleSource) GetStepInterval added in v1.1.0 

func (is IdleSource) GetStepInterval() time.Duration

func (IdleSource) GetThreshold added in v1.1.0 

func (is IdleSource) GetThreshold() time.Duration

func (*IdleSource) Marshal added in v1.1.0 

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

func (*IdleSource) MarshalTo added in v1.1.0 

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

func (*IdleSource) MarshalToSizedBuffer added in v1.1.0 

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

func (*IdleSource) ProtoMessage added in v1.1.0 

func (*IdleSource) ProtoMessage()

func (*IdleSource) Reset added in v1.1.0 

func (m *IdleSource) Reset()

func (*IdleSource) Size added in v1.1.0 

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

func (*IdleSource) String added in v1.1.0 

func (this *IdleSource) String() string

func (*IdleSource) Unmarshal added in v1.1.0 

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

func (*IdleSource) XXX_DiscardUnknown added in v1.1.0 

func (m *IdleSource) XXX_DiscardUnknown()

func (*IdleSource) XXX_Marshal added in v1.1.0 

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

func (*IdleSource) XXX_Merge added in v1.1.0 

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

func (*IdleSource) XXX_Size added in v1.1.0 

func (m *IdleSource) XXX_Size() int

func (*IdleSource) XXX_Unmarshal added in v1.1.0 

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

type InterStepBufferService 

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

	Spec InterStepBufferServiceSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	// +optional
	Status InterStepBufferServiceStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+genclient +kubebuilder:object:root=true +kubebuilder:resource:shortName=isbsvc +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Type",type=string,JSONPath=`.status.type` +kubebuilder:printcolumn:name="Phase",type=string,JSONPath=`.status.phase` +kubebuilder:printcolumn:name="Message",type=string,JSONPath=`.status.message` +kubebuilder:printcolumn:name="Age",type=date,JSONPath=`.metadata.creationTimestamp` +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true

func (*InterStepBufferService) DeepCopy 

func (in *InterStepBufferService) DeepCopy() *InterStepBufferService

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

func (*InterStepBufferService) DeepCopyInto 

func (in *InterStepBufferService) DeepCopyInto(out *InterStepBufferService)

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

func (*InterStepBufferService) DeepCopyObject 

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

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

func (*InterStepBufferService) Descriptor 

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

func (*InterStepBufferService) Marshal 

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

func (*InterStepBufferService) MarshalTo 

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

func (*InterStepBufferService) MarshalToSizedBuffer 

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

func (*InterStepBufferService) ProtoMessage 

func (*InterStepBufferService) ProtoMessage()

func (*InterStepBufferService) Reset 

func (m *InterStepBufferService) Reset()

func (*InterStepBufferService) Size 

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

func (*InterStepBufferService) String 

func (this *InterStepBufferService) String() string

func (*InterStepBufferService) Unmarshal 

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

func (*InterStepBufferService) XXX_DiscardUnknown 

func (m *InterStepBufferService) XXX_DiscardUnknown()

func (*InterStepBufferService) XXX_Marshal 

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

func (*InterStepBufferService) XXX_Merge 

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

func (*InterStepBufferService) XXX_Size 

func (m *InterStepBufferService) XXX_Size() int

func (*InterStepBufferService) XXX_Unmarshal 

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

type InterStepBufferServiceList 

type InterStepBufferServiceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`

	Items []InterStepBufferService `json:"items" protobuf:"bytes,2,rep,name=items"`
}

InterStepBufferServiceList is the list of InterStepBufferService resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*InterStepBufferServiceList) DeepCopy 

func (in *InterStepBufferServiceList) DeepCopy() *InterStepBufferServiceList

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

func (*InterStepBufferServiceList) DeepCopyInto 

func (in *InterStepBufferServiceList) DeepCopyInto(out *InterStepBufferServiceList)

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

func (*InterStepBufferServiceList) DeepCopyObject 

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

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

func (*InterStepBufferServiceList) Descriptor 

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

func (*InterStepBufferServiceList) Marshal 

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

func (*InterStepBufferServiceList) MarshalTo 

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

func (*InterStepBufferServiceList) MarshalToSizedBuffer 

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

func (*InterStepBufferServiceList) ProtoMessage 

func (*InterStepBufferServiceList) ProtoMessage()

func (*InterStepBufferServiceList) Reset 

func (m *InterStepBufferServiceList) Reset()

func (*InterStepBufferServiceList) Size 

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

func (*InterStepBufferServiceList) String 

func (this *InterStepBufferServiceList) String() string

func (*InterStepBufferServiceList) Unmarshal 

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

func (*InterStepBufferServiceList) XXX_DiscardUnknown 

func (m *InterStepBufferServiceList) XXX_DiscardUnknown()

func (*InterStepBufferServiceList) XXX_Marshal 

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

func (*InterStepBufferServiceList) XXX_Merge 

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

func (*InterStepBufferServiceList) XXX_Size 

func (m *InterStepBufferServiceList) XXX_Size() int

func (*InterStepBufferServiceList) XXX_Unmarshal 

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

type InterStepBufferServiceSpec 

type InterStepBufferServiceSpec struct {
	Redis     *RedisBufferService     `json:"redis,omitempty" protobuf:"bytes,1,opt,name=redis"`
	JetStream *JetStreamBufferService `json:"jetstream,omitempty" protobuf:"bytes,2,opt,name=jetstream"`
}

func (*InterStepBufferServiceSpec) DeepCopy 

func (in *InterStepBufferServiceSpec) DeepCopy() *InterStepBufferServiceSpec

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

func (*InterStepBufferServiceSpec) DeepCopyInto 

func (in *InterStepBufferServiceSpec) DeepCopyInto(out *InterStepBufferServiceSpec)

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

func (*InterStepBufferServiceSpec) Descriptor 

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

func (*InterStepBufferServiceSpec) Marshal 

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

func (*InterStepBufferServiceSpec) MarshalTo 

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

func (*InterStepBufferServiceSpec) MarshalToSizedBuffer 

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

func (*InterStepBufferServiceSpec) ProtoMessage 

func (*InterStepBufferServiceSpec) ProtoMessage()

func (*InterStepBufferServiceSpec) Reset 

func (m *InterStepBufferServiceSpec) Reset()

func (*InterStepBufferServiceSpec) Size 

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

func (*InterStepBufferServiceSpec) String 

func (this *InterStepBufferServiceSpec) String() string

func (*InterStepBufferServiceSpec) Unmarshal 

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

func (*InterStepBufferServiceSpec) XXX_DiscardUnknown 

func (m *InterStepBufferServiceSpec) XXX_DiscardUnknown()

func (*InterStepBufferServiceSpec) XXX_Marshal 

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

func (*InterStepBufferServiceSpec) XXX_Merge 

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

func (*InterStepBufferServiceSpec) XXX_Size 

func (m *InterStepBufferServiceSpec) XXX_Size() int

func (*InterStepBufferServiceSpec) XXX_Unmarshal 

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

type InterStepBufferServiceStatus 

type InterStepBufferServiceStatus struct {
	Status  `json:",inline" protobuf:"bytes,1,opt,name=status"`
	Phase   ISBSvcPhase         `json:"phase,omitempty" protobuf:"bytes,2,opt,name=phase,casttype=ISBSvcPhase"`
	Message string              `json:"message,omitempty" protobuf:"bytes,3,opt,name=message"`
	Config  BufferServiceConfig `json:"config,omitempty" protobuf:"bytes,4,opt,name=config"`
	Type    ISBSvcType          `json:"type,omitempty" protobuf:"bytes,5,opt,name=type"`
}

func (*InterStepBufferServiceStatus) DeepCopy 

func (in *InterStepBufferServiceStatus) DeepCopy() *InterStepBufferServiceStatus

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

func (*InterStepBufferServiceStatus) DeepCopyInto 

func (in *InterStepBufferServiceStatus) DeepCopyInto(out *InterStepBufferServiceStatus)

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

func (*InterStepBufferServiceStatus) Descriptor 

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

func (*InterStepBufferServiceStatus) InitConditions 

func (isbsvc *InterStepBufferServiceStatus) InitConditions()

InitConditions sets conditions to Unknown state.

func (*InterStepBufferServiceStatus) MarkConfigured 

func (isbsvc *InterStepBufferServiceStatus) MarkConfigured()

MarkConfigured set the InterStepBufferService has valid configuration.

func (*InterStepBufferServiceStatus) MarkDeployFailed 

func (isbsvc *InterStepBufferServiceStatus) MarkDeployFailed(reason, message string)

MarkDeployFailed set the InterStepBufferService deployment failed

func (*InterStepBufferServiceStatus) MarkDeployed 

func (isbsvc *InterStepBufferServiceStatus) MarkDeployed()

MarkDeployed set the InterStepBufferService has been deployed.

func (*InterStepBufferServiceStatus) MarkNotConfigured 

func (isbsvc *InterStepBufferServiceStatus) MarkNotConfigured(reason, message string)

MarkNotConfigured the InterStepBufferService has configuration.

func (*InterStepBufferServiceStatus) Marshal 

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

func (*InterStepBufferServiceStatus) MarshalTo 

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

func (*InterStepBufferServiceStatus) MarshalToSizedBuffer 

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

func (*InterStepBufferServiceStatus) ProtoMessage 

func (*InterStepBufferServiceStatus) ProtoMessage()

func (*InterStepBufferServiceStatus) Reset 

func (m *InterStepBufferServiceStatus) Reset()

func (*InterStepBufferServiceStatus) SetPhase 

func (isbsvc *InterStepBufferServiceStatus) SetPhase(phase ISBSvcPhase, msg string)

func (*InterStepBufferServiceStatus) SetType added in v0.6.1 

func (isbsvc *InterStepBufferServiceStatus) SetType(typ ISBSvcType)

func (*InterStepBufferServiceStatus) Size 

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

func (*InterStepBufferServiceStatus) String 

func (this *InterStepBufferServiceStatus) String() string

func (*InterStepBufferServiceStatus) Unmarshal 

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

func (*InterStepBufferServiceStatus) XXX_DiscardUnknown 

func (m *InterStepBufferServiceStatus) XXX_DiscardUnknown()

func (*InterStepBufferServiceStatus) XXX_Marshal 

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

func (*InterStepBufferServiceStatus) XXX_Merge 

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

func (*InterStepBufferServiceStatus) XXX_Size 

func (m *InterStepBufferServiceStatus) XXX_Size() int

func (*InterStepBufferServiceStatus) XXX_Unmarshal 

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

type JetStreamBufferService 

type JetStreamBufferService struct {
	// JetStream version, such as "2.7.1"
	Version string `json:"version,omitempty" protobuf:"bytes,1,opt,name=version"`
	// Redis StatefulSet size
	// +kubebuilder:default=3
	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,2,opt,name=replicas"`
	// ContainerTemplate contains customized spec for NATS container
	// +optional
	ContainerTemplate *ContainerTemplate `json:"containerTemplate,omitempty" protobuf:"bytes,3,opt,name=containerTemplate"`
	// ReloaderContainerTemplate contains customized spec for config reloader container
	// +optional
	ReloaderContainerTemplate *ContainerTemplate `json:"reloaderContainerTemplate,omitempty" protobuf:"bytes,4,opt,name=reloaderContainerTemplate"`
	// MetricsContainerTemplate contains customized spec for metrics container
	// +optional
	MetricsContainerTemplate *ContainerTemplate `json:"metricsContainerTemplate,omitempty" protobuf:"bytes,5,opt,name=metricsContainerTemplate"`
	// +optional
	Persistence *PersistenceStrategy `json:"persistence,omitempty" protobuf:"bytes,6,opt,name=persistence"`
	// +optional
	AbstractPodTemplate `json:",inline" protobuf:"bytes,7,opt,name=abstractPodTemplate"`
	// Nats/JetStream configuration, if not specified, global settings in numaflow-controller-config will be used.
	// See https://docs.nats.io/running-a-nats-service/configuration#limits and https://docs.nats.io/running-a-nats-service/configuration#jetstream.
	// For limits, only "max_payload" is supported for configuration, defaults to 1048576 (1MB), not recommended to use values over 8388608 (8MB) but max_payload can be set up to 67108864 (64MB).
	// For jetstream, only "max_memory_store" and "max_file_store" are supported for configuration, do not set "store_dir" as it has been hardcoded.
	// +optional
	Settings *string `json:"settings,omitempty" protobuf:"bytes,8,opt,name=settings"`
	// Optional arguments to start nats-server. For example, "-D" to enable debugging output, "-DV" to enable debugging and tracing.
	// Check https://docs.nats.io/ for all the available arguments.
	// +optional
	StartArgs []string `json:"startArgs,omitempty" protobuf:"bytes,9,rep,name=startArgs"`
	// Optional configuration for the streams, consumers and buckets to be created in this JetStream service, if specified, it will be merged with the default configuration in numaflow-controller-config.
	// It accepts a YAML format configuration, it may include 4 sections, "stream", "consumer", "otBucket" and "procBucket".
	// Available fields under "stream" include "retention" (e.g. interest, limits, workerQueue), "maxMsgs", "maxAge" (e.g. 72h), "replicas" (1, 3, 5), "duplicates" (e.g. 5m).
	// Available fields under "consumer" include "ackWait" (e.g. 60s)
	// Available fields under "otBucket" include "maxValueSize", "history", "ttl" (e.g. 72h), "maxBytes", "replicas" (1, 3, 5).
	// Available fields under "procBucket" include "maxValueSize", "history", "ttl" (e.g. 72h), "maxBytes", "replicas" (1, 3, 5).
	// +optional
	BufferConfig *string `json:"bufferConfig,omitempty" protobuf:"bytes,10,opt,name=bufferConfig"`
	// Whether encrypt the data at rest, defaults to false
	// Enabling encryption might impact the performance, see https://docs.nats.io/running-a-nats-service/nats_admin/jetstream_admin/encryption_at_rest for the detail
	// Toggling the value will impact encrypting/decrypting existing messages.
	// +optional
	Encryption bool `json:"encryption,omitempty" protobuf:"bytes,11,opt,name=encryption"`
	// Whether enable TLS, defaults to false
	// Enabling TLS might impact the performance
	// +optional
	TLS bool `json:"tls,omitempty" protobuf:"bytes,12,opt,name=tls"`
}

func (*JetStreamBufferService) DeepCopy 

func (in *JetStreamBufferService) DeepCopy() *JetStreamBufferService

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

func (*JetStreamBufferService) DeepCopyInto 

func (in *JetStreamBufferService) DeepCopyInto(out *JetStreamBufferService)

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

func (*JetStreamBufferService) Descriptor 

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

func (JetStreamBufferService) GetReplicas 

func (j JetStreamBufferService) GetReplicas() int

func (JetStreamBufferService) GetServiceSpec 

func (j JetStreamBufferService) GetServiceSpec(req GetJetStreamServiceSpecReq) corev1.ServiceSpec

func (JetStreamBufferService) GetStatefulSetSpec 

func (j JetStreamBufferService) GetStatefulSetSpec(req GetJetStreamStatefulSetSpecReq) appv1.StatefulSetSpec

func (*JetStreamBufferService) Marshal 

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

func (*JetStreamBufferService) MarshalTo 

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

func (*JetStreamBufferService) MarshalToSizedBuffer 

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

func (*JetStreamBufferService) ProtoMessage 

func (*JetStreamBufferService) ProtoMessage()

func (*JetStreamBufferService) Reset 

func (m *JetStreamBufferService) Reset()

func (*JetStreamBufferService) Size 

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

func (*JetStreamBufferService) String 

func (this *JetStreamBufferService) String() string

func (*JetStreamBufferService) Unmarshal 

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

func (*JetStreamBufferService) XXX_DiscardUnknown 

func (m *JetStreamBufferService) XXX_DiscardUnknown()

func (*JetStreamBufferService) XXX_Marshal 

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

func (*JetStreamBufferService) XXX_Merge 

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

func (*JetStreamBufferService) XXX_Size 

func (m *JetStreamBufferService) XXX_Size() int

func (*JetStreamBufferService) XXX_Unmarshal 

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

type JetStreamConfig 

type JetStreamConfig struct {
	// JetStream (NATS) URL
	URL  string    `json:"url,omitempty" protobuf:"bytes,1,opt,name=url"`
	Auth *NatsAuth `json:"auth,omitempty" protobuf:"bytes,2,opt,name=auth"`
	// +optional
	StreamConfig string `json:"streamConfig,omitempty" protobuf:"bytes,3,opt,name=streamConfig"`
	// TLS enabled or not
	TLSEnabled bool `json:"tlsEnabled,omitempty" protobuf:"bytes,4,opt,name=tlsEnabled"`
}

func (*JetStreamConfig) DeepCopy 

func (in *JetStreamConfig) DeepCopy() *JetStreamConfig

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

func (*JetStreamConfig) DeepCopyInto 

func (in *JetStreamConfig) DeepCopyInto(out *JetStreamConfig)

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

func (*JetStreamConfig) Descriptor 

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

func (*JetStreamConfig) Marshal 

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

func (*JetStreamConfig) MarshalTo 

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

func (*JetStreamConfig) MarshalToSizedBuffer 

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

func (*JetStreamConfig) ProtoMessage 

func (*JetStreamConfig) ProtoMessage()

func (*JetStreamConfig) Reset 

func (m *JetStreamConfig) Reset()

func (*JetStreamConfig) Size 

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

func (*JetStreamConfig) String 

func (this *JetStreamConfig) String() string

func (*JetStreamConfig) Unmarshal 

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

func (*JetStreamConfig) XXX_DiscardUnknown 

func (m *JetStreamConfig) XXX_DiscardUnknown()

func (*JetStreamConfig) XXX_Marshal 

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

func (*JetStreamConfig) XXX_Merge 

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

func (*JetStreamConfig) XXX_Size 

func (m *JetStreamConfig) XXX_Size() int

func (*JetStreamConfig) XXX_Unmarshal 

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

type JobTemplate added in v0.6.2 

type JobTemplate struct {
	// +optional
	AbstractPodTemplate `json:",inline" protobuf:"bytes,1,opt,name=abstractPodTemplate"`
	// +optional
	ContainerTemplate *ContainerTemplate `json:"containerTemplate,omitempty" protobuf:"bytes,2,opt,name=containerTemplate"`
	// ttlSecondsAfterFinished limits the lifetime of a Job that has finished
	// execution (either Complete or Failed). If this field is set,
	// ttlSecondsAfterFinished after the Job finishes, it is eligible to be
	// automatically deleted. When the Job is being deleted, its lifecycle
	// guarantees (e.g. finalizers) will be honored. If this field is unset,
	// the Job won't be automatically deleted. If this field is set to zero,
	// the Job becomes eligible to be deleted immediately after it finishes.
	// Numaflow defaults to 30
	// +optional
	TTLSecondsAfterFinished *int32 `json:"ttlSecondsAfterFinished,omitempty" protobuf:"varint,3,opt,name=ttlSecondsAfterFinished"`
	// Specifies the number of retries before marking this job failed.
	// More info: https://kubernetes.io/docs/concepts/workloads/controllers/job/#pod-backoff-failure-policy
	// Numaflow defaults to 20
	// +optional
	BackoffLimit *int32 `json:"backoffLimit,omitempty" protobuf:"varint,4,opt,name=backoffLimit"`
}

func (*JobTemplate) DeepCopy added in v0.6.2 

func (in *JobTemplate) DeepCopy() *JobTemplate

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

func (*JobTemplate) DeepCopyInto added in v0.6.2 

func (in *JobTemplate) DeepCopyInto(out *JobTemplate)

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

func (*JobTemplate) Descriptor added in v0.6.2 

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

func (*JobTemplate) Marshal added in v0.6.2 

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

func (*JobTemplate) MarshalTo added in v0.6.2 

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

func (*JobTemplate) MarshalToSizedBuffer added in v0.6.2 

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

func (*JobTemplate) ProtoMessage added in v0.6.2 

func (*JobTemplate) ProtoMessage()

func (*JobTemplate) Reset added in v0.6.2 

func (m *JobTemplate) Reset()

func (*JobTemplate) Size added in v0.6.2 

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

func (*JobTemplate) String added in v0.6.2 

func (this *JobTemplate) String() string

func (*JobTemplate) Unmarshal added in v0.6.2 

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

func (*JobTemplate) XXX_DiscardUnknown added in v0.6.2 

func (m *JobTemplate) XXX_DiscardUnknown()

func (*JobTemplate) XXX_Marshal added in v0.6.2 

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

func (*JobTemplate) XXX_Merge added in v0.6.2 

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

func (*JobTemplate) XXX_Size added in v0.6.2 

func (m *JobTemplate) XXX_Size() int

func (*JobTemplate) XXX_Unmarshal added in v0.6.2 

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

type KRB5AuthType added in v0.7.3 

type KRB5AuthType string

KRB5AuthType describes the kerberos auth type +enum 

const (
	// KRB5UserAuth represents the password method
	// KRB5UserAuth = "KRB5_USER_AUTH" = 1
	KRB5UserAuth KRB5AuthType = "KRB5_USER_AUTH"
	// KRB5KeytabAuth represents the password method
	// KRB5KeytabAuth = "KRB5_KEYTAB_AUTH" = 2
	KRB5KeytabAuth KRB5AuthType = "KRB5_KEYTAB_AUTH"
)

type KafkaSink 

type KafkaSink struct {
	Brokers []string `json:"brokers,omitempty" protobuf:"bytes,1,rep,name=brokers"`
	Topic   string   `json:"topic" protobuf:"bytes,2,opt,name=topic"`
	// TLS user to configure TLS connection for kafka broker
	// TLS.enable=true default for TLS.
	// +optional
	TLS *TLS `json:"tls" protobuf:"bytes,3,opt,name=tls"`
	// +optional
	Config string `json:"config,omitempty" protobuf:"bytes,4,opt,name=config"`
	// SASL user to configure SASL connection for kafka broker
	// SASL.enable=true default for SASL.
	// +optional
	SASL *SASL `json:"sasl" protobuf:"bytes,5,opt,name=sasl"`
}

func (*KafkaSink) DeepCopy 

func (in *KafkaSink) DeepCopy() *KafkaSink

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

func (*KafkaSink) DeepCopyInto 

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 

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

func (*KafkaSink) Marshal 

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

func (*KafkaSink) MarshalTo 

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

func (*KafkaSink) MarshalToSizedBuffer 

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

func (*KafkaSink) ProtoMessage 

func (*KafkaSink) ProtoMessage()

func (*KafkaSink) Reset 

func (m *KafkaSink) Reset()

func (*KafkaSink) Size 

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

func (*KafkaSink) String 

func (this *KafkaSink) String() string

func (*KafkaSink) Unmarshal 

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

func (*KafkaSink) XXX_DiscardUnknown 

func (m *KafkaSink) XXX_DiscardUnknown()

func (*KafkaSink) XXX_Marshal 

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

func (*KafkaSink) XXX_Merge 

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

func (*KafkaSink) XXX_Size 

func (m *KafkaSink) XXX_Size() int

func (*KafkaSink) XXX_Unmarshal 

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

type KafkaSource 

type KafkaSource struct {
	Brokers           []string `json:"brokers,omitempty" protobuf:"bytes,1,rep,name=brokers"`
	Topic             string   `json:"topic" protobuf:"bytes,2,opt,name=topic"`
	ConsumerGroupName string   `json:"consumerGroup,omitempty" protobuf:"bytes,3,opt,name=consumerGroup"`
	// TLS user to configure TLS connection for kafka broker
	// TLS.enable=true default for TLS.
	// +optional
	TLS *TLS `json:"tls" protobuf:"bytes,4,opt,name=tls"`
	// +optional
	Config string `json:"config,omitempty" protobuf:"bytes,5,opt,name=config"`
	// SASL user to configure SASL connection for kafka broker
	// SASL.enable=true default for SASL.
	// +optional
	SASL *SASL `json:"sasl" protobuf:"bytes,6,opt,name=sasl"`
}

func (*KafkaSource) DeepCopy 

func (in *KafkaSource) DeepCopy() *KafkaSource

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

func (*KafkaSource) DeepCopyInto 

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 

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

func (*KafkaSource) Marshal 

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

func (*KafkaSource) MarshalTo 

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

func (*KafkaSource) MarshalToSizedBuffer 

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

func (*KafkaSource) ProtoMessage 

func (*KafkaSource) ProtoMessage()

func (*KafkaSource) Reset 

func (m *KafkaSource) Reset()

func (*KafkaSource) Size 

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

func (*KafkaSource) String 

func (this *KafkaSource) String() string

func (*KafkaSource) Unmarshal 

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

func (*KafkaSource) XXX_DiscardUnknown 

func (m *KafkaSource) XXX_DiscardUnknown()

func (*KafkaSource) XXX_Marshal 

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

func (*KafkaSource) XXX_Merge 

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

func (*KafkaSource) XXX_Size 

func (m *KafkaSource) XXX_Size() int

func (*KafkaSource) XXX_Unmarshal 

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

type Lifecycle 

type Lifecycle struct {
	// DeleteGracePeriodSeconds used to delete pipeline gracefully
	// +kubebuilder:default=30
	// +optional
	DeleteGracePeriodSeconds *int32 `json:"deleteGracePeriodSeconds,omitempty" protobuf:"varint,1,opt,name=deleteGracePeriodSeconds"`
	// DesiredPhase used to bring the pipeline from current phase to desired phase
	// +kubebuilder:default=Running
	// +optional
	DesiredPhase PipelinePhase `json:"desiredPhase,omitempty" protobuf:"bytes,2,opt,name=desiredPhase"`
	// PauseGracePeriodSeconds used to pause pipeline gracefully
	// +kubebuilder:default=30
	// +optional
	PauseGracePeriodSeconds *int32 `json:"pauseGracePeriodSeconds,omitempty" protobuf:"varint,3,opt,name=pauseGracePeriodSeconds"`
}

func (*Lifecycle) DeepCopy 

func (in *Lifecycle) DeepCopy() *Lifecycle

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

func (*Lifecycle) DeepCopyInto 

func (in *Lifecycle) DeepCopyInto(out *Lifecycle)

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

func (*Lifecycle) Descriptor 

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

func (Lifecycle) GetDeleteGracePeriodSeconds added in v0.6.1 

func (lc Lifecycle) GetDeleteGracePeriodSeconds() int32

GetDeleteGracePeriodSeconds returns the value DeleteGracePeriodSeconds.

func (Lifecycle) GetDesiredPhase added in v0.6.1 

func (lc Lifecycle) GetDesiredPhase() PipelinePhase

func (Lifecycle) GetPauseGracePeriodSeconds added in v0.11.0 

func (lc Lifecycle) GetPauseGracePeriodSeconds() int32

return PauseGracePeriodSeconds if set

func (*Lifecycle) Marshal 

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

func (*Lifecycle) MarshalTo 

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

func (*Lifecycle) MarshalToSizedBuffer 

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

func (*Lifecycle) ProtoMessage 

func (*Lifecycle) ProtoMessage()

func (*Lifecycle) Reset 

func (m *Lifecycle) Reset()

func (*Lifecycle) Size 

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

func (*Lifecycle) String 

func (this *Lifecycle) String() string

func (*Lifecycle) Unmarshal 

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

func (*Lifecycle) XXX_DiscardUnknown 

func (m *Lifecycle) XXX_DiscardUnknown()

func (*Lifecycle) XXX_Marshal 

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

func (*Lifecycle) XXX_Merge 

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

func (*Lifecycle) XXX_Size 

func (m *Lifecycle) XXX_Size() int

func (*Lifecycle) XXX_Unmarshal 

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

type Log 

type Log struct {
}

func (*Log) DeepCopy 

func (in *Log) DeepCopy() *Log

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

func (*Log) DeepCopyInto 

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

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

func (*Log) Descriptor 

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

func (*Log) Marshal 

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

func (*Log) MarshalTo 

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

func (*Log) MarshalToSizedBuffer 

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

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) Reset 

func (m *Log) Reset()

func (*Log) Size 

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

func (*Log) String 

func (this *Log) String() string

func (*Log) Unmarshal 

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

func (*Log) XXX_DiscardUnknown 

func (m *Log) XXX_DiscardUnknown()

func (*Log) XXX_Marshal 

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

func (*Log) XXX_Merge 

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

func (*Log) XXX_Size 

func (m *Log) XXX_Size() int

func (*Log) XXX_Unmarshal 

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

type LogicOperator added in v0.8.0 

type LogicOperator string
const (
	LogicOperatorAnd LogicOperator = "and"
	LogicOperatorOr  LogicOperator = "or"
	LogicOperatorNot LogicOperator = "not"
)

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 NativeRedis 

type NativeRedis struct {
	// Redis version, such as "6.0.16"
	Version string `json:"version,omitempty" protobuf:"bytes,1,opt,name=version"`
	// Redis StatefulSet size
	// +kubebuilder:default=3
	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,2,opt,name=replicas"`
	// RedisContainerTemplate contains customized spec for Redis container
	// +optional
	RedisContainerTemplate *ContainerTemplate `json:"redisContainerTemplate,omitempty" protobuf:"bytes,3,opt,name=redisContainerTemplate"`
	// SentinelContainerTemplate contains customized spec for Redis container
	// +optional
	SentinelContainerTemplate *ContainerTemplate `json:"sentinelContainerTemplate,omitempty" protobuf:"bytes,4,opt,name=sentinelContainerTemplate"`
	// MetricsContainerTemplate contains customized spec for metrics container
	// +optional
	MetricsContainerTemplate *ContainerTemplate `json:"metricsContainerTemplate,omitempty" protobuf:"bytes,5,opt,name=metricsContainerTemplate"`
	// +optional
	InitContainerTemplate *ContainerTemplate `json:"initContainerTemplate,omitempty" protobuf:"bytes,6,opt,name=initContainerTemplate"`
	// +optional
	Persistence *PersistenceStrategy `json:"persistence,omitempty" protobuf:"bytes,7,opt,name=persistence"`
	// +optional
	AbstractPodTemplate `json:",inline" protobuf:"bytes,8,opt,name=abstractPodTemplate"`
	// Redis configuration, if not specified, global settings in numaflow-controller-config will be used.
	// +optional
	Settings *RedisSettings `json:"settings,omitempty" protobuf:"bytes,9,opt,name=settings"`
}

func (*NativeRedis) DeepCopy 

func (in *NativeRedis) DeepCopy() *NativeRedis

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

func (*NativeRedis) DeepCopyInto 

func (in *NativeRedis) DeepCopyInto(out *NativeRedis)

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

func (*NativeRedis) Descriptor 

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

func (NativeRedis) GetHeadlessServiceSpec 

func (nr NativeRedis) GetHeadlessServiceSpec(req GetRedisServiceSpecReq) corev1.ServiceSpec

func (NativeRedis) GetReplicas 

func (nr NativeRedis) GetReplicas() int

func (NativeRedis) GetServiceSpec 

func (nr NativeRedis) GetServiceSpec(req GetRedisServiceSpecReq) corev1.ServiceSpec

func (NativeRedis) GetStatefulSetSpec 

func (nr NativeRedis) GetStatefulSetSpec(req GetRedisStatefulSetSpecReq) appv1.StatefulSetSpec

func (*NativeRedis) Marshal 

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

func (*NativeRedis) MarshalTo 

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

func (*NativeRedis) MarshalToSizedBuffer 

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

func (*NativeRedis) ProtoMessage 

func (*NativeRedis) ProtoMessage()

func (*NativeRedis) Reset 

func (m *NativeRedis) Reset()

func (*NativeRedis) Size 

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

func (*NativeRedis) String 

func (this *NativeRedis) String() string

func (*NativeRedis) Unmarshal 

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

func (*NativeRedis) XXX_DiscardUnknown 

func (m *NativeRedis) XXX_DiscardUnknown()

func (*NativeRedis) XXX_Marshal 

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

func (*NativeRedis) XXX_Merge 

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

func (*NativeRedis) XXX_Size 

func (m *NativeRedis) XXX_Size() int

func (*NativeRedis) XXX_Unmarshal 

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

type NatsAuth added in v0.7.0 

type NatsAuth struct {
	// Basic auth which contains a user name and a password
	// +optional
	Basic *BasicAuth `json:"basic,omitempty" protobuf:"bytes,1,opt,name=basic"`
	// Token auth
	// +optional
	Token *corev1.SecretKeySelector `json:"token,omitempty" protobuf:"bytes,2,opt,name=token"`
	// NKey auth
	// +optional
	NKey *corev1.SecretKeySelector `json:"nkey,omitempty" protobuf:"bytes,3,opt,name=nkey"`
}

NatsAuth defines how to authenticate the nats access

func (*NatsAuth) DeepCopy added in v0.7.0 

func (in *NatsAuth) DeepCopy() *NatsAuth

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

func (*NatsAuth) DeepCopyInto added in v0.7.0 

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.7.0 

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

func (*NatsAuth) Marshal added in v0.7.0 

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

func (*NatsAuth) MarshalTo added in v0.7.0 

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

func (*NatsAuth) MarshalToSizedBuffer added in v0.7.0 

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

func (*NatsAuth) ProtoMessage added in v0.7.0 

func (*NatsAuth) ProtoMessage()

func (*NatsAuth) Reset added in v0.7.0 

func (m *NatsAuth) Reset()

func (*NatsAuth) Size added in v0.7.0 

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

func (*NatsAuth) String added in v0.7.0 

func (this *NatsAuth) String() string

func (*NatsAuth) Unmarshal added in v0.7.0 

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

func (*NatsAuth) XXX_DiscardUnknown added in v0.7.0 

func (m *NatsAuth) XXX_DiscardUnknown()

func (*NatsAuth) XXX_Marshal added in v0.7.0 

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

func (*NatsAuth) XXX_Merge added in v0.7.0 

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

func (*NatsAuth) XXX_Size added in v0.7.0 

func (m *NatsAuth) XXX_Size() int

func (*NatsAuth) XXX_Unmarshal added in v0.7.0 

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

type NatsSource added in v0.7.0 

type NatsSource struct {
	// URL to connect to NATS cluster, multiple urls could be separated by comma.
	URL string `json:"url" protobuf:"bytes,1,opt,name=url"`
	// Subject holds the name of the subject onto which messages are published.
	Subject string `json:"subject" protobuf:"bytes,2,opt,name=subject"`
	// Queue is used for queue subscription.
	Queue string `json:"queue" protobuf:"bytes,3,opt,name=queue"`
	// TLS configuration for the nats client.
	// +optional
	TLS *TLS `json:"tls" protobuf:"bytes,4,opt,name=tls"`
	// Auth information
	// +optional
	Auth *NatsAuth `json:"auth,omitempty" protobuf:"bytes,5,opt,name=auth"`
}

func (*NatsSource) DeepCopy added in v0.7.0 

func (in *NatsSource) DeepCopy() *NatsSource

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

func (*NatsSource) DeepCopyInto added in v0.7.0 

func (in *NatsSource) DeepCopyInto(out *NatsSource)

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

func (*NatsSource) Descriptor added in v0.7.0 

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

func (*NatsSource) Marshal added in v0.7.0 

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

func (*NatsSource) MarshalTo added in v0.7.0 

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

func (*NatsSource) MarshalToSizedBuffer added in v0.7.0 

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

func (*NatsSource) ProtoMessage added in v0.7.0 

func (*NatsSource) ProtoMessage()

func (*NatsSource) Reset added in v0.7.0 

func (m *NatsSource) Reset()

func (*NatsSource) Size added in v0.7.0 

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

func (*NatsSource) String added in v0.7.0 

func (this *NatsSource) String() string

func (*NatsSource) Unmarshal added in v0.7.0 

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

func (*NatsSource) XXX_DiscardUnknown added in v0.7.0 

func (m *NatsSource) XXX_DiscardUnknown()

func (*NatsSource) XXX_Marshal added in v0.7.0 

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

func (*NatsSource) XXX_Merge added in v0.7.0 

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

func (*NatsSource) XXX_Size added in v0.7.0 

func (m *NatsSource) XXX_Size() int

func (*NatsSource) XXX_Unmarshal added in v0.7.0 

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

type PBQStorage added in v0.6.2 

type PBQStorage struct {
	// +optional
	PersistentVolumeClaim *PersistenceStrategy `json:"persistentVolumeClaim,omitempty" protobuf:"bytes,1,opt,name=persistentVolumeClaim"`
	// +optional
	EmptyDir *corev1.EmptyDirVolumeSource `json:"emptyDir,omitempty" protobuf:"bytes,2,opt,name=emptyDir"`
}

PBQStorage defines the persistence configuration for a vertex.

func (*PBQStorage) DeepCopy added in v0.6.2 

func (in *PBQStorage) DeepCopy() *PBQStorage

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

func (*PBQStorage) DeepCopyInto added in v0.6.2 

func (in *PBQStorage) DeepCopyInto(out *PBQStorage)

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

func (*PBQStorage) Descriptor added in v0.6.2 

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

func (*PBQStorage) Marshal added in v0.6.2 

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

func (*PBQStorage) MarshalTo added in v0.6.2 

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

func (*PBQStorage) MarshalToSizedBuffer added in v0.6.2 

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

func (*PBQStorage) ProtoMessage added in v0.6.2 

func (*PBQStorage) ProtoMessage()

func (*PBQStorage) Reset added in v0.6.2 

func (m *PBQStorage) Reset()

func (*PBQStorage) Size added in v0.6.2 

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

func (*PBQStorage) String added in v0.6.2 

func (this *PBQStorage) String() string

func (*PBQStorage) Unmarshal added in v0.6.2 

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

func (*PBQStorage) XXX_DiscardUnknown added in v0.6.2 

func (m *PBQStorage) XXX_DiscardUnknown()

func (*PBQStorage) XXX_Marshal added in v0.6.2 

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

func (*PBQStorage) XXX_Merge added in v0.6.2 

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

func (*PBQStorage) XXX_Size added in v0.6.2 

func (m *PBQStorage) XXX_Size() int

func (*PBQStorage) XXX_Unmarshal added in v0.6.2 

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

type PersistenceStrategy 

type PersistenceStrategy struct {
	// Name of the StorageClass required by the claim.
	// More info: https://kubernetes.io/docs/concepts/storage/persistent-volumes#class-1
	// +optional
	StorageClassName *string `json:"storageClassName,omitempty" protobuf:"bytes,1,opt,name=storageClassName"`
	// Available access modes such as ReadWriteOnce, ReadWriteMany
	// https://kubernetes.io/docs/concepts/storage/persistent-volumes/#access-modes
	// +optional
	AccessMode *corev1.PersistentVolumeAccessMode `json:"accessMode,omitempty" protobuf:"bytes,2,opt,name=accessMode,casttype=k8s.io/api/core/v1.PersistentVolumeAccessMode"`
	// Volume size, e.g. 50Gi
	VolumeSize *apiresource.Quantity `json:"volumeSize,omitempty" protobuf:"bytes,3,opt,name=volumeSize"`
}

PersistenceStrategy defines the strategy of persistence

func (*PersistenceStrategy) DeepCopy 

func (in *PersistenceStrategy) DeepCopy() *PersistenceStrategy

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

func (*PersistenceStrategy) DeepCopyInto 

func (in *PersistenceStrategy) DeepCopyInto(out *PersistenceStrategy)

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

func (*PersistenceStrategy) Descriptor 

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

func (PersistenceStrategy) GetPVCSpec added in v0.6.2 

func (ps PersistenceStrategy) GetPVCSpec(name string) corev1.PersistentVolumeClaim

func (*PersistenceStrategy) Marshal 

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

func (*PersistenceStrategy) MarshalTo 

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

func (*PersistenceStrategy) MarshalToSizedBuffer 

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

func (*PersistenceStrategy) ProtoMessage 

func (*PersistenceStrategy) ProtoMessage()

func (*PersistenceStrategy) Reset 

func (m *PersistenceStrategy) Reset()

func (*PersistenceStrategy) Size 

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

func (*PersistenceStrategy) String 

func (this *PersistenceStrategy) String() string

func (*PersistenceStrategy) Unmarshal 

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

func (*PersistenceStrategy) XXX_DiscardUnknown 

func (m *PersistenceStrategy) XXX_DiscardUnknown()

func (*PersistenceStrategy) XXX_Marshal 

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

func (*PersistenceStrategy) XXX_Merge 

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

func (*PersistenceStrategy) XXX_Size 

func (m *PersistenceStrategy) XXX_Size() int

func (*PersistenceStrategy) XXX_Unmarshal 

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

type Pipeline 

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

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

+genclient +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` +kubebuilder:printcolumn:name="Vertices",type=integer,JSONPath=`.status.vertexCount` +kubebuilder:printcolumn:name="Sources",type=integer,JSONPath=`.status.sourceCount`,priority=10 +kubebuilder:printcolumn:name="Sinks",type=integer,JSONPath=`.status.sinkCount`,priority=10 +kubebuilder:printcolumn:name="UDFs",type=integer,JSONPath=`.status.udfCount`,priority=10 +kubebuilder:printcolumn:name="Age",type=date,JSONPath=`.metadata.creationTimestamp` +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true

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) FindVertexWithBuffer added in v0.8.1 

func (p Pipeline) FindVertexWithBuffer(buffer string) *AbstractVertex

func (Pipeline) GetAllBuckets added in v0.8.1 

func (p Pipeline) GetAllBuckets() []string

func (Pipeline) GetAllBuffers 

func (p Pipeline) GetAllBuffers() []string

func (Pipeline) GetDaemonDeploymentName 

func (p Pipeline) GetDaemonDeploymentName() string

func (Pipeline) GetDaemonDeploymentObj 

func (p Pipeline) GetDaemonDeploymentObj(req GetDaemonDeploymentReq) (*appv1.Deployment, error)

func (Pipeline) GetDaemonServiceName 

func (p Pipeline) GetDaemonServiceName() string

func (Pipeline) GetDaemonServiceObj 

func (p Pipeline) GetDaemonServiceObj() *corev1.Service

func (Pipeline) GetDaemonServiceURL 

func (p Pipeline) GetDaemonServiceURL() string

func (Pipeline) GetDownstreamEdges added in v0.5.4 

func (p Pipeline) GetDownstreamEdges(vertexName string) []Edge

GetDownstreamEdges returns all the downstream edges of a vertex

func (Pipeline) GetFromEdges 

func (p Pipeline) GetFromEdges(vertexName string) []Edge

func (Pipeline) GetPipelineLimits added in v0.6.1 

func (p Pipeline) GetPipelineLimits() PipelineLimits

GetPipelineLimits returns the pipeline limits with default values

func (Pipeline) GetSideInputsManagerDeploymentName added in v0.10.0 

func (p Pipeline) GetSideInputsManagerDeploymentName(sideInputName string) string

func (Pipeline) GetSideInputsManagerDeployments added in v0.10.0 

func (p Pipeline) GetSideInputsManagerDeployments(req GetSideInputDeploymentReq) ([]*appv1.Deployment, error)

func (Pipeline) GetSideInputsStoreName added in v0.10.0 

func (p Pipeline) GetSideInputsStoreName() string

func (Pipeline) GetToEdges 

func (p Pipeline) GetToEdges(vertexName string) []Edge

func (Pipeline) GetVertex 

func (p Pipeline) GetVertex(vertexName string) *AbstractVertex

GetVertex is used to find the AbstractVertex info from vertex name.

func (Pipeline) HasSideInputs added in v0.10.0 

func (p Pipeline) HasSideInputs() bool

HasSideInputs returns if the pipeline has side inputs.

func (Pipeline) ListAllEdges added in v0.6.1 

func (p Pipeline) ListAllEdges() []Edge

ListAllEdges returns a copy of all the edges.

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) NumOfPartitions added in v0.8.1 

func (p Pipeline) NumOfPartitions(vertex string) int

NumOfPartitions returns the number of partitions for a vertex.

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 PipelineLimits 

type PipelineLimits struct {
	// Read batch size for all the vertices in the pipeline, can be overridden by the vertex's limit settings.
	// +kubebuilder:default=500
	// +optional
	ReadBatchSize *uint64 `json:"readBatchSize,omitempty" protobuf:"varint,1,opt,name=readBatchSize"`
	// BufferMaxLength is used to define the max length of a buffer.
	// Only applies to UDF and Source vertices as only they do buffer write.
	// It can be overridden by the settings in vertex limits.
	// +kubebuilder:default=30000
	// +optional
	BufferMaxLength *uint64 `json:"bufferMaxLength,omitempty" protobuf:"varint,2,opt,name=bufferMaxLength"`
	// BufferUsageLimit is used to define the percentage of the buffer usage limit, a valid value should be less than 100, for example, 85.
	// Only applies to UDF and Source vertices as only they do buffer write.
	// It will be overridden by the settings in vertex limits.
	// +kubebuilder:default=80
	// +optional
	BufferUsageLimit *uint32 `json:"bufferUsageLimit,omitempty" protobuf:"varint,3,opt,name=bufferUsageLimit"`
	// Read timeout for all the vertices in the pipeline, can be overridden by the vertex's limit settings
	// +kubebuilder:default= "1s"
	// +optional
	ReadTimeout *metav1.Duration `json:"readTimeout,omitempty" protobuf:"bytes,4,opt,name=readTimeout"`
}

func (*PipelineLimits) DeepCopy 

func (in *PipelineLimits) DeepCopy() *PipelineLimits

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

func (*PipelineLimits) DeepCopyInto 

func (in *PipelineLimits) DeepCopyInto(out *PipelineLimits)

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

func (*PipelineLimits) Descriptor 

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

func (*PipelineLimits) Marshal 

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

func (*PipelineLimits) MarshalTo 

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

func (*PipelineLimits) MarshalToSizedBuffer 

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

func (*PipelineLimits) ProtoMessage 

func (*PipelineLimits) ProtoMessage()

func (*PipelineLimits) Reset 

func (m *PipelineLimits) Reset()

func (*PipelineLimits) Size 

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

func (*PipelineLimits) String 

func (this *PipelineLimits) String() string

func (*PipelineLimits) Unmarshal 

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

func (*PipelineLimits) XXX_DiscardUnknown 

func (m *PipelineLimits) XXX_DiscardUnknown()

func (*PipelineLimits) XXX_Marshal 

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

func (*PipelineLimits) XXX_Merge 

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

func (*PipelineLimits) XXX_Size 

func (m *PipelineLimits) XXX_Size() int

func (*PipelineLimits) XXX_Unmarshal 

func (m *PipelineLimits) 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"`
}

+kubebuilder:object:root=true +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

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="";Running;Succeeded;Failed;Pausing;Paused;Deleting

type PipelineSpec 

type PipelineSpec struct {
	// +optional
	InterStepBufferServiceName string `json:"interStepBufferServiceName,omitempty" protobuf:"bytes,1,opt,name=interStepBufferServiceName"`
	// +patchStrategy=merge
	// +patchMergeKey=name
	Vertices []AbstractVertex `json:"vertices,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=vertices"`
	// Edges define the relationships between vertices
	Edges []Edge `json:"edges,omitempty" protobuf:"bytes,3,rep,name=edges"`
	// Lifecycle define the Lifecycle properties
	// +kubebuilder:default={"deleteGracePeriodSeconds": 30, "desiredPhase": Running, "pauseGracePeriodSeconds": 30}
	// +optional
	Lifecycle Lifecycle `json:"lifecycle,omitempty" protobuf:"bytes,4,opt,name=lifecycle"`
	// Limits define the limitations such as buffer read batch size for all the vertices of a pipeline, they could be overridden by each vertex's settings
	// +kubebuilder:default={"readBatchSize": 500, "bufferMaxLength": 30000, "bufferUsageLimit": 80}
	// +optional
	Limits *PipelineLimits `json:"limits,omitempty" protobuf:"bytes,5,opt,name=limits"`
	// Watermark enables watermark progression across the entire pipeline.
	// +kubebuilder:default={"disabled": false}
	// +optional
	Watermark Watermark `json:"watermark,omitempty" protobuf:"bytes,6,opt,name=watermark"`
	// Templates are used to customize additional kubernetes resources required for the Pipeline
	// +optional
	Templates *Templates `json:"templates,omitempty" protobuf:"bytes,7,opt,name=templates"`
	// SideInputs defines the Side Inputs of a pipeline.
	// +optional
	SideInputs []SideInput `json:"sideInputs,omitempty" protobuf:"bytes,8,rep,name=sideInputs"`
}

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) GetMatchingVertices added in v0.10.0 

func (pipeline PipelineSpec) GetMatchingVertices(f func(AbstractVertex) bool) map[string]*AbstractVertex

func (PipelineSpec) GetSinksByName added in v0.10.0 

func (pipeline PipelineSpec) GetSinksByName() map[string]*AbstractVertex

func (PipelineSpec) GetSourcesByName added in v0.10.0 

func (pipeline PipelineSpec) GetSourcesByName() map[string]*AbstractVertex

func (PipelineSpec) GetVerticesByName added in v0.10.0 

func (pipeline PipelineSpec) GetVerticesByName() map[string]*AbstractVertex

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 {
	Status      `json:",inline" protobuf:"bytes,1,opt,name=status"`
	Phase       PipelinePhase `json:"phase,omitempty" protobuf:"bytes,2,opt,name=phase,casttype=PipelinePhase"`
	Message     string        `json:"message,omitempty" protobuf:"bytes,3,opt,name=message"`
	LastUpdated metav1.Time   `json:"lastUpdated,omitempty" protobuf:"bytes,4,opt,name=lastUpdated"`
	VertexCount *uint32       `json:"vertexCount,omitempty" protobuf:"varint,5,opt,name=vertexCount"`
	SourceCount *uint32       `json:"sourceCount,omitempty" protobuf:"varint,6,opt,name=sourceCount"`
	SinkCount   *uint32       `json:"sinkCount,omitempty" protobuf:"varint,7,opt,name=sinkCount"`
	UDFCount    *uint32       `json:"udfCount,omitempty" protobuf:"varint,8,opt,name=udfCount"`
}

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) InitConditions 

func (pls *PipelineStatus) InitConditions()

InitConditions sets conditions to Unknown state.

func (*PipelineStatus) MarkConfigured 

func (pls *PipelineStatus) MarkConfigured()

MarkConfigured set the Pipeline has valid configuration.

func (*PipelineStatus) MarkDeployFailed 

func (pls *PipelineStatus) MarkDeployFailed(reason, message string)

MarkDeployFailed set the Pipeline deployment failed

func (*PipelineStatus) MarkDeployed 

func (pls *PipelineStatus) MarkDeployed()

MarkDeployed set the Pipeline has been deployed.

func (*PipelineStatus) MarkNotConfigured 

func (pls *PipelineStatus) MarkNotConfigured(reason, message string)

MarkNotConfigured the Pipeline has configuration.

func (*PipelineStatus) MarkPhaseDeleting 

func (pls *PipelineStatus) MarkPhaseDeleting()

MarkPhaseDeleting set the Pipeline is deleting.

func (*PipelineStatus) MarkPhasePaused 

func (pls *PipelineStatus) MarkPhasePaused()

MarkPhasePaused set the Pipeline has been paused.

func (*PipelineStatus) MarkPhasePausing 

func (pls *PipelineStatus) MarkPhasePausing()

MarkPhasePausing set the Pipeline is pausing.

func (*PipelineStatus) MarkPhaseRunning 

func (pls *PipelineStatus) MarkPhaseRunning()

MarkPhaseRunning set the Pipeline has been running.

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) SetPhase 

func (pls *PipelineStatus) SetPhase(phase PipelinePhase, msg string)

func (*PipelineStatus) SetVertexCounts added in v0.6.2 

func (pls *PipelineStatus) SetVertexCounts(vertices []AbstractVertex)

SetVertexCounts sets the counts of vertices.

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 RedisBufferService added in v0.6.2 

type RedisBufferService struct {
	// Native brings up a native Redis service
	Native *NativeRedis `json:"native,omitempty" protobuf:"bytes,1,opt,name=native"`
	// External holds an External Redis config
	External *RedisConfig `json:"external,omitempty" protobuf:"bytes,2,opt,name=external"`
}

func (*RedisBufferService) DeepCopy added in v0.6.2 

func (in *RedisBufferService) DeepCopy() *RedisBufferService

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

func (*RedisBufferService) DeepCopyInto added in v0.6.2 

func (in *RedisBufferService) DeepCopyInto(out *RedisBufferService)

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

func (*RedisBufferService) Descriptor added in v0.6.2 

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

func (*RedisBufferService) Marshal added in v0.6.2 

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

func (*RedisBufferService) MarshalTo added in v0.6.2 

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

func (*RedisBufferService) MarshalToSizedBuffer added in v0.6.2 

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

func (*RedisBufferService) ProtoMessage added in v0.6.2 

func (*RedisBufferService) ProtoMessage()

func (*RedisBufferService) Reset added in v0.6.2 

func (m *RedisBufferService) Reset()

func (*RedisBufferService) Size added in v0.6.2 

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

func (*RedisBufferService) String added in v0.6.2 

func (this *RedisBufferService) String() string

func (*RedisBufferService) Unmarshal added in v0.6.2 

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

func (*RedisBufferService) XXX_DiscardUnknown added in v0.6.2 

func (m *RedisBufferService) XXX_DiscardUnknown()

func (*RedisBufferService) XXX_Marshal added in v0.6.2 

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

func (*RedisBufferService) XXX_Merge added in v0.6.2 

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

func (*RedisBufferService) XXX_Size added in v0.6.2 

func (m *RedisBufferService) XXX_Size() int

func (*RedisBufferService) XXX_Unmarshal added in v0.6.2 

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

type RedisConfig 

type RedisConfig struct {
	// Redis URL
	// +optional
	URL string `json:"url,omitempty" protobuf:"bytes,1,opt,name=url"`
	// Sentinel URL, will be ignored if Redis URL is provided
	// +optional
	SentinelURL string `json:"sentinelUrl,omitempty" protobuf:"bytes,2,opt,name=sentinelUrl"`
	// Only required when Sentinel is used
	// +optional
	MasterName string `json:"masterName,omitempty" protobuf:"bytes,3,opt,name=masterName"`
	// Redis user
	// +optional
	User string `json:"user,omitempty" protobuf:"bytes,4,opt,name=user"`
	// Redis password secret selector
	// +optional
	Password *corev1.SecretKeySelector `json:"password,omitempty" protobuf:"bytes,5,opt,name=password"`
	// Sentinel password secret selector
	// +optional
	SentinelPassword *corev1.SecretKeySelector `json:"sentinelPassword,omitempty" protobuf:"bytes,6,opt,name=sentinelPassword"`
}

func (*RedisConfig) DeepCopy 

func (in *RedisConfig) DeepCopy() *RedisConfig

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

func (*RedisConfig) DeepCopyInto 

func (in *RedisConfig) DeepCopyInto(out *RedisConfig)

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

func (*RedisConfig) Descriptor 

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

func (*RedisConfig) Marshal 

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

func (*RedisConfig) MarshalTo 

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

func (*RedisConfig) MarshalToSizedBuffer 

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

func (*RedisConfig) ProtoMessage 

func (*RedisConfig) ProtoMessage()

func (*RedisConfig) Reset 

func (m *RedisConfig) Reset()

func (*RedisConfig) Size 

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

func (*RedisConfig) String 

func (this *RedisConfig) String() string

func (*RedisConfig) Unmarshal 

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

func (*RedisConfig) XXX_DiscardUnknown 

func (m *RedisConfig) XXX_DiscardUnknown()

func (*RedisConfig) XXX_Marshal 

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

func (*RedisConfig) XXX_Merge 

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

func (*RedisConfig) XXX_Size 

func (m *RedisConfig) XXX_Size() int

func (*RedisConfig) XXX_Unmarshal 

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

type RedisSettings 

type RedisSettings struct {
	// Redis settings shared by both master and slaves, will override the global settings from controller config
	// +optional
	Redis string `json:"redis,omitempty" protobuf:"bytes,1,opt,name=redis"`
	// Special settings for Redis master node, will override the global settings from controller config
	// +optional
	Master string `json:"master,omitempty" protobuf:"bytes,2,opt,name=master"`
	// Special settings for Redis replica nodes, will override the global settings from controller config
	// +optional
	Replica string `json:"replica,omitempty" protobuf:"bytes,3,opt,name=replica"`
	// Sentinel settings, will override the global settings from controller config
	// +optional
	Sentinel string `json:"sentinel,omitempty" protobuf:"bytes,4,opt,name=sentinel"`
}

func (*RedisSettings) DeepCopy 

func (in *RedisSettings) DeepCopy() *RedisSettings

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

func (*RedisSettings) DeepCopyInto 

func (in *RedisSettings) DeepCopyInto(out *RedisSettings)

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

func (*RedisSettings) Descriptor 

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

func (*RedisSettings) Marshal 

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

func (*RedisSettings) MarshalTo 

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

func (*RedisSettings) MarshalToSizedBuffer 

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

func (*RedisSettings) ProtoMessage 

func (*RedisSettings) ProtoMessage()

func (*RedisSettings) Reset 

func (m *RedisSettings) Reset()

func (*RedisSettings) Size 

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

func (*RedisSettings) String 

func (this *RedisSettings) String() string

func (*RedisSettings) Unmarshal 

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

func (*RedisSettings) XXX_DiscardUnknown 

func (m *RedisSettings) XXX_DiscardUnknown()

func (*RedisSettings) XXX_Marshal 

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

func (*RedisSettings) XXX_Merge 

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

func (*RedisSettings) XXX_Size 

func (m *RedisSettings) XXX_Size() int

func (*RedisSettings) XXX_Unmarshal 

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

type SASL added in v0.7.3 

type SASL struct {
	// SASL mechanism to use
	Mechanism *SASLType `json:"mechanism" protobuf:"bytes,1,opt,name=mechanism,casttype=SASLType"`
	// GSSAPI contains the kerberos config
	// +optional
	GSSAPI *GSSAPI `json:"gssapi" protobuf:"bytes,2,opt,name=gssapi"`
	// SASLPlain contains the sasl plain config
	// +optional
	Plain *SASLPlain `json:"plain" protobuf:"bytes,3,opt,name=plain"`
	// SASLSCRAMSHA256 contains the sasl plain config
	// +optional
	SCRAMSHA256 *SASLPlain `json:"scramsha256" protobuf:"bytes,4,opt,name=scramsha256"`
	// SASLSCRAMSHA512 contains the sasl plain config
	// +optional
	SCRAMSHA512 *SASLPlain `json:"scramsha512" protobuf:"bytes,5,opt,name=scramsha512"`
}

func (*SASL) DeepCopy added in v0.7.3 

func (in *SASL) DeepCopy() *SASL

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

func (*SASL) DeepCopyInto added in v0.7.3 

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.7.3 

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

func (*SASL) Marshal added in v0.7.3 

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

func (*SASL) MarshalTo added in v0.7.3 

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

func (*SASL) MarshalToSizedBuffer added in v0.7.3 

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

func (*SASL) ProtoMessage added in v0.7.3 

func (*SASL) ProtoMessage()

func (*SASL) Reset added in v0.7.3 

func (m *SASL) Reset()

func (*SASL) Size added in v0.7.3 

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

func (*SASL) String added in v0.7.3 

func (this *SASL) String() string

func (*SASL) Unmarshal added in v0.7.3 

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

func (*SASL) XXX_DiscardUnknown added in v0.7.3 

func (m *SASL) XXX_DiscardUnknown()

func (*SASL) XXX_Marshal added in v0.7.3 

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

func (*SASL) XXX_Merge added in v0.7.3 

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

func (*SASL) XXX_Size added in v0.7.3 

func (m *SASL) XXX_Size() int

func (*SASL) XXX_Unmarshal added in v0.7.3 

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

type SASLPlain added in v0.7.3 

type SASLPlain struct {
	// UserSecret refers to the secret that contains the user
	UserSecret *corev1.SecretKeySelector `json:"userSecret" protobuf:"bytes,1,opt,name=userSecret"`
	// PasswordSecret refers to the secret that contains the password
	// +optional
	PasswordSecret *corev1.SecretKeySelector `json:"passwordSecret" protobuf:"bytes,2,opt,name=passwordSecret"`
	Handshake      bool                      `json:"handshake" protobuf:"bytes,3,opt,name=handshake"`
}

func (*SASLPlain) DeepCopy added in v0.7.3 

func (in *SASLPlain) DeepCopy() *SASLPlain

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

func (*SASLPlain) DeepCopyInto added in v0.7.3 

func (in *SASLPlain) DeepCopyInto(out *SASLPlain)

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

func (*SASLPlain) Descriptor added in v0.7.3 

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

func (*SASLPlain) Marshal added in v0.7.3 

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

func (*SASLPlain) MarshalTo added in v0.7.3 

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

func (*SASLPlain) MarshalToSizedBuffer added in v0.7.3 

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

func (*SASLPlain) ProtoMessage added in v0.7.3 

func (*SASLPlain) ProtoMessage()

func (*SASLPlain) Reset added in v0.7.3 

func (m *SASLPlain) Reset()

func (*SASLPlain) Size added in v0.7.3 

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

func (*SASLPlain) String added in v0.7.3 

func (this *SASLPlain) String() string

func (*SASLPlain) Unmarshal added in v0.7.3 

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

func (*SASLPlain) XXX_DiscardUnknown added in v0.7.3 

func (m *SASLPlain) XXX_DiscardUnknown()

func (*SASLPlain) XXX_Marshal added in v0.7.3 

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

func (*SASLPlain) XXX_Merge added in v0.7.3 

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

func (*SASLPlain) XXX_Size added in v0.7.3 

func (m *SASLPlain) XXX_Size() int

func (*SASLPlain) XXX_Unmarshal added in v0.7.3 

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

type SASLType added in v0.7.3 

type SASLType string

SASLType describes the SASL type 

const (
	// SASLTypeOAuth represents the SASL/OAUTHBEARER mechanism (Kafka 2.0.0+)
	// SASLTypeOAuth = "OAUTHBEARER"
	SASLTypeOAuth SASLType = "OAUTHBEARER"
	// SASLTypePlaintext represents the SASL/PLAIN mechanism
	// SASLTypePlaintext = "PLAIN"
	SASLTypePlaintext SASLType = "PLAIN"
	// SASLTypeSCRAMSHA256 represents the SCRAM-SHA-256 mechanism.
	// SASLTypeSCRAMSHA256 = "SCRAM-SHA-256"
	SASLTypeSCRAMSHA256 SASLType = "SCRAM-SHA-256"
	// SASLTypeSCRAMSHA512 represents the SCRAM-SHA-512 mechanism.
	// SASLTypeSCRAMSHA512 = "SCRAM-SHA-512"
	SASLTypeSCRAMSHA512 SASLType = "SCRAM-SHA-512"
	// SASLTypeGSSAPI represents the GSSAPI mechanism
	// SASLTypeGSSAPI      = "GSSAPI"
	SASLTypeGSSAPI SASLType = "GSSAPI"
)

type Scale 

type Scale struct {
	// Whether to disable autoscaling.
	// Set to "true" when using Kubernetes HPA or any other 3rd party autoscaling strategies.
	// +optional
	Disabled bool `json:"disabled,omitempty" protobuf:"bytes,1,opt,name=disabled"`
	// Minimum replicas.
	// +optional
	Min *int32 `json:"min,omitempty" protobuf:"varint,2,opt,name=min"`
	// Maximum replicas.
	// +optional
	Max *int32 `json:"max,omitempty" protobuf:"varint,3,opt,name=max"`
	// Lookback seconds to calculate the average pending messages and processing rate.
	// +optional
	LookbackSeconds *uint32 `json:"lookbackSeconds,omitempty" protobuf:"varint,4,opt,name=lookbackSeconds"`
	// Deprecated: Use scaleUpCooldownSeconds and scaleDownCooldownSeconds instead.
	// Cooldown seconds after a scaling operation before another one.
	// +optional
	DeprecatedCooldownSeconds *uint32 `json:"cooldownSeconds,omitempty" protobuf:"varint,5,opt,name=cooldownSeconds"`
	// After scaling down the source vertex to 0, sleep how many seconds before scaling the source vertex back up to peek.
	// +optional
	ZeroReplicaSleepSeconds *uint32 `json:"zeroReplicaSleepSeconds,omitempty" protobuf:"varint,6,opt,name=zeroReplicaSleepSeconds"`
	// TargetProcessingSeconds is used to tune the aggressiveness of autoscaling for source vertices, it measures how fast
	// you want the vertex to process all the pending messages. Typically increasing the value, which leads to lower processing
	// rate, thus less replicas. It's only effective for source vertices.
	// +optional
	TargetProcessingSeconds *uint32 `json:"targetProcessingSeconds,omitempty" protobuf:"varint,7,opt,name=targetProcessingSeconds"`
	// TargetBufferAvailability is used to define the target percentage of the buffer availability.
	// A valid and meaningful value should be less than the BufferUsageLimit defined in the Edge spec (or Pipeline spec), for example, 50.
	// It only applies to UDF and Sink vertices because only they have buffers to read.
	// +optional
	TargetBufferAvailability *uint32 `json:"targetBufferAvailability,omitempty" protobuf:"varint,8,opt,name=targetBufferAvailability"`
	// ReplicasPerScale defines maximum replicas can be scaled up or down at once.
	// The is use to prevent too aggressive scaling operations
	// +optional
	ReplicasPerScale *uint32 `json:"replicasPerScale,omitempty" protobuf:"varint,9,opt,name=replicasPerScale"`
	// ScaleUpCooldownSeconds defines the cooldown seconds after a scaling operation, before a follow-up scaling up.
	// It defaults to the CooldownSeconds if not set.
	// +optional
	ScaleUpCooldownSeconds *uint32 `json:"scaleUpCooldownSeconds,omitempty" protobuf:"varint,10,opt,name=scaleUpCooldownSeconds"`
	// ScaleDownCooldownSeconds defines the cooldown seconds after a scaling operation, before a follow-up scaling down.
	// It defaults to the CooldownSeconds if not set.
	// +optional
	ScaleDownCooldownSeconds *uint32 `json:"scaleDownCooldownSeconds,omitempty" protobuf:"varint,11,opt,name=scaleDownCooldownSeconds"`
}

Scale defines the parameters for autoscaling.

func (*Scale) DeepCopy 

func (in *Scale) DeepCopy() *Scale

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

func (*Scale) DeepCopyInto 

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 

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

func (Scale) GetLookbackSeconds added in v0.5.4 

func (s Scale) GetLookbackSeconds() int

func (Scale) GetMaxReplicas added in v0.5.4 

func (s Scale) GetMaxReplicas() int32

func (Scale) GetMinReplicas added in v0.5.4 

func (s Scale) GetMinReplicas() int32

func (Scale) GetReplicasPerScale added in v0.5.4 

func (s Scale) GetReplicasPerScale() int

func (Scale) GetScaleDownCooldownSeconds added in v0.10.0 

func (s Scale) GetScaleDownCooldownSeconds() int

func (Scale) GetScaleUpCooldownSeconds added in v0.10.0 

func (s Scale) GetScaleUpCooldownSeconds() int

func (Scale) GetTargetBufferAvailability added in v0.7.2 

func (s Scale) GetTargetBufferAvailability() int

func (Scale) GetTargetProcessingSeconds added in v0.5.4 

func (s Scale) GetTargetProcessingSeconds() int

func (Scale) GetZeroReplicaSleepSeconds added in v0.5.4 

func (s Scale) GetZeroReplicaSleepSeconds() int

func (*Scale) Marshal 

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

func (*Scale) MarshalTo 

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

func (*Scale) MarshalToSizedBuffer 

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

func (*Scale) ProtoMessage 

func (*Scale) ProtoMessage()

func (*Scale) Reset 

func (m *Scale) Reset()

func (*Scale) Size 

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

func (*Scale) String 

func (this *Scale) String() string

func (*Scale) Unmarshal 

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

func (*Scale) XXX_DiscardUnknown 

func (m *Scale) XXX_DiscardUnknown()

func (*Scale) XXX_Marshal 

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

func (*Scale) XXX_Merge 

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

func (*Scale) XXX_Size 

func (m *Scale) XXX_Size() int

func (*Scale) XXX_Unmarshal 

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

type SideInput added in v0.10.0 

type SideInput struct {
	Name      string     `json:"name" protobuf:"bytes,1,opt,name=name"`
	Container *Container `json:"container" protobuf:"bytes,2,opt,name=container"`
	// +optional
	// +patchStrategy=merge
	// +patchMergeKey=name
	Volumes []corev1.Volume   `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,3,rep,name=volumes"`
	Trigger *SideInputTrigger `json:"trigger" protobuf:"bytes,4,opt,name=trigger"`
}

SideInput defines information of a Side Input

func (*SideInput) DeepCopy added in v0.10.0 

func (in *SideInput) DeepCopy() *SideInput

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

func (*SideInput) DeepCopyInto added in v0.10.0 

func (in *SideInput) DeepCopyInto(out *SideInput)

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

func (*SideInput) Descriptor added in v0.10.0 

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

func (*SideInput) Marshal added in v0.10.0 

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

func (*SideInput) MarshalTo added in v0.10.0 

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

func (*SideInput) MarshalToSizedBuffer added in v0.10.0 

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

func (*SideInput) ProtoMessage added in v0.10.0 

func (*SideInput) ProtoMessage()

func (*SideInput) Reset added in v0.10.0 

func (m *SideInput) Reset()

func (*SideInput) Size added in v0.10.0 

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

func (*SideInput) String added in v0.10.0 

func (this *SideInput) String() string

func (*SideInput) Unmarshal added in v0.10.0 

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

func (*SideInput) XXX_DiscardUnknown added in v0.10.0 

func (m *SideInput) XXX_DiscardUnknown()

func (*SideInput) XXX_Marshal added in v0.10.0 

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

func (*SideInput) XXX_Merge added in v0.10.0 

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

func (*SideInput) XXX_Size added in v0.10.0 

func (m *SideInput) XXX_Size() int

func (*SideInput) XXX_Unmarshal added in v0.10.0 

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

type SideInputTrigger added in v0.10.0 

type SideInputTrigger struct {
	// The schedule to trigger the retrievement of the side input data.
	// It supports cron format, for example, "0 30 * * * *".
	// Or interval based format, such as "@hourly", "@every 1h30m", etc.
	Schedule string `json:"schedule" protobuf:"bytes,1,opt,name=schedule"`
	// +optional
	Timezone *string `json:"timezone" protobuf:"bytes,2,opt,name=timezone"`
}

func (*SideInputTrigger) DeepCopy added in v0.10.0 

func (in *SideInputTrigger) DeepCopy() *SideInputTrigger

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

func (*SideInputTrigger) DeepCopyInto added in v0.10.0 

func (in *SideInputTrigger) DeepCopyInto(out *SideInputTrigger)

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

func (*SideInputTrigger) Descriptor added in v0.10.0 

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

func (*SideInputTrigger) Marshal added in v0.10.0 

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

func (*SideInputTrigger) MarshalTo added in v0.10.0 

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

func (*SideInputTrigger) MarshalToSizedBuffer added in v0.10.0 

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

func (*SideInputTrigger) ProtoMessage added in v0.10.0 

func (*SideInputTrigger) ProtoMessage()

func (*SideInputTrigger) Reset added in v0.10.0 

func (m *SideInputTrigger) Reset()

func (*SideInputTrigger) Size added in v0.10.0 

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

func (*SideInputTrigger) String added in v0.10.0 

func (this *SideInputTrigger) String() string

func (*SideInputTrigger) Unmarshal added in v0.10.0 

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

func (*SideInputTrigger) XXX_DiscardUnknown added in v0.10.0 

func (m *SideInputTrigger) XXX_DiscardUnknown()

func (*SideInputTrigger) XXX_Marshal added in v0.10.0 

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

func (*SideInputTrigger) XXX_Merge added in v0.10.0 

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

func (*SideInputTrigger) XXX_Size added in v0.10.0 

func (m *SideInputTrigger) XXX_Size() int

func (*SideInputTrigger) XXX_Unmarshal added in v0.10.0 

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

type SideInputsManagerTemplate added in v0.10.0 

type SideInputsManagerTemplate struct {
	// +optional
	AbstractPodTemplate `json:",inline" protobuf:"bytes,1,opt,name=abstractPodTemplate"`
	// Template for the side inputs manager numa container
	// +optional
	ContainerTemplate *ContainerTemplate `json:"containerTemplate,omitempty" protobuf:"bytes,2,opt,name=containerTemplate"`
	// Template for the side inputs manager init container
	// +optional
	InitContainerTemplate *ContainerTemplate `json:"initContainerTemplate,omitempty" protobuf:"bytes,3,opt,name=initContainerTemplate"`
}

func (*SideInputsManagerTemplate) DeepCopy added in v0.10.0 

func (in *SideInputsManagerTemplate) DeepCopy() *SideInputsManagerTemplate

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

func (*SideInputsManagerTemplate) DeepCopyInto added in v0.10.0 

func (in *SideInputsManagerTemplate) DeepCopyInto(out *SideInputsManagerTemplate)

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

func (*SideInputsManagerTemplate) Descriptor added in v0.10.0 

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

func (*SideInputsManagerTemplate) Marshal added in v0.10.0 

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

func (*SideInputsManagerTemplate) MarshalTo added in v0.10.0 

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

func (*SideInputsManagerTemplate) MarshalToSizedBuffer added in v0.10.0 

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

func (*SideInputsManagerTemplate) ProtoMessage added in v0.10.0 

func (*SideInputsManagerTemplate) ProtoMessage()

func (*SideInputsManagerTemplate) Reset added in v0.10.0 

func (m *SideInputsManagerTemplate) Reset()

func (*SideInputsManagerTemplate) Size added in v0.10.0 

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

func (*SideInputsManagerTemplate) String added in v0.10.0 

func (this *SideInputsManagerTemplate) String() string

func (*SideInputsManagerTemplate) Unmarshal added in v0.10.0 

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

func (*SideInputsManagerTemplate) XXX_DiscardUnknown added in v0.10.0 

func (m *SideInputsManagerTemplate) XXX_DiscardUnknown()

func (*SideInputsManagerTemplate) XXX_Marshal added in v0.10.0 

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

func (*SideInputsManagerTemplate) XXX_Merge added in v0.10.0 

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

func (*SideInputsManagerTemplate) XXX_Size added in v0.10.0 

func (m *SideInputsManagerTemplate) XXX_Size() int

func (*SideInputsManagerTemplate) XXX_Unmarshal added in v0.10.0 

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

type Sink 

type Sink struct {
	Log       *Log       `json:"log,omitempty" protobuf:"bytes,1,opt,name=log"`
	Kafka     *KafkaSink `json:"kafka,omitempty" protobuf:"bytes,2,opt,name=kafka"`
	Blackhole *Blackhole `json:"blackhole,omitempty" protobuf:"bytes,3,opt,name=blackhole"`
	UDSink    *UDSink    `json:"udsink,omitempty" protobuf:"bytes,4,opt,name=udsink"`
}

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 SlidingWindow added in v0.7.0 

type SlidingWindow struct {
	Length *metav1.Duration `json:"length,omitempty" protobuf:"bytes,1,opt,name=length"`
	Slide  *metav1.Duration `json:"slide,omitempty" protobuf:"bytes,2,opt,name=slide"`
}

SlidingWindow describes a sliding window

func (*SlidingWindow) DeepCopy added in v0.7.0 

func (in *SlidingWindow) DeepCopy() *SlidingWindow

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

func (*SlidingWindow) DeepCopyInto added in v0.7.0 

func (in *SlidingWindow) DeepCopyInto(out *SlidingWindow)

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

func (*SlidingWindow) Descriptor added in v0.7.0 

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

func (*SlidingWindow) Marshal added in v0.7.0 

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

func (*SlidingWindow) MarshalTo added in v0.7.0 

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

func (*SlidingWindow) MarshalToSizedBuffer added in v0.7.0 

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

func (*SlidingWindow) ProtoMessage added in v0.7.0 

func (*SlidingWindow) ProtoMessage()

func (*SlidingWindow) Reset added in v0.7.0 

func (m *SlidingWindow) Reset()

func (*SlidingWindow) Size added in v0.7.0 

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

func (*SlidingWindow) String added in v0.7.0 

func (this *SlidingWindow) String() string

func (*SlidingWindow) Unmarshal added in v0.7.0 

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

func (*SlidingWindow) XXX_DiscardUnknown added in v0.7.0 

func (m *SlidingWindow) XXX_DiscardUnknown()

func (*SlidingWindow) XXX_Marshal added in v0.7.0 

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

func (*SlidingWindow) XXX_Merge added in v0.7.0 

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

func (*SlidingWindow) XXX_Size added in v0.7.0 

func (m *SlidingWindow) XXX_Size() int

func (*SlidingWindow) XXX_Unmarshal added in v0.7.0 

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

type Source 

type Source struct {
	// +optional
	Generator *GeneratorSource `json:"generator,omitempty" protobuf:"bytes,1,opt,name=generator"`
	// +optional
	Kafka *KafkaSource `json:"kafka,omitempty" protobuf:"bytes,2,opt,name=kafka"`
	// +optional
	HTTP *HTTPSource `json:"http,omitempty" protobuf:"bytes,3,opt,name=http"`
	// +optional
	Nats *NatsSource `json:"nats,omitempty" protobuf:"bytes,4,opt,name=nats"`
	// +optional
	UDTransformer *UDTransformer `json:"transformer,omitempty" protobuf:"bytes,5,opt,name=transformer"`
	// +optional
	UDSource *UDSource `json:"udsource,omitempty" protobuf:"bytes,6,opt,name=udSource"`
}

func (*Source) DeepCopy 

func (in *Source) DeepCopy() *Source

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

func (*Source) DeepCopyInto 

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

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

func (*Source) Descriptor 

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

func (*Source) Marshal 

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

func (*Source) MarshalTo 

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

func (*Source) MarshalToSizedBuffer 

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

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) Reset 

func (m *Source) Reset()

func (*Source) Size 

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

func (*Source) String 

func (this *Source) String() string

func (*Source) Unmarshal 

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

func (*Source) XXX_DiscardUnknown 

func (m *Source) XXX_DiscardUnknown()

func (*Source) XXX_Marshal 

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

func (*Source) XXX_Merge 

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

func (*Source) XXX_Size 

func (m *Source) XXX_Size() int

func (*Source) XXX_Unmarshal 

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

type Status 

type Status struct {
	// Conditions are the latest available observations of a resource's current state.
	// +optional
	// +patchMergeKey=type
	// +patchStrategy=merge
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`
}

Status is a common structure which can be used for Status field.

func (*Status) DeepCopy 

func (in *Status) DeepCopy() *Status

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

func (*Status) DeepCopyInto 

func (in *Status) DeepCopyInto(out *Status)

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

func (*Status) Descriptor 

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

func (*Status) GetCondition 

func (s *Status) GetCondition(t ConditionType) *metav1.Condition

GetCondition returns the condition of a condition type

func (*Status) InitializeConditions 

func (s *Status) InitializeConditions(conditionTypes ...ConditionType)

InitializeConditions initializes the conditions to Unknown

func (*Status) IsReady 

func (s *Status) IsReady() bool

IsReady returns true when all the conditions are true

func (*Status) MarkFalse 

func (s *Status) MarkFalse(t ConditionType, reason, message string)

MarkFalse sets the status of t to fasle

func (*Status) MarkTrue 

func (s *Status) MarkTrue(t ConditionType)

MarkTrue sets the status of t to true

func (*Status) MarkTrueWithReason 

func (s *Status) MarkTrueWithReason(t ConditionType, reason, message string)

MarkTrueWithReason sets the status of t to true with reason

func (*Status) MarkUnknown 

func (s *Status) MarkUnknown(t ConditionType, reason, message string)

MarkUnknown sets the status of t to unknown

func (*Status) Marshal 

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

func (*Status) MarshalTo 

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

func (*Status) MarshalToSizedBuffer 

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

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) Size 

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

func (*Status) String 

func (this *Status) String() string

func (*Status) Unmarshal 

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

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

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

func (*Status) XXX_Merge 

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

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

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

type TLS 

type TLS struct {
	// +optional
	InsecureSkipVerify bool `json:"insecureSkipVerify,omitempty" protobuf:"bytes,1,opt,name=insecureSkipVerify"`
	// CACertSecret refers to the secret that contains the CA cert
	// +optional
	CACertSecret *corev1.SecretKeySelector `json:"caCertSecret,omitempty" protobuf:"bytes,2,opt,name=caCertSecret"`
	// CertSecret refers to the secret that contains the cert
	// +optional
	CertSecret *corev1.SecretKeySelector `json:"certSecret,omitempty" protobuf:"bytes,3,opt,name=certSecret"`
	// KeySecret refers to the secret that contains the key
	// +optional
	KeySecret *corev1.SecretKeySelector `json:"keySecret,omitempty" protobuf:"bytes,4,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 TagConditions added in v0.8.0 

type TagConditions struct {
	// Operator specifies the type of operation that should be used for conditional forwarding
	// value could be "and", "or", "not"
	// +kubebuilder:validation:Enum=and;or;not
	// +optional
	Operator *LogicOperator `json:"operator" protobuf:"bytes,1,opt,name=operator"`
	// Values tag values for conditional forwarding
	Values []string `json:"values" protobuf:"bytes,2,rep,name=values"`
}

func (*TagConditions) DeepCopy added in v0.8.0 

func (in *TagConditions) DeepCopy() *TagConditions

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

func (*TagConditions) DeepCopyInto added in v0.8.0 

func (in *TagConditions) DeepCopyInto(out *TagConditions)

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

func (*TagConditions) Descriptor added in v0.8.0 

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

func (TagConditions) GetOperator added in v0.8.0 

func (tc TagConditions) GetOperator() LogicOperator

func (*TagConditions) Marshal added in v0.8.0 

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

func (*TagConditions) MarshalTo added in v0.8.0 

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

func (*TagConditions) MarshalToSizedBuffer added in v0.8.0 

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

func (*TagConditions) ProtoMessage added in v0.8.0 

func (*TagConditions) ProtoMessage()

func (*TagConditions) Reset added in v0.8.0 

func (m *TagConditions) Reset()

func (*TagConditions) Size added in v0.8.0 

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

func (*TagConditions) String added in v0.8.0 

func (this *TagConditions) String() string

func (*TagConditions) Unmarshal added in v0.8.0 

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

func (*TagConditions) XXX_DiscardUnknown added in v0.8.0 

func (m *TagConditions) XXX_DiscardUnknown()

func (*TagConditions) XXX_Marshal added in v0.8.0 

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

func (*TagConditions) XXX_Merge added in v0.8.0 

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

func (*TagConditions) XXX_Size added in v0.8.0 

func (m *TagConditions) XXX_Size() int

func (*TagConditions) XXX_Unmarshal added in v0.8.0 

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

type Templates added in v0.6.2 

type Templates struct {
	// DaemonTemplate is used to customize the Daemon Deployment.
	// +optional
	DaemonTemplate *DaemonTemplate `json:"daemon,omitempty" protobuf:"bytes,1,opt,name=daemon"`
	// JobTemplate is used to customize Jobs.
	// +optional
	JobTemplate *JobTemplate `json:"job,omitempty" protobuf:"bytes,2,opt,name=job"`
	// SideInputsManagerTemplate is used to customize the Side Inputs Manager.
	// +optional
	SideInputsManagerTemplate *SideInputsManagerTemplate `json:"sideInputsManager,omitempty" protobuf:"bytes,3,opt,name=sideInputsManager"`
	// VertexTemplate is used to customize the vertices of the pipeline.
	// +optional
	VertexTemplate *VertexTemplate `json:"vertex,omitempty" protobuf:"bytes,4,opt,name=vertex"`
}

func (*Templates) DeepCopy added in v0.6.2 

func (in *Templates) DeepCopy() *Templates

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

func (*Templates) DeepCopyInto added in v0.6.2 

func (in *Templates) DeepCopyInto(out *Templates)

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

func (*Templates) Descriptor added in v0.6.2 

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

func (*Templates) Marshal added in v0.6.2 

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

func (*Templates) MarshalTo added in v0.6.2 

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

func (*Templates) MarshalToSizedBuffer added in v0.6.2 

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

func (*Templates) ProtoMessage added in v0.6.2 

func (*Templates) ProtoMessage()

func (*Templates) Reset added in v0.6.2 

func (m *Templates) Reset()

func (*Templates) Size added in v0.6.2 

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

func (*Templates) String added in v0.6.2 

func (this *Templates) String() string

func (*Templates) Unmarshal added in v0.6.2 

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

func (*Templates) XXX_DiscardUnknown added in v0.6.2 

func (m *Templates) XXX_DiscardUnknown()

func (*Templates) XXX_Marshal added in v0.6.2 

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

func (*Templates) XXX_Merge added in v0.6.2 

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

func (*Templates) XXX_Size added in v0.6.2 

func (m *Templates) XXX_Size() int

func (*Templates) XXX_Unmarshal added in v0.6.2 

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

type Transformer added in v0.7.1 

type Transformer struct {
	// +kubebuilder:validation:Enum=eventTimeExtractor;filter;timeExtractionFilter
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// +optional
	Args []string `json:"args,omitempty" protobuf:"bytes,2,rep,name=args"`
	// +optional
	KWArgs map[string]string `json:"kwargs,omitempty" protobuf:"bytes,3,rep,name=kwargs"`
}

func (*Transformer) DeepCopy added in v0.7.1 

func (in *Transformer) DeepCopy() *Transformer

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

func (*Transformer) DeepCopyInto added in v0.7.1 

func (in *Transformer) DeepCopyInto(out *Transformer)

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

func (*Transformer) Descriptor added in v0.7.1 

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

func (*Transformer) Marshal added in v0.7.1 

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

func (*Transformer) MarshalTo added in v0.7.1 

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

func (*Transformer) MarshalToSizedBuffer added in v0.7.1 

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

func (*Transformer) ProtoMessage added in v0.7.1 

func (*Transformer) ProtoMessage()

func (*Transformer) Reset added in v0.7.1 

func (m *Transformer) Reset()

func (*Transformer) Size added in v0.7.1 

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

func (*Transformer) String added in v0.7.1 

func (this *Transformer) String() string

func (*Transformer) Unmarshal added in v0.7.1 

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

func (*Transformer) XXX_DiscardUnknown added in v0.7.1 

func (m *Transformer) XXX_DiscardUnknown()

func (*Transformer) XXX_Marshal added in v0.7.1 

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

func (*Transformer) XXX_Merge added in v0.7.1 

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

func (*Transformer) XXX_Size added in v0.7.1 

func (m *Transformer) XXX_Size() int

func (*Transformer) XXX_Unmarshal added in v0.7.1 

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

type UDF 

type UDF struct {
	// +optional
	Container *Container `json:"container" protobuf:"bytes,1,opt,name=container"`
	// +optional
	Builtin *Function `json:"builtin" protobuf:"bytes,2,opt,name=builtin"`
	// +optional
	GroupBy *GroupBy `json:"groupBy" protobuf:"bytes,3,opt,name=groupBy"`
}

func (*UDF) DeepCopy 

func (in *UDF) DeepCopy() *UDF

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

func (*UDF) DeepCopyInto 

func (in *UDF) DeepCopyInto(out *UDF)

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

func (*UDF) Descriptor 

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

func (*UDF) Marshal 

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

func (*UDF) MarshalTo 

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

func (*UDF) MarshalToSizedBuffer 

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

func (*UDF) ProtoMessage 

func (*UDF) ProtoMessage()

func (*UDF) Reset 

func (m *UDF) Reset()

func (*UDF) Size 

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

func (*UDF) String 

func (this *UDF) String() string

func (*UDF) Unmarshal 

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

func (*UDF) XXX_DiscardUnknown 

func (m *UDF) XXX_DiscardUnknown()

func (*UDF) XXX_Marshal 

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

func (*UDF) XXX_Merge 

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

func (*UDF) XXX_Size 

func (m *UDF) XXX_Size() int

func (*UDF) XXX_Unmarshal 

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

type UDSink 

type UDSink struct {
	Container Container `json:"container" protobuf:"bytes,1,opt,name=container"`
}

func (*UDSink) DeepCopy 

func (in *UDSink) DeepCopy() *UDSink

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

func (*UDSink) DeepCopyInto 

func (in *UDSink) DeepCopyInto(out *UDSink)

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

func (*UDSink) Descriptor 

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

func (*UDSink) Marshal 

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

func (*UDSink) MarshalTo 

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

func (*UDSink) MarshalToSizedBuffer 

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

func (*UDSink) ProtoMessage 

func (*UDSink) ProtoMessage()

func (*UDSink) Reset 

func (m *UDSink) Reset()

func (*UDSink) Size 

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

func (*UDSink) String 

func (this *UDSink) String() string

func (*UDSink) Unmarshal 

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

func (*UDSink) XXX_DiscardUnknown 

func (m *UDSink) XXX_DiscardUnknown()

func (*UDSink) XXX_Marshal 

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

func (*UDSink) XXX_Merge 

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

func (*UDSink) XXX_Size 

func (m *UDSink) XXX_Size() int

func (*UDSink) XXX_Unmarshal 

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

type UDSource added in v0.10.0 

type UDSource struct {
	Container *Container `json:"container" protobuf:"bytes,1,opt,name=container"`
}

func (*UDSource) DeepCopy added in v0.10.0 

func (in *UDSource) DeepCopy() *UDSource

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

func (*UDSource) DeepCopyInto added in v0.10.0 

func (in *UDSource) DeepCopyInto(out *UDSource)

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

func (*UDSource) Descriptor added in v0.10.0 

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

func (*UDSource) Marshal added in v0.10.0 

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

func (*UDSource) MarshalTo added in v0.10.0 

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

func (*UDSource) MarshalToSizedBuffer added in v0.10.0 

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

func (*UDSource) ProtoMessage added in v0.10.0 

func (*UDSource) ProtoMessage()

func (*UDSource) Reset added in v0.10.0 

func (m *UDSource) Reset()

func (*UDSource) Size added in v0.10.0 

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

func (*UDSource) String added in v0.10.0 

func (this *UDSource) String() string

func (*UDSource) Unmarshal added in v0.10.0 

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

func (*UDSource) XXX_DiscardUnknown added in v0.10.0 

func (m *UDSource) XXX_DiscardUnknown()

func (*UDSource) XXX_Marshal added in v0.10.0 

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

func (*UDSource) XXX_Merge added in v0.10.0 

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

func (*UDSource) XXX_Size added in v0.10.0 

func (m *UDSource) XXX_Size() int

func (*UDSource) XXX_Unmarshal added in v0.10.0 

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

type UDTransformer added in v0.7.1 

type UDTransformer struct {
	// +optional
	Container *Container `json:"container" protobuf:"bytes,1,opt,name=container"`
	// +optional
	Builtin *Transformer `json:"builtin" protobuf:"bytes,2,opt,name=builtin"`
}

func (*UDTransformer) DeepCopy added in v0.7.1 

func (in *UDTransformer) DeepCopy() *UDTransformer

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

func (*UDTransformer) DeepCopyInto added in v0.7.1 

func (in *UDTransformer) DeepCopyInto(out *UDTransformer)

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

func (*UDTransformer) Descriptor added in v0.7.1 

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

func (*UDTransformer) Marshal added in v0.7.1 

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

func (*UDTransformer) MarshalTo added in v0.7.1 

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

func (*UDTransformer) MarshalToSizedBuffer added in v0.7.1 

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

func (*UDTransformer) ProtoMessage added in v0.7.1 

func (*UDTransformer) ProtoMessage()

func (*UDTransformer) Reset added in v0.7.1 

func (m *UDTransformer) Reset()

func (*UDTransformer) Size added in v0.7.1 

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

func (*UDTransformer) String added in v0.7.1 

func (this *UDTransformer) String() string

func (*UDTransformer) Unmarshal added in v0.7.1 

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

func (*UDTransformer) XXX_DiscardUnknown added in v0.7.1 

func (m *UDTransformer) XXX_DiscardUnknown()

func (*UDTransformer) XXX_Marshal added in v0.7.1 

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

func (*UDTransformer) XXX_Merge added in v0.7.1 

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

func (*UDTransformer) XXX_Size added in v0.7.1 

func (m *UDTransformer) XXX_Size() int

func (*UDTransformer) XXX_Unmarshal added in v0.7.1 

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

type Vertex 

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

	Spec VertexSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	// +optional
	Status VertexStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

+genclient +kubebuilder:object:root=true +kubebuilder:resource:shortName=vtx +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` +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true

func (*Vertex) DeepCopy 

func (in *Vertex) DeepCopy() *Vertex

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

func (*Vertex) DeepCopyInto 

func (in *Vertex) DeepCopyInto(out *Vertex)

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

func (*Vertex) DeepCopyObject 

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

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

func (*Vertex) Descriptor 

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

func (Vertex) GetFromBuckets added in v0.8.1 

func (v Vertex) GetFromBuckets() []string

GetFromBuckets returns the buckets that the vertex reads from. For a source vertex, it returns the source bucket name.

func (Vertex) GetHeadlessServiceName 

func (v Vertex) GetHeadlessServiceName() string

func (Vertex) GetPartitionCount added in v0.9.0 

func (v Vertex) GetPartitionCount() int

func (Vertex) GetPodSpec 

func (v Vertex) GetPodSpec(req GetVertexPodSpecReq) (*corev1.PodSpec, error)

func (Vertex) GetReplicas added in v0.6.2 

func (v Vertex) GetReplicas() int

func (Vertex) GetServiceObjs 

func (v Vertex) GetServiceObjs() []*corev1.Service

func (Vertex) GetToBuckets added in v0.8.1 

func (v Vertex) GetToBuckets() []string

GetToBuckets returns the buckets that the vertex writes to. For a sink vertex, it returns the sink bucket name.

func (Vertex) GetToBuffers 

func (v Vertex) GetToBuffers() []string

func (Vertex) GetVertexType added in v0.8.1 

func (v Vertex) GetVertexType() VertexType

func (Vertex) HasSideInputs added in v0.10.0 

func (v Vertex) HasSideInputs() bool

func (Vertex) HasUDTransformer added in v0.7.1 

func (v Vertex) HasUDTransformer() bool

func (Vertex) IsASink 

func (v Vertex) IsASink() bool

func (Vertex) IsASource 

func (v Vertex) IsASource() bool

func (Vertex) IsMapUDF added in v0.6.1 

func (v Vertex) IsMapUDF() bool

func (Vertex) IsReduceUDF added in v0.6.1 

func (v Vertex) IsReduceUDF() bool

func (Vertex) IsUDSink added in v0.6.5 

func (v Vertex) IsUDSink() bool

func (Vertex) IsUDSource added in v0.10.0 

func (v Vertex) IsUDSource() bool

func (Vertex) MapUdfStreamEnabled added in v0.8.1 

func (v Vertex) MapUdfStreamEnabled() (bool, error)

func (*Vertex) Marshal 

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

func (*Vertex) MarshalTo 

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

func (*Vertex) MarshalToSizedBuffer 

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

func (Vertex) OwnedBuffers added in v0.8.1 

func (v Vertex) OwnedBuffers() []string

OwnedBuffers returns the buffers that the vertex owns

func (*Vertex) ProtoMessage 

func (*Vertex) ProtoMessage()

func (*Vertex) Reset 

func (m *Vertex) Reset()

func (Vertex) Scalable added in v0.5.4 

func (v Vertex) Scalable() bool

func (*Vertex) Size 

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

func (*Vertex) String 

func (this *Vertex) String() string

func (*Vertex) Unmarshal 

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

func (*Vertex) XXX_DiscardUnknown 

func (m *Vertex) XXX_DiscardUnknown()

func (*Vertex) XXX_Marshal 

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

func (*Vertex) XXX_Merge 

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

func (*Vertex) XXX_Size 

func (m *Vertex) XXX_Size() int

func (*Vertex) XXX_Unmarshal 

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

type VertexInstance added in v0.5.3 

type VertexInstance struct {
	Vertex   *Vertex `json:"vertex,omitempty" protobuf:"bytes,1,opt,name=vertex"`
	Hostname string  `json:"hostname,omitempty" protobuf:"bytes,2,opt,name=hostname"`
	Replica  int32   `json:"replica,omitempty" protobuf:"varint,3,opt,name=replica"`
}

VertexInstance is a wrapper of a vertex instance, which contains the vertex spec and the instance information such as hostname and replica index.

func (*VertexInstance) DeepCopy added in v0.5.3 

func (in *VertexInstance) DeepCopy() *VertexInstance

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

func (*VertexInstance) DeepCopyInto added in v0.5.3 

func (in *VertexInstance) DeepCopyInto(out *VertexInstance)

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

func (*VertexInstance) Descriptor added in v0.5.3 

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

func (*VertexInstance) Marshal added in v0.5.3 

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

func (*VertexInstance) MarshalTo added in v0.5.3 

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

func (*VertexInstance) MarshalToSizedBuffer added in v0.5.3 

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

func (*VertexInstance) ProtoMessage added in v0.5.3 

func (*VertexInstance) ProtoMessage()

func (*VertexInstance) Reset added in v0.5.3 

func (m *VertexInstance) Reset()

func (*VertexInstance) Size added in v0.5.3 

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

func (*VertexInstance) String added in v0.5.3 

func (this *VertexInstance) String() string

func (*VertexInstance) Unmarshal added in v0.5.3 

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

func (*VertexInstance) XXX_DiscardUnknown added in v0.5.3 

func (m *VertexInstance) XXX_DiscardUnknown()

func (*VertexInstance) XXX_Marshal added in v0.5.3 

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

func (*VertexInstance) XXX_Merge added in v0.5.3 

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

func (*VertexInstance) XXX_Size added in v0.5.3 

func (m *VertexInstance) XXX_Size() int

func (*VertexInstance) XXX_Unmarshal added in v0.5.3 

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

type VertexLimits 

type VertexLimits struct {
	// Read batch size from the source or buffer.
	// It overrides the settings from pipeline limits.
	// +optional
	ReadBatchSize *uint64 `json:"readBatchSize,omitempty" protobuf:"varint,1,opt,name=readBatchSize"`
	// Read timeout duration from the source or buffer
	// It overrides the settings from pipeline limits.
	// +optional
	ReadTimeout *metav1.Duration `json:"readTimeout,omitempty" protobuf:"bytes,2,opt,name=readTimeout"`
	// BufferMaxLength is used to define the max length of a buffer.
	// It overrides the settings from pipeline limits.
	// +optional
	BufferMaxLength *uint64 `json:"bufferMaxLength,omitempty" protobuf:"varint,3,opt,name=bufferMaxLength"`
	// BufferUsageLimit is used to define the percentage of the buffer usage limit, a valid value should be less than 100, for example, 85.
	// It overrides the settings from pipeline limits.
	// +optional
	BufferUsageLimit *uint32 `json:"bufferUsageLimit,omitempty" protobuf:"varint,4,opt,name=bufferUsageLimit"`
}

func (*VertexLimits) DeepCopy 

func (in *VertexLimits) DeepCopy() *VertexLimits

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

func (*VertexLimits) DeepCopyInto 

func (in *VertexLimits) DeepCopyInto(out *VertexLimits)

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

func (*VertexLimits) Descriptor 

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

func (*VertexLimits) Marshal 

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

func (*VertexLimits) MarshalTo 

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

func (*VertexLimits) MarshalToSizedBuffer 

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

func (*VertexLimits) ProtoMessage 

func (*VertexLimits) ProtoMessage()

func (*VertexLimits) Reset 

func (m *VertexLimits) Reset()

func (*VertexLimits) Size 

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

func (*VertexLimits) String 

func (this *VertexLimits) String() string

func (*VertexLimits) Unmarshal 

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

func (*VertexLimits) XXX_DiscardUnknown 

func (m *VertexLimits) XXX_DiscardUnknown()

func (*VertexLimits) XXX_Marshal 

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

func (*VertexLimits) XXX_Merge 

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

func (*VertexLimits) XXX_Size 

func (m *VertexLimits) XXX_Size() int

func (*VertexLimits) XXX_Unmarshal 

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

type VertexList 

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

+kubebuilder:object:root=true +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*VertexList) DeepCopy 

func (in *VertexList) DeepCopy() *VertexList

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

func (*VertexList) DeepCopyInto 

func (in *VertexList) DeepCopyInto(out *VertexList)

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

func (*VertexList) DeepCopyObject 

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

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

func (*VertexList) Descriptor 

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

func (*VertexList) Marshal 

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

func (*VertexList) MarshalTo 

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

func (*VertexList) MarshalToSizedBuffer 

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

func (*VertexList) ProtoMessage 

func (*VertexList) ProtoMessage()

func (*VertexList) Reset 

func (m *VertexList) Reset()

func (*VertexList) Size 

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

func (*VertexList) String 

func (this *VertexList) String() string

func (*VertexList) Unmarshal 

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

func (*VertexList) XXX_DiscardUnknown 

func (m *VertexList) XXX_DiscardUnknown()

func (*VertexList) XXX_Marshal 

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

func (*VertexList) XXX_Merge 

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

func (*VertexList) XXX_Size 

func (m *VertexList) XXX_Size() int

func (*VertexList) XXX_Unmarshal 

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

type VertexPhase 

type VertexPhase string

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

const (
	VertexPhaseUnknown   VertexPhase = ""
	VertexPhasePending   VertexPhase = "Pending"
	VertexPhaseRunning   VertexPhase = "Running"
	VertexPhaseSucceeded VertexPhase = "Succeeded"
	VertexPhaseFailed    VertexPhase = "Failed"
)

type VertexSpec 

type VertexSpec struct {
	AbstractVertex `json:",inline" protobuf:"bytes,1,opt,name=abstractVertex"`
	PipelineName   string `json:"pipelineName" protobuf:"bytes,2,opt,name=pipelineName"`
	// +optional
	InterStepBufferServiceName string `json:"interStepBufferServiceName" protobuf:"bytes,3,opt,name=interStepBufferServiceName"`
	// +kubebuilder:default=1
	// +optional
	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,4,opt,name=replicas"`
	// +optional
	FromEdges []CombinedEdge `json:"fromEdges,omitempty" protobuf:"bytes,5,rep,name=fromEdges"`
	// +optional
	ToEdges []CombinedEdge `json:"toEdges,omitempty" protobuf:"bytes,6,rep,name=toEdges"`
	// Watermark indicates watermark progression in the vertex, it's populated from the pipeline watermark settings.
	// +kubebuilder:default={"disabled": false}
	// +optional
	Watermark Watermark `json:"watermark,omitempty" protobuf:"bytes,7,opt,name=watermark"`
}

func (*VertexSpec) DeepCopy 

func (in *VertexSpec) DeepCopy() *VertexSpec

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

func (*VertexSpec) DeepCopyInto 

func (in *VertexSpec) DeepCopyInto(out *VertexSpec)

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

func (*VertexSpec) Descriptor 

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

func (*VertexSpec) Marshal 

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

func (*VertexSpec) MarshalTo 

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

func (*VertexSpec) MarshalToSizedBuffer 

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

func (*VertexSpec) ProtoMessage 

func (*VertexSpec) ProtoMessage()

func (*VertexSpec) Reset 

func (m *VertexSpec) Reset()

func (*VertexSpec) Size 

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

func (*VertexSpec) String 

func (this *VertexSpec) String() string

func (*VertexSpec) Unmarshal 

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

func (VertexSpec) WithOutReplicas 

func (vs VertexSpec) WithOutReplicas() VertexSpec

func (*VertexSpec) XXX_DiscardUnknown 

func (m *VertexSpec) XXX_DiscardUnknown()

func (*VertexSpec) XXX_Marshal 

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

func (*VertexSpec) XXX_Merge 

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

func (*VertexSpec) XXX_Size 

func (m *VertexSpec) XXX_Size() int

func (*VertexSpec) XXX_Unmarshal 

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

type VertexStatus 

type VertexStatus struct {
	Phase        VertexPhase `json:"phase" protobuf:"bytes,1,opt,name=phase,casttype=VertexPhase"`
	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 (*VertexStatus) DeepCopy 

func (in *VertexStatus) DeepCopy() *VertexStatus

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

func (*VertexStatus) DeepCopyInto 

func (in *VertexStatus) DeepCopyInto(out *VertexStatus)

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

func (*VertexStatus) Descriptor 

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

func (*VertexStatus) MarkPhase 

func (vs *VertexStatus) MarkPhase(phase VertexPhase, reason, message string)

func (*VertexStatus) MarkPhaseFailed 

func (vs *VertexStatus) MarkPhaseFailed(reason, message string)

func (*VertexStatus) MarkPhaseRunning 

func (vs *VertexStatus) MarkPhaseRunning()

func (*VertexStatus) Marshal 

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

func (*VertexStatus) MarshalTo 

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

func (*VertexStatus) MarshalToSizedBuffer 

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

func (*VertexStatus) ProtoMessage 

func (*VertexStatus) ProtoMessage()

func (*VertexStatus) Reset 

func (m *VertexStatus) Reset()

func (*VertexStatus) Size 

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

func (*VertexStatus) String 

func (this *VertexStatus) String() string

func (*VertexStatus) Unmarshal 

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

func (*VertexStatus) XXX_DiscardUnknown 

func (m *VertexStatus) XXX_DiscardUnknown()

func (*VertexStatus) XXX_Marshal 

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

func (*VertexStatus) XXX_Merge 

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

func (*VertexStatus) XXX_Size 

func (m *VertexStatus) XXX_Size() int

func (*VertexStatus) XXX_Unmarshal 

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

type VertexTemplate added in v0.10.0 

type VertexTemplate struct {
	// +optional
	AbstractPodTemplate `json:",inline" protobuf:"bytes,1,opt,name=abstractPodTemplate"`
	// Template for the vertex numa container
	// +optional
	ContainerTemplate *ContainerTemplate `json:"containerTemplate,omitempty" protobuf:"bytes,2,opt,name=containerTemplate"`
	// Template for the vertex init container
	// +optional
	InitContainerTemplate *ContainerTemplate `json:"initContainerTemplate,omitempty" protobuf:"bytes,3,opt,name=initContainerTemplate"`
}

func (*VertexTemplate) DeepCopy added in v0.10.0 

func (in *VertexTemplate) DeepCopy() *VertexTemplate

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

func (*VertexTemplate) DeepCopyInto added in v0.10.0 

func (in *VertexTemplate) DeepCopyInto(out *VertexTemplate)

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

func (*VertexTemplate) Descriptor added in v0.10.0 

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

func (*VertexTemplate) Marshal added in v0.10.0 

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

func (*VertexTemplate) MarshalTo added in v0.10.0 

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

func (*VertexTemplate) MarshalToSizedBuffer added in v0.10.0 

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

func (*VertexTemplate) ProtoMessage added in v0.10.0 

func (*VertexTemplate) ProtoMessage()

func (*VertexTemplate) Reset added in v0.10.0 

func (m *VertexTemplate) Reset()

func (*VertexTemplate) Size added in v0.10.0 

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

func (*VertexTemplate) String added in v0.10.0 

func (this *VertexTemplate) String() string

func (*VertexTemplate) Unmarshal added in v0.10.0 

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

func (*VertexTemplate) XXX_DiscardUnknown added in v0.10.0 

func (m *VertexTemplate) XXX_DiscardUnknown()

func (*VertexTemplate) XXX_Marshal added in v0.10.0 

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

func (*VertexTemplate) XXX_Merge added in v0.10.0 

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

func (*VertexTemplate) XXX_Size added in v0.10.0 

func (m *VertexTemplate) XXX_Size() int

func (*VertexTemplate) XXX_Unmarshal added in v0.10.0 

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

type VertexType added in v0.6.1 

type VertexType string
const (
	VertexTypeSource    VertexType = "Source"
	VertexTypeSink      VertexType = "Sink"
	VertexTypeMapUDF    VertexType = "MapUDF"
	VertexTypeReduceUDF VertexType = "ReduceUDF"
)

type Watermark 

type Watermark struct {
	// Disabled toggles the watermark propagation, defaults to false.
	// +kubebuilder:default=false
	// +optional
	Disabled bool `json:"disabled,omitempty" protobuf:"bytes,1,opt,name=disabled"`
	// Maximum delay allowed for watermark calculation, defaults to "0s", which means no delay.
	// +kubebuilder:default="0s"
	// +optional
	MaxDelay *metav1.Duration `json:"maxDelay,omitempty" protobuf:"bytes,2,opt,name=maxDelay"`
	// IdleSource defines the idle watermark properties, it could be configured in case source is idling.
	// +optional
	IdleSource *IdleSource `json:"idleSource,omitempty" protobuf:"bytes,3,opt,name=idleSource"`
}

func (*Watermark) DeepCopy 

func (in *Watermark) DeepCopy() *Watermark

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

func (*Watermark) DeepCopyInto 

func (in *Watermark) DeepCopyInto(out *Watermark)

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

func (*Watermark) Descriptor 

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

func (Watermark) GetMaxDelay added in v0.6.1 

func (wm Watermark) GetMaxDelay() time.Duration

GetMaxDelay returns the configured max delay with a default value.

func (*Watermark) Marshal 

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

func (*Watermark) MarshalTo 

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

func (*Watermark) MarshalToSizedBuffer 

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

func (*Watermark) ProtoMessage 

func (*Watermark) ProtoMessage()

func (*Watermark) Reset 

func (m *Watermark) Reset()

func (*Watermark) Size 

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

func (*Watermark) String 

func (this *Watermark) String() string

func (*Watermark) Unmarshal 

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

func (*Watermark) XXX_DiscardUnknown 

func (m *Watermark) XXX_DiscardUnknown()

func (*Watermark) XXX_Marshal 

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

func (*Watermark) XXX_Merge 

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

func (*Watermark) XXX_Size 

func (m *Watermark) XXX_Size() int

func (*Watermark) XXX_Unmarshal 

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

type Window added in v0.6.1 

type Window struct {
	// +optional
	Fixed *FixedWindow `json:"fixed" protobuf:"bytes,1,opt,name=fixed"`
	// +optional
	Sliding *SlidingWindow `json:"sliding" protobuf:"bytes,2,opt,name=sliding"`
}

Window describes windowing strategy

func (*Window) DeepCopy added in v0.6.1 

func (in *Window) DeepCopy() *Window

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

func (*Window) DeepCopyInto added in v0.6.1 

func (in *Window) DeepCopyInto(out *Window)

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

func (*Window) Descriptor added in v0.6.1 

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

func (*Window) Marshal added in v0.6.1 

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

func (*Window) MarshalTo added in v0.6.1 

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

func (*Window) MarshalToSizedBuffer added in v0.6.1 

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

func (*Window) ProtoMessage added in v0.6.1 

func (*Window) ProtoMessage()

func (*Window) Reset added in v0.6.1 

func (m *Window) Reset()

func (*Window) Size added in v0.6.1 

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

func (*Window) String added in v0.6.1 

func (this *Window) String() string

func (*Window) Unmarshal added in v0.6.1 

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

func (*Window) XXX_DiscardUnknown added in v0.6.1 

func (m *Window) XXX_DiscardUnknown()

func (*Window) XXX_Marshal added in v0.6.1 

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

func (*Window) XXX_Merge added in v0.6.1 

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

func (*Window) XXX_Size added in v0.6.1 

func (m *Window) XXX_Size() int

func (*Window) XXX_Unmarshal added in v0.6.1 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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