v1alpha1

package
v0.5.2 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2022 License: Apache-2.0 Imports: 23 Imported by: 5

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"

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

	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   = "main"
	CtrUdf    = "udf"
	CtrUdsink = "udsink"

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

	// 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"
	EnvUDFContentType              = "NUMAFLOW_UDF_CONTENT_TYPE"
	EnvUDSinkContentType           = "NUMAFLOW_UDSINK_CONTENT_TYPE" // Content-Type for the user defined sinks
	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"
	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"

	// Watermark
	EnvWatermarkOn = "NUMAFLOW_WATERMARK_ON"

	PathVarRun        = "/var/run/numaflow"
	VertexMetricsPort = 2469
	VertexHTTPSPort   = 8443
	DaemonServicePort = 4327

	DefaultRequeueAfter = 10 * time.Second

	DefaultBufferLength     = 50000
	DefaultBufferUsageLimit = 0.8

	UDFApplierMessageKey = "x-numa-message-key" // The key in the UDF applier HTTP header used to pass the map-reduce key
)
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")
)

Functions

func GenerateEdgeBufferName added in v0.5.2 

func GenerateEdgeBufferName(namespace, pipelineName, fromVetex, toVertex string) string

GenerateEdgeBufferName generates buffer name

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 Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type AbstractVertex 

type AbstractVertex struct {
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// +optional
	Source *Source `json:"source,omitempty" protobuf:"bytes,3,rep,name=source"`
	// +optional
	Sink *Sink `json:"sink,omitempty" protobuf:"bytes,4,rep,name=sink"`
	// +optional
	ContainerTemplate *ContainerTemplate `json:"containerTemplate,omitempty" protobuf:"bytes,5,rep,name=containerTemplate"`
	// +optional
	UDF *UDF `json:"udf,omitempty" protobuf:"bytes,6,rep,name=udf"`
	// Metadata sets the pods's metadata, i.e. annotations and labels
	Metadata *Metadata `json:"metadata,omitempty" protobuf:"bytes,7,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,8,rep,name=nodeSelector"`
	// If specified, the pod's tolerations.
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,9,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,10,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,11,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,12,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,13,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,14,opt,name=affinity"`
	// ServiceAccountName to apply to the StatefulSet
	// +optional
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,15,opt,name=serviceAccountName"`
	// +patchStrategy=merge
	// +patchMergeKey=name
	Volumes []corev1.Volume `json:"volumes,omitempty" protobuf:"bytes,16,rep,name=volumes"`
	// Limits define the limitations such as buffer read batch size for all the vertices of a pipleine, will override pipeline level settings
	// +optional
	Limits *VertexLimits `json:"limits,omitempty" protobuf:"bytes,17,opt,name=limits"`
	// +optional
	Scale Scale `json:"scale,omitempty" protobuf:"bytes,18,opt,name=scale"`
}

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

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 {
	Resources       corev1.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,1,opt,name=resources"`
	ImagePullPolicy corev1.PullPolicy           `json:"imagePullPolicy,omitempty" protobuf:"bytes,2,opt,name=imagePullPolicy,casttype=PullPolicy"`
	SecurityContext *corev1.SecurityContext     `json:"securityContext,omitempty" protobuf:"bytes,3,opt,name=securityContext"`
	Env             []corev1.EnvVar             `json:"env,omitempty" protobuf:"bytes,4,rep,name=env"`
}

ContainerTemplate defines customized spec for a container

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 ContentType 

