v1alpha1

package
v0.7.1 Latest Latest
Warning

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

 Go to latest Published: Feb 14, 2023 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"
	KeyDefaultContainer = "kubectl.kubernetes.io/default-container"

	// 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"
	CtrUdtransformer = "transformer"

	// components
	ComponentISBSvc = "isbsvc"
	ComponentDaemon = "daemon"
	ComponentVertex = "vertex"
	ComponentJob    = "job"

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

	// 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"
	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"
	EnvDebug                          = "NUMAFLOW_DEBUG"
	EnvPPROF                          = "NUMAFLOW_PPROF"
	EnvHealthCheckDisabled            = "NUMAFLOW_HEALTH_CHECK_DISABLED"
	EnvGRPCMaxMessageSize             = "NUMAFLOW_GRPC_MAX_MESSAGE_SIZE"

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

	DefaultRequeueAfter = 10 * time.Second

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

	// Auto scaling
	DefaultLookbackSeconds         = 180 // Default lookback seconds for calculating avg rate and pending
	DefaultCooldownSeconds         = 90  // Default cooldown seconds after a scaling operation
	DefaultZeroReplicaSleepSeconds = 180 // 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
	DefaultTargetBufferUsage       = 50  // Default targeted percentage of balanced buffer usage
	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"

	// Default gRPC max message size
	DefaultGRPCMaxMessageSize = 20 * 1024 * 1024
)
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 (
	MessageKeyDrop = fmt.Sprintf("%U__DROP__", '\\') // U+005C__DROP__
	MessageKeyAll  = 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 GenerateEdgeBufferNames added in v0.6.1 

func GenerateEdgeBufferNames(namespace, pipelineName string, edge Edge) []string

GenerateEdgeBufferNames generates buffer names for an edge

func GeneratePBQStoragePVCName added in v0.6.2 

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

GeneratePBQStoragePVCName generates pvc name used by reduce vertex.

func GenerateSinkBufferName added in v0.5.2 

func GenerateSinkBufferName(namespace, pipelineName, vertex string) string

func GenerateSourceBufferName added in v0.5.2 

func GenerateSourceBufferName(namespace, pipelineName, 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"`
}

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,rep,name=source"`
	// +optional
	Sink *Sink `json:"sink,omitempty" protobuf:"bytes,3,rep,name=sink"`
	// +optional
	UDF *UDF `json:"udf,omitempty" protobuf:"bytes,4,rep,name=udf"`
	// +optional
	ContainerTemplate *ContainerTemplate `json:"containerTemplate,omitempty" protobuf:"bytes,5,rep,name=containerTemplate"`
	// +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 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 sidecar containers belonging to the pod.
	// +optional
	Sidecars []corev1.Container `json:"sidecars,omitempty" protobuf:"bytes,12,rep,name=sidecars"`
}

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) 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) 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 Buffer added in v0.5.2 

type Buffer struct {
	Name string     `protobuf:"bytes,1,opt,name=name"`
	Type BufferType `protobuf:"bytes,2,opt,name=type,casttype=BufferType"`
}

func (*Buffer) DeepCopy added in v0.5.2 

func (in *Buffer) DeepCopy() *Buffer

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

func (*Buffer) DeepCopyInto added in v0.5.2 

func (in *Buffer) DeepCopyInto(out *Buffer)

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

func (*Buffer) Descriptor added in v0.5.2 

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

func (*Buffer) Marshal added in v0.5.2 

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

func (*Buffer) MarshalTo added in v0.5.2 

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

func (*Buffer) MarshalToSizedBuffer added in v0.5.2 

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

func (*Buffer) ProtoMessage added in v0.5.2 

func (*Buffer) ProtoMessage()

func (*Buffer) Reset added in v0.5.2 

func (m *Buffer) Reset()

func (*Buffer) Size added in v0.5.2 

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

func (*Buffer) String added in v0.5.2 

func (this *Buffer) String() string

func (*Buffer) Unmarshal added in v0.5.2 

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

func (*Buffer) XXX_DiscardUnknown added in v0.5.2 

func (m *Buffer) XXX_DiscardUnknown()

func (*Buffer) XXX_Marshal added in v0.5.2 

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

func (*Buffer) XXX_Merge added in v0.5.2 

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

func (*Buffer) XXX_Size added in v0.5.2 

func (m *Buffer) XXX_Size() int

func (*Buffer) XXX_Unmarshal added in v0.5.2 

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

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 BufferType added in v0.5.2 

type BufferType string
const (
	SourceBuffer BufferType = "so"
	SinkBuffer   BufferType = "si"
	EdgeBuffer   BufferType = "ed"
)

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
	VolumeMounts []corev1.VolumeMount `json:"volumeMounts,omitempty" protobuf:"bytes,5,rep,name=volumeMounts"`
	// +optional
	Resources corev1.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,6,opt,name=resources"`
	// +optional
	SecurityContext *corev1.SecurityContext `json:"securityContext,omitempty" protobuf:"bytes,7,opt,name=securityContext"`
}

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

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"`
	// Limits define the limitations such as buffer read batch size for the edge, will override pipeline level settings.
	// +optional
	Limits *EdgeLimits `json:"limits,omitempty" protobuf:"bytes,4,opt,name=limits"`
	// Parallelism is only effective when the "to" vertex is a reduce vertex,
	// if it's provided, the default value is set to "1".
	// Parallelism is ignored when the "to" vertex is not a reduce vertex.
	// +optional
	Parallelism *int32 `json:"parallelism" protobuf:"bytes,5,opt,name=parallelism"`
}

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) 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 EdgeLimits added in v0.5.3 