type ContentType string
const (
	JsonType    ContentType = "application/json"
	MsgPackType ContentType = "application/msgpack"
)

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

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 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 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="Phase",type=string,JSONPath=`.status.phase` +kubebuilder:printcolumn:name="Message",type=string,JSONPath=`.status.message` +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     *RedisBuferService      `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"`
}

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) 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"`
	// Metadata sets the pods's metadata, i.e. annotations and labels
	Metadata *Metadata `json:"metadata,omitempty" protobuf:"bytes,77,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,8,rep,name=nodeSelector"`
	// If specified, the pod's tolerations.
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,9,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,10,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,11,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,12,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,13,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,14,opt,name=affinity"`
	// ServiceAccountName to apply to the StatefulSet
	// +optional
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,15,opt,name=serviceAccountName"`
	// 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,16,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,17,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,18,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,19,opt,name=encryption"`
	// Whether enable TLS, defaults to false
	// Enabling TLS might impact the performance
	// +optional
	TLS bool `json:"tls,omitempty" protobuf:"bytes,20,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 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) 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 NATSAuth 

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

func (*NATSAuth) DeepCopy 

func (in *NATSAuth) DeepCopy() *NATSAuth

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

func (*NATSAuth) DeepCopyInto 

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 

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

func (*NATSAuth) Marshal 

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

func (*NATSAuth) MarshalTo 

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

func (*NATSAuth) MarshalToSizedBuffer 

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

func (*NATSAuth) ProtoMessage 

func (*NATSAuth) ProtoMessage()

func (*NATSAuth) Reset 

func (m *NATSAuth) Reset()

func (*NATSAuth) Size 

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

func (*NATSAuth) String 

func (this *NATSAuth) String() string

func (*NATSAuth) Unmarshal 

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

func (*NATSAuth) XXX_DiscardUnknown 

func (m *NATSAuth) XXX_DiscardUnknown()

func (*NATSAuth) XXX_Marshal 

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

func (*NATSAuth) XXX_Merge 

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

func (*NATSAuth) XXX_Size 

func (m *NATSAuth) XXX_Size() int

func (*NATSAuth) XXX_Unmarshal 

func (m *NATSAuth) 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
	Persistence *PersistenceStrategy `json:"persistence,omitempty" protobuf:"bytes,6,opt,name=persistence"`
	// Metadata sets the pods's metadata, i.e. annotations and labels
	Metadata *Metadata `json:"metadata,omitempty" protobuf:"bytes,7,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,8,rep,name=nodeSelector"`
	// If specified, the pod's tolerations.
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,9,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,10,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,11,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,12,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,13,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,14,opt,name=affinity"`
	// ServiceAccountName to apply to the StatefulSet
	// +optional
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,15,opt,name=serviceAccountName"`
	// Redis configuration, if not specified, global settings in numaflow-controller-config will be used.
	// +optional
	Settings *RedisSettings `json:"settings,omitempty" protobuf:"bytes,16,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 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) 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` +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) FindVerticesWithEdgeBuffer added in v0.5.2 

func (p Pipeline) FindVerticesWithEdgeBuffer(buffer string) (from, to *AbstractVertex)

FindVerticesWithEdgeBuffer is used to locate the vertices who write and read from 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) GetFromEdges 

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

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) 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=100
	// +optional
	ReadBatchSize *uint64 `json:"readBatchSize,omitempty" protobuf:"varint,1,opt,name=readBatchSize"`
	// Workers used to concurrently call UDF functions, it's only meaningful for UDF vertex, and will be ignored by source and sink vertices.
	// It can be overridden by the vertex's limit settings
	// +kubebuilder:default=100
	// +optional
	UDFWorkers *uint32 `json:"udfWorkers,omitempty" protobuf:"varint,2,opt,name=udfWorkers"`
	// 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=10000
	// +optional
	BufferMaxLength *uint64 `json:"bufferMaxLength,omitempty" protobuf:"varint,3,opt,name=bufferMaxLength"`
	// BufferUsageLimit is used to define the pencentage 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,4,opt,name=bufferUsageLimit"`
}

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" 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
	// +patchStrategy=merge
	// +patchMergeKey=name
	// +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 pipleine, they could be overridden by each vertex's settings
	// +kubebuilder:default={"readBatchSize": 100, "udfWorkers": 100, "bufferMaxLength": 10000, "bufferUsageLimit": 80}
	// +optional
	Limits *PipelineLimits `json:"limits,omitempty" protobuf:"bytes,5,opt,name=limits"`
	// Watermark enables watermark progression across the entire pipeline. Updating this after the pipeline has been
	// created will have no impact and will be ignored. To make the pipeline honor any changes to the setting, the pipeline
	// should be recreated.
	// +kubebuilder:default={"propagate": false}
	// +optional
	Watermark Watermark `json:"watermark,omitempty" protobuf:"bytes,6,opt,name=watermark"`
}

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

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

type RedisBuferService 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 (*RedisBuferService) DeepCopy 

func (in *RedisBuferService) DeepCopy() *RedisBuferService

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

func (*RedisBuferService) DeepCopyInto 

func (in *RedisBuferService) DeepCopyInto(out *RedisBuferService)

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

func (*RedisBuferService) Descriptor 

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

func (*RedisBuferService) Marshal 

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

func (*RedisBuferService) MarshalTo 

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

func (*RedisBuferService) MarshalToSizedBuffer 

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

func (*RedisBuferService) ProtoMessage 

func (*RedisBuferService) ProtoMessage()

func (*RedisBuferService) Reset 

func (m *RedisBuferService) Reset()

func (*RedisBuferService) Size 

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

func (*RedisBuferService) String 

func (this *RedisBuferService) String() string

func (*RedisBuferService) Unmarshal 

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

func (*RedisBuferService) XXX_DiscardUnknown 

func (m *RedisBuferService) XXX_DiscardUnknown()

func (*RedisBuferService) XXX_Marshal 

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

func (*RedisBuferService) XXX_Merge 

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

func (*RedisBuferService) XXX_Size 

func (m *RedisBuferService) XXX_Size() int

func (*RedisBuferService) XXX_Unmarshal 

func (m *RedisBuferService) 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 {
	// Minimal replicas
	// +kubebuilder:default=1
	// +optional
	Min *int32 `json:"min,omitempty" protobuf:"varint,1,opt,name=min"`
	// Maximum replicas
	// +kubebuilder:default=1
	// +optional
	Max *int32 `json:"max,omitempty" protobuf:"varint,2,opt,name=max"`
}

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) 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"`
	UDSink *UDSink    `json:"udsink,omitempty" protobuf:"bytes,3,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 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"`
}

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 contions 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 ToVertex 

type ToVertex struct {
	Name string `json:"name" protobuf:"bytes,1,opt,name=name"`
	// +optional
	Conditions *ForwardConditions `json:"conditions" protobuf:"bytes,2,opt,name=conditions"`
}

func (*ToVertex) DeepCopy 

func (in *ToVertex) DeepCopy() *ToVertex

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

func (*ToVertex) DeepCopyInto 

func (in *ToVertex) DeepCopyInto(out *ToVertex)

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

func (*ToVertex) Descriptor 

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

func (*ToVertex) Marshal 

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

func (*ToVertex) MarshalTo 

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

func (*ToVertex) MarshalToSizedBuffer 

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

func (*ToVertex) ProtoMessage 

func (*ToVertex) ProtoMessage()

func (*ToVertex) Reset 

func (m *ToVertex) Reset()

func (*ToVertex) Size 

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

func (*ToVertex) String 

func (this *ToVertex) String() string

func (*ToVertex) Unmarshal 

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

func (*ToVertex) XXX_DiscardUnknown 

func (m *ToVertex) XXX_DiscardUnknown()

func (*ToVertex) XXX_Marshal 

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

func (*ToVertex) XXX_Merge 

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

func (*ToVertex) XXX_Size 

func (m *ToVertex) XXX_Size() int

func (*ToVertex) XXX_Unmarshal 

func (m *ToVertex) 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,12,opt,name=builtin"`
}

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

func (v Vertex) GetServiceObjs() []*corev1.Service

func (Vertex) GetToBuffers 

func (v Vertex) GetToBuffers() []Buffer

func (Vertex) IsASink 

func (v Vertex) IsASink() bool

func (Vertex) IsASource 

func (v Vertex) IsASource() bool

func (Vertex) IsAnUDF 

func (v Vertex) IsAnUDF() 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) 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 VertexLimits 

type VertexLimits struct {
	// Read batch size
	// +optional
	ReadBatchSize *uint64 `json:"readBatchSize,omitempty" protobuf:"varint,1,opt,name=readBatchSize"`
	// Workers used to concurrently call UDF functions, it's only meaningful for UDF vertex, and will be ignored by source and sink vertices.
	// It overrides the setting in pipeline limits.
	// +optional
	UDFWorkers *uint32 `json:"udfWorkers,omitempty" protobuf:"varint,2,opt,name=udfWorkers"`
	// BufferMaxLength is used to define the max length of a buffer.
	// It overrides the settings from pipeline limits.
	// Only meaningful for UDF and Source vertice as only they do buffer write.
	// +optional
	BufferMaxLength *uint64 `json:"bufferMaxLength,omitempty" protobuf:"varint,3,opt,name=bufferMaxLength"`
	// BufferUsageLimit is used to define the pencentage of the buffer usage limit, a valid value should be less than 100, for example, 85.
	// It overrides the settings from pipeline limits.
	// Only meaningful for UDF and Source vertice as only they do buffer write.
	// +optional
	BufferUsageLimit *uint32 `json:"bufferUsageLimit,omitempty" protobuf:"varint,4,opt,name=bufferUsageLimit"`
}