type EdgeLimits struct {
	// 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,1,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,2,opt,name=bufferUsageLimit"`
}

func (*EdgeLimits) DeepCopy added in v0.5.3 

func (in *EdgeLimits) DeepCopy() *EdgeLimits

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

func (*EdgeLimits) DeepCopyInto added in v0.5.3 

func (in *EdgeLimits) DeepCopyInto(out *EdgeLimits)

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

func (*EdgeLimits) Descriptor added in v0.5.3 

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

func (*EdgeLimits) Marshal added in v0.5.3 

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

func (*EdgeLimits) MarshalTo added in v0.5.3 

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

func (*EdgeLimits) MarshalToSizedBuffer added in v0.5.3 

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

func (*EdgeLimits) ProtoMessage added in v0.5.3 

func (*EdgeLimits) ProtoMessage()

func (*EdgeLimits) Reset added in v0.5.3 

func (m *EdgeLimits) Reset()

func (*EdgeLimits) Size added in v0.5.3 

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

func (*EdgeLimits) String added in v0.5.3 

func (this *EdgeLimits) String() string

func (*EdgeLimits) Unmarshal added in v0.5.3 

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

func (*EdgeLimits) XXX_DiscardUnknown added in v0.5.3 

func (m *EdgeLimits) XXX_DiscardUnknown()

func (*EdgeLimits) XXX_Marshal added in v0.5.3 

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

func (*EdgeLimits) XXX_Merge added in v0.5.3 

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

func (*EdgeLimits) XXX_Size added in v0.5.3 

func (m *EdgeLimits) XXX_Size() int

func (*EdgeLimits) XXX_Unmarshal added in v0.5.3 

func (m *EdgeLimits) 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 {
	KeyIn []string `json:"keyIn" protobuf:"bytes,1,rep,name=keyIn"`
}

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

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

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

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

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

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"`
	// Storage is used to define the PBQ storage for a reduce vertex.
	Storage *PBQStorage `json:"storage,omitempty" protobuf:"bytes,3,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 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"`
	// JetStream configuration, if not specified, global settings in numaflow-controller-config will be used.
	// See https://docs.nats.io/running-a-nats-service/configuration#jetstream.
	// Only configure "max_memory_store" or "max_file_store", 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 encypting/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
	BufferConfig string `json:"bufferConfig,omitempty" protobuf:"bytes,3,opt,name=bufferConfig"`
	// 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 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"`
}

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

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

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) 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 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) FindEdgeWithBuffer added in v0.5.3 

func (p Pipeline) FindEdgeWithBuffer(buffer string) *Edge

FindEdgeWithBuffer is used to locate the edge of the buffer.

func (Pipeline) GetAllBuffers 

func (p Pipeline) GetAllBuffers() []Buffer

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) 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) 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) 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 vertice 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 vertice 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}
	// +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 is used to customize additional kubernetes resources required for the Pipeline
	// +optional
	Templates *Templates `json:"templates,omitempty" protobuf:"bytes,7,opt,name=templates"`
}

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) 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 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"`
	// Cooldown seconds after a scaling operation before another one.
	// +optional
	CooldownSeconds *uint32 `json:"cooldownSeconds,omitempty" protobuf:"varint,5,opt,name=cooldownSeconds"`
	// After scaling down to 0, sleep how many seconds before scaling 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"`
	// TargetBufferUsage is used to define the target percentage of usage of the buffer to be read.
	// 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 as only they have buffers to read.
	// +optional
	TargetBufferUsage *uint32 `json:"targetBufferUsage,omitempty" protobuf:"varint,8,opt,name=targetBufferUsage"`
	// 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"`
}

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) GetCooldownSeconds added in v0.5.4 

func (s Scale) GetCooldownSeconds() 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) GetTargetBufferUsage added in v0.5.4 

func (s Scale) GetTargetBufferUsage() 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 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"`
}

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:"clientCertSecret,omitempty" protobuf:"bytes,3,opt,name=certSecret"`
	// KeySecret refers to the secret that contains the key
	// +optional
	KeySecret *corev1.SecretKeySelector `json:"clientKeySecret,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 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"`
}

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

func (v Vertex) GetFromBuffers() []Buffer

func (Vertex) GetHeadlessServiceName 

func (v Vertex) GetHeadlessServiceName() string

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

func (v Vertex) GetToBuffers() []Buffer

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

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 []Edge `json:"fromEdges,omitempty" protobuf:"bytes,5,rep,name=fromEdges"`
	// +optional
	ToEdges []Edge `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 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"`
}

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.