func (*VertexLimits) DeepCopy 

func (in *VertexLimits) DeepCopy() *VertexLimits

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

func (*VertexLimits) DeepCopyInto 

func (in *VertexLimits) DeepCopyInto(out *VertexLimits)

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

func (*VertexLimits) Descriptor 

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

func (*VertexLimits) Marshal 

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

func (*VertexLimits) MarshalTo 

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

func (*VertexLimits) MarshalToSizedBuffer 

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

func (*VertexLimits) ProtoMessage 

func (*VertexLimits) ProtoMessage()

func (*VertexLimits) Reset 

func (m *VertexLimits) Reset()

func (*VertexLimits) Size 

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

func (*VertexLimits) String 

func (this *VertexLimits) String() string

func (*VertexLimits) Unmarshal 

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

func (*VertexLimits) XXX_DiscardUnknown 

func (m *VertexLimits) XXX_DiscardUnknown()

func (*VertexLimits) XXX_Marshal 

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

func (*VertexLimits) XXX_Merge 

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

func (*VertexLimits) XXX_Size 

func (m *VertexLimits) XXX_Size() int

func (*VertexLimits) XXX_Unmarshal 

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

type VertexList 

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

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

func (*VertexList) DeepCopy 

func (in *VertexList) DeepCopy() *VertexList

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

func (*VertexList) DeepCopyInto 

func (in *VertexList) DeepCopyInto(out *VertexList)

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

func (*VertexList) DeepCopyObject 

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

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

func (*VertexList) Descriptor 

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

func (*VertexList) Marshal 

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

func (*VertexList) MarshalTo 

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

func (*VertexList) MarshalToSizedBuffer 

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

func (*VertexList) ProtoMessage 

func (*VertexList) ProtoMessage()

func (*VertexList) Reset 

func (m *VertexList) Reset()

func (*VertexList) Size 

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

func (*VertexList) String 

func (this *VertexList) String() string

func (*VertexList) Unmarshal 

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

func (*VertexList) XXX_DiscardUnknown 

func (m *VertexList) XXX_DiscardUnknown()

func (*VertexList) XXX_Marshal 

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

func (*VertexList) XXX_Merge 

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

func (*VertexList) XXX_Size 

func (m *VertexList) XXX_Size() int

func (*VertexList) XXX_Unmarshal 

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

type VertexPhase 

type VertexPhase string

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

const (
	VertexPhaseUnknown   VertexPhase = ""
	VertexPhasePending   VertexPhase = "Pending"
	VertexPhaseRunning   VertexPhase = "Running"
	VertexPhaseSucceeded VertexPhase = "Succeeded"
	VertexPhaseFailed    VertexPhase = "Failed"
)

type VertexSpec 

type VertexSpec struct {
	AbstractVertex `json:",inline" protobuf:"bytes,1,opt,name=abstractVertex"`
	PipelineName   string `json:"pipelineName" protobuf:"bytes,2,opt,name=pipelineName"`
	// +optional
	InterStepBufferServiceName string `json:"interStepBufferServiceName" protobuf:"bytes,3,opt,name=interStepBufferServiceName"`
	// +kubebuilder:default=1
	// +optional
	Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,4,opt,name=replicas"`
	// +optional
	FromVertices []string `json:"fromVertices,omitempty" protobuf:"bytes,5,rep,name=fromVertices"`
	// +optional
	ToVertices []ToVertex `json:"toVertices,omitempty" protobuf:"bytes,6,rep,name=toVertices"`
}

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

func (vs VertexSpec) GetReplicas() 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 Watermark 

type Watermark struct {
	// Propagate toggles the watermark propagation.
	// +kubebuilder:default=false
	// +optional
	Propagate bool `json:"propagate,omitempty" protobuf:"bytes,1,opt,name=propagate"`
}

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

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.