zz_generated.deepcopy.go

//go:build !ignore_autogenerated
// +build !ignore_autogenerated

/*
Copyright 2022 The Numaproj Authors.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

// Code generated by deepcopy-gen. DO NOT EDIT.

package v1alpha1

import (
	v1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	runtime "k8s.io/apimachinery/pkg/runtime"
)

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *AbstractPodTemplate) DeepCopyInto(out *AbstractPodTemplate) {
	*out = *in
	if in.Metadata != nil {
		in, out := &in.Metadata, &out.Metadata
		*out = new(Metadata)
		(*in).DeepCopyInto(*out)
	}
	if in.NodeSelector != nil {
		in, out := &in.NodeSelector, &out.NodeSelector
		*out = make(map[string]string, len(*in))
		for key, val := range *in {
			(*out)[key] = val
		}
	}
	if in.Tolerations != nil {
		in, out := &in.Tolerations, &out.Tolerations
		*out = make([]v1.Toleration, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	if in.SecurityContext != nil {
		in, out := &in.SecurityContext, &out.SecurityContext
		*out = new(v1.PodSecurityContext)
		(*in).DeepCopyInto(*out)
	}
	if in.ImagePullSecrets != nil {
		in, out := &in.ImagePullSecrets, &out.ImagePullSecrets
		*out = make([]v1.LocalObjectReference, len(*in))
		copy(*out, *in)
	}
	if in.Priority != nil {
		in, out := &in.Priority, &out.Priority
		*out = new(int32)
		**out = **in
	}
	if in.Affinity != nil {
		in, out := &in.Affinity, &out.Affinity
		*out = new(v1.Affinity)
		(*in).DeepCopyInto(*out)
	}
	if in.RuntimeClassName != nil {
		in, out := &in.RuntimeClassName, &out.RuntimeClassName
		*out = new(string)
		**out = **in
	}
	if in.AutomountServiceAccountToken != nil {
		in, out := &in.AutomountServiceAccountToken, &out.AutomountServiceAccountToken
		*out = new(bool)
		**out = **in
	}
	if in.DNSConfig != nil {
		in, out := &in.DNSConfig, &out.DNSConfig
		*out = new(v1.PodDNSConfig)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AbstractPodTemplate.
func (in *AbstractPodTemplate) DeepCopy() *AbstractPodTemplate {
	if in == nil {
		return nil
	}
	out := new(AbstractPodTemplate)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *AbstractSink) DeepCopyInto(out *AbstractSink) {
	*out = *in
	if in.Log != nil {
		in, out := &in.Log, &out.Log
		*out = new(Log)
		**out = **in
	}
	if in.Kafka != nil {
		in, out := &in.Kafka, &out.Kafka
		*out = new(KafkaSink)
		(*in).DeepCopyInto(*out)
	}
	if in.Blackhole != nil {
		in, out := &in.Blackhole, &out.Blackhole
		*out = new(Blackhole)
		**out = **in
	}
	if in.UDSink != nil {
		in, out := &in.UDSink, &out.UDSink
		*out = new(UDSink)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AbstractSink.
func (in *AbstractSink) DeepCopy() *AbstractSink {
	if in == nil {
		return nil
	}
	out := new(AbstractSink)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *AbstractVertex) DeepCopyInto(out *AbstractVertex) {
	*out = *in
	if in.Source != nil {
		in, out := &in.Source, &out.Source
		*out = new(Source)
		(*in).DeepCopyInto(*out)
	}
	if in.Sink != nil {
		in, out := &in.Sink, &out.Sink
		*out = new(Sink)
		(*in).DeepCopyInto(*out)
	}
	if in.UDF != nil {
		in, out := &in.UDF, &out.UDF
		*out = new(UDF)
		(*in).DeepCopyInto(*out)
	}
	if in.ContainerTemplate != nil {
		in, out := &in.ContainerTemplate, &out.ContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.InitContainerTemplate != nil {
		in, out := &in.InitContainerTemplate, &out.InitContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	in.AbstractPodTemplate.DeepCopyInto(&out.AbstractPodTemplate)
	if in.Volumes != nil {
		in, out := &in.Volumes, &out.Volumes
		*out = make([]v1.Volume, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	if in.Limits != nil {
		in, out := &in.Limits, &out.Limits
		*out = new(VertexLimits)
		(*in).DeepCopyInto(*out)
	}
	in.Scale.DeepCopyInto(&out.Scale)
	if in.InitContainers != nil {
		in, out := &in.InitContainers, &out.InitContainers
		*out = make([]v1.Container, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	if in.Sidecars != nil {
		in, out := &in.Sidecars, &out.Sidecars
		*out = make([]v1.Container, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	if in.Partitions != nil {
		in, out := &in.Partitions, &out.Partitions
		*out = new(int32)
		**out = **in
	}
	if in.SideInputs != nil {
		in, out := &in.SideInputs, &out.SideInputs
		*out = make([]string, len(*in))
		copy(*out, *in)
	}
	if in.SideInputsContainerTemplate != nil {
		in, out := &in.SideInputsContainerTemplate, &out.SideInputsContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AbstractVertex.
func (in *AbstractVertex) DeepCopy() *AbstractVertex {
	if in == nil {
		return nil
	}
	out := new(AbstractVertex)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Authorization) DeepCopyInto(out *Authorization) {
	*out = *in
	if in.Token != nil {
		in, out := &in.Token, &out.Token
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Authorization.
func (in *Authorization) DeepCopy() *Authorization {
	if in == nil {
		return nil
	}
	out := new(Authorization)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *BasicAuth) DeepCopyInto(out *BasicAuth) {
	*out = *in
	if in.User != nil {
		in, out := &in.User, &out.User
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	if in.Password != nil {
		in, out := &in.Password, &out.Password
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BasicAuth.
func (in *BasicAuth) DeepCopy() *BasicAuth {
	if in == nil {
		return nil
	}
	out := new(BasicAuth)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Blackhole) DeepCopyInto(out *Blackhole) {
	*out = *in
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Blackhole.
func (in *Blackhole) DeepCopy() *Blackhole {
	if in == nil {
		return nil
	}
	out := new(Blackhole)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *BufferServiceConfig) DeepCopyInto(out *BufferServiceConfig) {
	*out = *in
	if in.Redis != nil {
		in, out := &in.Redis, &out.Redis
		*out = new(RedisConfig)
		(*in).DeepCopyInto(*out)
	}
	if in.JetStream != nil {
		in, out := &in.JetStream, &out.JetStream
		*out = new(JetStreamConfig)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BufferServiceConfig.
func (in *BufferServiceConfig) DeepCopy() *BufferServiceConfig {
	if in == nil {
		return nil
	}
	out := new(BufferServiceConfig)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *CombinedEdge) DeepCopyInto(out *CombinedEdge) {
	*out = *in
	in.Edge.DeepCopyInto(&out.Edge)
	if in.FromVertexPartitionCount != nil {
		in, out := &in.FromVertexPartitionCount, &out.FromVertexPartitionCount
		*out = new(int32)
		**out = **in
	}
	if in.FromVertexLimits != nil {
		in, out := &in.FromVertexLimits, &out.FromVertexLimits
		*out = new(VertexLimits)
		(*in).DeepCopyInto(*out)
	}
	if in.ToVertexPartitionCount != nil {
		in, out := &in.ToVertexPartitionCount, &out.ToVertexPartitionCount
		*out = new(int32)
		**out = **in
	}
	if in.ToVertexLimits != nil {
		in, out := &in.ToVertexLimits, &out.ToVertexLimits
		*out = new(VertexLimits)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CombinedEdge.
func (in *CombinedEdge) DeepCopy() *CombinedEdge {
	if in == nil {
		return nil
	}
	out := new(CombinedEdge)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Container) DeepCopyInto(out *Container) {
	*out = *in
	if in.Command != nil {
		in, out := &in.Command, &out.Command
		*out = make([]string, len(*in))
		copy(*out, *in)
	}
	if in.Args != nil {
		in, out := &in.Args, &out.Args
		*out = make([]string, len(*in))
		copy(*out, *in)
	}
	if in.Env != nil {
		in, out := &in.Env, &out.Env
		*out = make([]v1.EnvVar, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	if in.EnvFrom != nil {
		in, out := &in.EnvFrom, &out.EnvFrom
		*out = make([]v1.EnvFromSource, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	if in.VolumeMounts != nil {
		in, out := &in.VolumeMounts, &out.VolumeMounts
		*out = make([]v1.VolumeMount, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	in.Resources.DeepCopyInto(&out.Resources)
	if in.SecurityContext != nil {
		in, out := &in.SecurityContext, &out.SecurityContext
		*out = new(v1.SecurityContext)
		(*in).DeepCopyInto(*out)
	}
	if in.ImagePullPolicy != nil {
		in, out := &in.ImagePullPolicy, &out.ImagePullPolicy
		*out = new(v1.PullPolicy)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Container.
func (in *Container) DeepCopy() *Container {
	if in == nil {
		return nil
	}
	out := new(Container)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ContainerTemplate) DeepCopyInto(out *ContainerTemplate) {
	*out = *in
	in.Resources.DeepCopyInto(&out.Resources)
	if in.SecurityContext != nil {
		in, out := &in.SecurityContext, &out.SecurityContext
		*out = new(v1.SecurityContext)
		(*in).DeepCopyInto(*out)
	}
	if in.Env != nil {
		in, out := &in.Env, &out.Env
		*out = make([]v1.EnvVar, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	if in.EnvFrom != nil {
		in, out := &in.EnvFrom, &out.EnvFrom
		*out = make([]v1.EnvFromSource, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ContainerTemplate.
func (in *ContainerTemplate) DeepCopy() *ContainerTemplate {
	if in == nil {
		return nil
	}
	out := new(ContainerTemplate)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *DaemonTemplate) DeepCopyInto(out *DaemonTemplate) {
	*out = *in
	in.AbstractPodTemplate.DeepCopyInto(&out.AbstractPodTemplate)
	if in.Replicas != nil {
		in, out := &in.Replicas, &out.Replicas
		*out = new(int32)
		**out = **in
	}
	if in.ContainerTemplate != nil {
		in, out := &in.ContainerTemplate, &out.ContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.InitContainerTemplate != nil {
		in, out := &in.InitContainerTemplate, &out.InitContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DaemonTemplate.
func (in *DaemonTemplate) DeepCopy() *DaemonTemplate {
	if in == nil {
		return nil
	}
	out := new(DaemonTemplate)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Edge) DeepCopyInto(out *Edge) {
	*out = *in
	if in.Conditions != nil {
		in, out := &in.Conditions, &out.Conditions
		*out = new(ForwardConditions)
		(*in).DeepCopyInto(*out)
	}
	if in.OnFull != nil {
		in, out := &in.OnFull, &out.OnFull
		*out = new(BufferFullWritingStrategy)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Edge.
func (in *Edge) DeepCopy() *Edge {
	if in == nil {
		return nil
	}
	out := new(Edge)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *FixedWindow) DeepCopyInto(out *FixedWindow) {
	*out = *in
	if in.Length != nil {
		in, out := &in.Length, &out.Length
		*out = new(metav1.Duration)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FixedWindow.
func (in *FixedWindow) DeepCopy() *FixedWindow {
	if in == nil {
		return nil
	}
	out := new(FixedWindow)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *ForwardConditions) DeepCopyInto(out *ForwardConditions) {
	*out = *in
	if in.Tags != nil {
		in, out := &in.Tags, &out.Tags
		*out = new(TagConditions)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ForwardConditions.
func (in *ForwardConditions) DeepCopy() *ForwardConditions {
	if in == nil {
		return nil
	}
	out := new(ForwardConditions)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Function) DeepCopyInto(out *Function) {
	*out = *in
	if in.Args != nil {
		in, out := &in.Args, &out.Args
		*out = make([]string, len(*in))
		copy(*out, *in)
	}
	if in.KWArgs != nil {
		in, out := &in.KWArgs, &out.KWArgs
		*out = make(map[string]string, len(*in))
		for key, val := range *in {
			(*out)[key] = val
		}
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Function.
func (in *Function) DeepCopy() *Function {
	if in == nil {
		return nil
	}
	out := new(Function)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *GSSAPI) DeepCopyInto(out *GSSAPI) {
	*out = *in
	if in.UsernameSecret != nil {
		in, out := &in.UsernameSecret, &out.UsernameSecret
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	if in.AuthType != nil {
		in, out := &in.AuthType, &out.AuthType
		*out = new(KRB5AuthType)
		**out = **in
	}
	if in.PasswordSecret != nil {
		in, out := &in.PasswordSecret, &out.PasswordSecret
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	if in.KeytabSecret != nil {
		in, out := &in.KeytabSecret, &out.KeytabSecret
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	if in.KerberosConfigSecret != nil {
		in, out := &in.KerberosConfigSecret, &out.KerberosConfigSecret
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GSSAPI.
func (in *GSSAPI) DeepCopy() *GSSAPI {
	if in == nil {
		return nil
	}
	out := new(GSSAPI)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *GeneratorSource) DeepCopyInto(out *GeneratorSource) {
	*out = *in
	if in.RPU != nil {
		in, out := &in.RPU, &out.RPU
		*out = new(int64)
		**out = **in
	}
	if in.Duration != nil {
		in, out := &in.Duration, &out.Duration
		*out = new(metav1.Duration)
		**out = **in
	}
	if in.MsgSize != nil {
		in, out := &in.MsgSize, &out.MsgSize
		*out = new(int32)
		**out = **in
	}
	if in.KeyCount != nil {
		in, out := &in.KeyCount, &out.KeyCount
		*out = new(int32)
		**out = **in
	}
	if in.Value != nil {
		in, out := &in.Value, &out.Value
		*out = new(uint64)
		**out = **in
	}
	if in.Jitter != nil {
		in, out := &in.Jitter, &out.Jitter
		*out = new(metav1.Duration)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GeneratorSource.
func (in *GeneratorSource) DeepCopy() *GeneratorSource {
	if in == nil {
		return nil
	}
	out := new(GeneratorSource)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *GetDaemonDeploymentReq) DeepCopyInto(out *GetDaemonDeploymentReq) {
	*out = *in
	if in.Env != nil {
		in, out := &in.Env, &out.Env
		*out = make([]v1.EnvVar, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	in.DefaultResources.DeepCopyInto(&out.DefaultResources)
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetDaemonDeploymentReq.
func (in *GetDaemonDeploymentReq) DeepCopy() *GetDaemonDeploymentReq {
	if in == nil {
		return nil
	}
	out := new(GetDaemonDeploymentReq)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *GetJetStreamServiceSpecReq) DeepCopyInto(out *GetJetStreamServiceSpecReq) {
	*out = *in
	if in.Labels != nil {
		in, out := &in.Labels, &out.Labels
		*out = make(map[string]string, len(*in))
		for key, val := range *in {
			(*out)[key] = val
		}
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetJetStreamServiceSpecReq.
func (in *GetJetStreamServiceSpecReq) DeepCopy() *GetJetStreamServiceSpecReq {
	if in == nil {
		return nil
	}
	out := new(GetJetStreamServiceSpecReq)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *GetJetStreamStatefulSetSpecReq) DeepCopyInto(out *GetJetStreamStatefulSetSpecReq) {
	*out = *in
	if in.Labels != nil {
		in, out := &in.Labels, &out.Labels
		*out = make(map[string]string, len(*in))
		for key, val := range *in {
			(*out)[key] = val
		}
	}
	in.DefaultResources.DeepCopyInto(&out.DefaultResources)
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetJetStreamStatefulSetSpecReq.
func (in *GetJetStreamStatefulSetSpecReq) DeepCopy() *GetJetStreamStatefulSetSpecReq {
	if in == nil {
		return nil
	}
	out := new(GetJetStreamStatefulSetSpecReq)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *GetRedisServiceSpecReq) DeepCopyInto(out *GetRedisServiceSpecReq) {
	*out = *in
	if in.Labels != nil {
		in, out := &in.Labels, &out.Labels
		*out = make(map[string]string, len(*in))
		for key, val := range *in {
			(*out)[key] = val
		}
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetRedisServiceSpecReq.
func (in *GetRedisServiceSpecReq) DeepCopy() *GetRedisServiceSpecReq {
	if in == nil {
		return nil
	}
	out := new(GetRedisServiceSpecReq)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *GetRedisStatefulSetSpecReq) DeepCopyInto(out *GetRedisStatefulSetSpecReq) {
	*out = *in
	if in.Labels != nil {
		in, out := &in.Labels, &out.Labels
		*out = make(map[string]string, len(*in))
		for key, val := range *in {
			(*out)[key] = val
		}
	}
	in.DefaultResources.DeepCopyInto(&out.DefaultResources)
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetRedisStatefulSetSpecReq.
func (in *GetRedisStatefulSetSpecReq) DeepCopy() *GetRedisStatefulSetSpecReq {
	if in == nil {
		return nil
	}
	out := new(GetRedisStatefulSetSpecReq)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *GetSideInputDeploymentReq) DeepCopyInto(out *GetSideInputDeploymentReq) {
	*out = *in
	if in.Env != nil {
		in, out := &in.Env, &out.Env
		*out = make([]v1.EnvVar, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	in.DefaultResources.DeepCopyInto(&out.DefaultResources)
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetSideInputDeploymentReq.
func (in *GetSideInputDeploymentReq) DeepCopy() *GetSideInputDeploymentReq {
	if in == nil {
		return nil
	}
	out := new(GetSideInputDeploymentReq)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *GetVertexPodSpecReq) DeepCopyInto(out *GetVertexPodSpecReq) {
	*out = *in
	if in.Env != nil {
		in, out := &in.Env, &out.Env
		*out = make([]v1.EnvVar, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	in.DefaultResources.DeepCopyInto(&out.DefaultResources)
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetVertexPodSpecReq.
func (in *GetVertexPodSpecReq) DeepCopy() *GetVertexPodSpecReq {
	if in == nil {
		return nil
	}
	out := new(GetVertexPodSpecReq)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *GroupBy) DeepCopyInto(out *GroupBy) {
	*out = *in
	in.Window.DeepCopyInto(&out.Window)
	if in.AllowedLateness != nil {
		in, out := &in.AllowedLateness, &out.AllowedLateness
		*out = new(metav1.Duration)
		**out = **in
	}
	if in.Storage != nil {
		in, out := &in.Storage, &out.Storage
		*out = new(PBQStorage)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GroupBy.
func (in *GroupBy) DeepCopy() *GroupBy {
	if in == nil {
		return nil
	}
	out := new(GroupBy)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *HTTPSource) DeepCopyInto(out *HTTPSource) {
	*out = *in
	if in.Auth != nil {
		in, out := &in.Auth, &out.Auth
		*out = new(Authorization)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HTTPSource.
func (in *HTTPSource) DeepCopy() *HTTPSource {
	if in == nil {
		return nil
	}
	out := new(HTTPSource)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *IdleSource) DeepCopyInto(out *IdleSource) {
	*out = *in
	if in.Threshold != nil {
		in, out := &in.Threshold, &out.Threshold
		*out = new(metav1.Duration)
		**out = **in
	}
	if in.StepInterval != nil {
		in, out := &in.StepInterval, &out.StepInterval
		*out = new(metav1.Duration)
		**out = **in
	}
	if in.IncrementBy != nil {
		in, out := &in.IncrementBy, &out.IncrementBy
		*out = new(metav1.Duration)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IdleSource.
func (in *IdleSource) DeepCopy() *IdleSource {
	if in == nil {
		return nil
	}
	out := new(IdleSource)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *InterStepBufferService) DeepCopyInto(out *InterStepBufferService) {
	*out = *in
	out.TypeMeta = in.TypeMeta
	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
	in.Spec.DeepCopyInto(&out.Spec)
	in.Status.DeepCopyInto(&out.Status)
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InterStepBufferService.
func (in *InterStepBufferService) DeepCopy() *InterStepBufferService {
	if in == nil {
		return nil
	}
	out := new(InterStepBufferService)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *InterStepBufferService) DeepCopyObject() runtime.Object {
	if c := in.DeepCopy(); c != nil {
		return c
	}
	return nil
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *InterStepBufferServiceList) DeepCopyInto(out *InterStepBufferServiceList) {
	*out = *in
	out.TypeMeta = in.TypeMeta
	in.ListMeta.DeepCopyInto(&out.ListMeta)
	if in.Items != nil {
		in, out := &in.Items, &out.Items
		*out = make([]InterStepBufferService, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InterStepBufferServiceList.
func (in *InterStepBufferServiceList) DeepCopy() *InterStepBufferServiceList {
	if in == nil {
		return nil
	}
	out := new(InterStepBufferServiceList)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *InterStepBufferServiceList) DeepCopyObject() runtime.Object {
	if c := in.DeepCopy(); c != nil {
		return c
	}
	return nil
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *InterStepBufferServiceSpec) DeepCopyInto(out *InterStepBufferServiceSpec) {
	*out = *in
	if in.Redis != nil {
		in, out := &in.Redis, &out.Redis
		*out = new(RedisBufferService)
		(*in).DeepCopyInto(*out)
	}
	if in.JetStream != nil {
		in, out := &in.JetStream, &out.JetStream
		*out = new(JetStreamBufferService)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InterStepBufferServiceSpec.
func (in *InterStepBufferServiceSpec) DeepCopy() *InterStepBufferServiceSpec {
	if in == nil {
		return nil
	}
	out := new(InterStepBufferServiceSpec)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *InterStepBufferServiceStatus) DeepCopyInto(out *InterStepBufferServiceStatus) {
	*out = *in
	in.Status.DeepCopyInto(&out.Status)
	in.Config.DeepCopyInto(&out.Config)
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InterStepBufferServiceStatus.
func (in *InterStepBufferServiceStatus) DeepCopy() *InterStepBufferServiceStatus {
	if in == nil {
		return nil
	}
	out := new(InterStepBufferServiceStatus)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *JetStreamBufferService) DeepCopyInto(out *JetStreamBufferService) {
	*out = *in
	if in.Replicas != nil {
		in, out := &in.Replicas, &out.Replicas
		*out = new(int32)
		**out = **in
	}
	if in.ContainerTemplate != nil {
		in, out := &in.ContainerTemplate, &out.ContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.ReloaderContainerTemplate != nil {
		in, out := &in.ReloaderContainerTemplate, &out.ReloaderContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.MetricsContainerTemplate != nil {
		in, out := &in.MetricsContainerTemplate, &out.MetricsContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.Persistence != nil {
		in, out := &in.Persistence, &out.Persistence
		*out = new(PersistenceStrategy)
		(*in).DeepCopyInto(*out)
	}
	in.AbstractPodTemplate.DeepCopyInto(&out.AbstractPodTemplate)
	if in.Settings != nil {
		in, out := &in.Settings, &out.Settings
		*out = new(string)
		**out = **in
	}
	if in.StartArgs != nil {
		in, out := &in.StartArgs, &out.StartArgs
		*out = make([]string, len(*in))
		copy(*out, *in)
	}
	if in.BufferConfig != nil {
		in, out := &in.BufferConfig, &out.BufferConfig
		*out = new(string)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JetStreamBufferService.
func (in *JetStreamBufferService) DeepCopy() *JetStreamBufferService {
	if in == nil {
		return nil
	}
	out := new(JetStreamBufferService)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *JetStreamConfig) DeepCopyInto(out *JetStreamConfig) {
	*out = *in
	if in.Auth != nil {
		in, out := &in.Auth, &out.Auth
		*out = new(NatsAuth)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JetStreamConfig.
func (in *JetStreamConfig) DeepCopy() *JetStreamConfig {
	if in == nil {
		return nil
	}
	out := new(JetStreamConfig)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *JobTemplate) DeepCopyInto(out *JobTemplate) {
	*out = *in
	in.AbstractPodTemplate.DeepCopyInto(&out.AbstractPodTemplate)
	if in.ContainerTemplate != nil {
		in, out := &in.ContainerTemplate, &out.ContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.TTLSecondsAfterFinished != nil {
		in, out := &in.TTLSecondsAfterFinished, &out.TTLSecondsAfterFinished
		*out = new(int32)
		**out = **in
	}
	if in.BackoffLimit != nil {
		in, out := &in.BackoffLimit, &out.BackoffLimit
		*out = new(int32)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobTemplate.
func (in *JobTemplate) DeepCopy() *JobTemplate {
	if in == nil {
		return nil
	}
	out := new(JobTemplate)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *KafkaSink) DeepCopyInto(out *KafkaSink) {
	*out = *in
	if in.Brokers != nil {
		in, out := &in.Brokers, &out.Brokers
		*out = make([]string, len(*in))
		copy(*out, *in)
	}
	if in.TLS != nil {
		in, out := &in.TLS, &out.TLS
		*out = new(TLS)
		(*in).DeepCopyInto(*out)
	}
	if in.SASL != nil {
		in, out := &in.SASL, &out.SASL
		*out = new(SASL)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSink.
func (in *KafkaSink) DeepCopy() *KafkaSink {
	if in == nil {
		return nil
	}
	out := new(KafkaSink)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *KafkaSource) DeepCopyInto(out *KafkaSource) {
	*out = *in
	if in.Brokers != nil {
		in, out := &in.Brokers, &out.Brokers
		*out = make([]string, len(*in))
		copy(*out, *in)
	}
	if in.TLS != nil {
		in, out := &in.TLS, &out.TLS
		*out = new(TLS)
		(*in).DeepCopyInto(*out)
	}
	if in.SASL != nil {
		in, out := &in.SASL, &out.SASL
		*out = new(SASL)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSource.
func (in *KafkaSource) DeepCopy() *KafkaSource {
	if in == nil {
		return nil
	}
	out := new(KafkaSource)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Lifecycle) DeepCopyInto(out *Lifecycle) {
	*out = *in
	if in.DeleteGracePeriodSeconds != nil {
		in, out := &in.DeleteGracePeriodSeconds, &out.DeleteGracePeriodSeconds
		*out = new(int32)
		**out = **in
	}
	if in.PauseGracePeriodSeconds != nil {
		in, out := &in.PauseGracePeriodSeconds, &out.PauseGracePeriodSeconds
		*out = new(int32)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Lifecycle.
func (in *Lifecycle) DeepCopy() *Lifecycle {
	if in == nil {
		return nil
	}
	out := new(Lifecycle)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Log) DeepCopyInto(out *Log) {
	*out = *in
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Log.
func (in *Log) DeepCopy() *Log {
	if in == nil {
		return nil
	}
	out := new(Log)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Metadata) DeepCopyInto(out *Metadata) {
	*out = *in
	if in.Annotations != nil {
		in, out := &in.Annotations, &out.Annotations
		*out = make(map[string]string, len(*in))
		for key, val := range *in {
			(*out)[key] = val
		}
	}
	if in.Labels != nil {
		in, out := &in.Labels, &out.Labels
		*out = make(map[string]string, len(*in))
		for key, val := range *in {
			(*out)[key] = val
		}
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Metadata.
func (in *Metadata) DeepCopy() *Metadata {
	if in == nil {
		return nil
	}
	out := new(Metadata)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *NativeRedis) DeepCopyInto(out *NativeRedis) {
	*out = *in
	if in.Replicas != nil {
		in, out := &in.Replicas, &out.Replicas
		*out = new(int32)
		**out = **in
	}
	if in.RedisContainerTemplate != nil {
		in, out := &in.RedisContainerTemplate, &out.RedisContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.SentinelContainerTemplate != nil {
		in, out := &in.SentinelContainerTemplate, &out.SentinelContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.MetricsContainerTemplate != nil {
		in, out := &in.MetricsContainerTemplate, &out.MetricsContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.InitContainerTemplate != nil {
		in, out := &in.InitContainerTemplate, &out.InitContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.Persistence != nil {
		in, out := &in.Persistence, &out.Persistence
		*out = new(PersistenceStrategy)
		(*in).DeepCopyInto(*out)
	}
	in.AbstractPodTemplate.DeepCopyInto(&out.AbstractPodTemplate)
	if in.Settings != nil {
		in, out := &in.Settings, &out.Settings
		*out = new(RedisSettings)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NativeRedis.
func (in *NativeRedis) DeepCopy() *NativeRedis {
	if in == nil {
		return nil
	}
	out := new(NativeRedis)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *NatsAuth) DeepCopyInto(out *NatsAuth) {
	*out = *in
	if in.Basic != nil {
		in, out := &in.Basic, &out.Basic
		*out = new(BasicAuth)
		(*in).DeepCopyInto(*out)
	}
	if in.Token != nil {
		in, out := &in.Token, &out.Token
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	if in.NKey != nil {
		in, out := &in.NKey, &out.NKey
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NatsAuth.
func (in *NatsAuth) DeepCopy() *NatsAuth {
	if in == nil {
		return nil
	}
	out := new(NatsAuth)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *NatsSource) DeepCopyInto(out *NatsSource) {
	*out = *in
	if in.TLS != nil {
		in, out := &in.TLS, &out.TLS
		*out = new(TLS)
		(*in).DeepCopyInto(*out)
	}
	if in.Auth != nil {
		in, out := &in.Auth, &out.Auth
		*out = new(NatsAuth)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NatsSource.
func (in *NatsSource) DeepCopy() *NatsSource {
	if in == nil {
		return nil
	}
	out := new(NatsSource)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *NoStore) DeepCopyInto(out *NoStore) {
	*out = *in
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NoStore.
func (in *NoStore) DeepCopy() *NoStore {
	if in == nil {
		return nil
	}
	out := new(NoStore)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *PBQStorage) DeepCopyInto(out *PBQStorage) {
	*out = *in
	if in.PersistentVolumeClaim != nil {
		in, out := &in.PersistentVolumeClaim, &out.PersistentVolumeClaim
		*out = new(PersistenceStrategy)
		(*in).DeepCopyInto(*out)
	}
	if in.EmptyDir != nil {
		in, out := &in.EmptyDir, &out.EmptyDir
		*out = new(v1.EmptyDirVolumeSource)
		(*in).DeepCopyInto(*out)
	}
	if in.NoStore != nil {
		in, out := &in.NoStore, &out.NoStore
		*out = new(NoStore)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PBQStorage.
func (in *PBQStorage) DeepCopy() *PBQStorage {
	if in == nil {
		return nil
	}
	out := new(PBQStorage)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *PersistenceStrategy) DeepCopyInto(out *PersistenceStrategy) {
	*out = *in
	if in.StorageClassName != nil {
		in, out := &in.StorageClassName, &out.StorageClassName
		*out = new(string)
		**out = **in
	}
	if in.AccessMode != nil {
		in, out := &in.AccessMode, &out.AccessMode
		*out = new(v1.PersistentVolumeAccessMode)
		**out = **in
	}
	if in.VolumeSize != nil {
		in, out := &in.VolumeSize, &out.VolumeSize
		x := (*in).DeepCopy()
		*out = &x
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PersistenceStrategy.
func (in *PersistenceStrategy) DeepCopy() *PersistenceStrategy {
	if in == nil {
		return nil
	}
	out := new(PersistenceStrategy)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Pipeline) DeepCopyInto(out *Pipeline) {
	*out = *in
	out.TypeMeta = in.TypeMeta
	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
	in.Spec.DeepCopyInto(&out.Spec)
	in.Status.DeepCopyInto(&out.Status)
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Pipeline.
func (in *Pipeline) DeepCopy() *Pipeline {
	if in == nil {
		return nil
	}
	out := new(Pipeline)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *Pipeline) DeepCopyObject() runtime.Object {
	if c := in.DeepCopy(); c != nil {
		return c
	}
	return nil
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *PipelineLimits) DeepCopyInto(out *PipelineLimits) {
	*out = *in
	if in.ReadBatchSize != nil {
		in, out := &in.ReadBatchSize, &out.ReadBatchSize
		*out = new(uint64)
		**out = **in
	}
	if in.BufferMaxLength != nil {
		in, out := &in.BufferMaxLength, &out.BufferMaxLength
		*out = new(uint64)
		**out = **in
	}
	if in.BufferUsageLimit != nil {
		in, out := &in.BufferUsageLimit, &out.BufferUsageLimit
		*out = new(uint32)
		**out = **in
	}
	if in.ReadTimeout != nil {
		in, out := &in.ReadTimeout, &out.ReadTimeout
		*out = new(metav1.Duration)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipelineLimits.
func (in *PipelineLimits) DeepCopy() *PipelineLimits {
	if in == nil {
		return nil
	}
	out := new(PipelineLimits)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *PipelineList) DeepCopyInto(out *PipelineList) {
	*out = *in
	out.TypeMeta = in.TypeMeta
	in.ListMeta.DeepCopyInto(&out.ListMeta)
	if in.Items != nil {
		in, out := &in.Items, &out.Items
		*out = make([]Pipeline, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipelineList.
func (in *PipelineList) DeepCopy() *PipelineList {
	if in == nil {
		return nil
	}
	out := new(PipelineList)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *PipelineList) DeepCopyObject() runtime.Object {
	if c := in.DeepCopy(); c != nil {
		return c
	}
	return nil
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *PipelineSpec) DeepCopyInto(out *PipelineSpec) {
	*out = *in
	if in.Vertices != nil {
		in, out := &in.Vertices, &out.Vertices
		*out = make([]AbstractVertex, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	if in.Edges != nil {
		in, out := &in.Edges, &out.Edges
		*out = make([]Edge, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	in.Lifecycle.DeepCopyInto(&out.Lifecycle)
	if in.Limits != nil {
		in, out := &in.Limits, &out.Limits
		*out = new(PipelineLimits)
		(*in).DeepCopyInto(*out)
	}
	in.Watermark.DeepCopyInto(&out.Watermark)
	if in.Templates != nil {
		in, out := &in.Templates, &out.Templates
		*out = new(Templates)
		(*in).DeepCopyInto(*out)
	}
	if in.SideInputs != nil {
		in, out := &in.SideInputs, &out.SideInputs
		*out = make([]SideInput, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipelineSpec.
func (in *PipelineSpec) DeepCopy() *PipelineSpec {
	if in == nil {
		return nil
	}
	out := new(PipelineSpec)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *PipelineStatus) DeepCopyInto(out *PipelineStatus) {
	*out = *in
	in.Status.DeepCopyInto(&out.Status)
	in.LastUpdated.DeepCopyInto(&out.LastUpdated)
	if in.VertexCount != nil {
		in, out := &in.VertexCount, &out.VertexCount
		*out = new(uint32)
		**out = **in
	}
	if in.SourceCount != nil {
		in, out := &in.SourceCount, &out.SourceCount
		*out = new(uint32)
		**out = **in
	}
	if in.SinkCount != nil {
		in, out := &in.SinkCount, &out.SinkCount
		*out = new(uint32)
		**out = **in
	}
	if in.UDFCount != nil {
		in, out := &in.UDFCount, &out.UDFCount
		*out = new(uint32)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PipelineStatus.
func (in *PipelineStatus) DeepCopy() *PipelineStatus {
	if in == nil {
		return nil
	}
	out := new(PipelineStatus)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *RedisBufferService) DeepCopyInto(out *RedisBufferService) {
	*out = *in
	if in.Native != nil {
		in, out := &in.Native, &out.Native
		*out = new(NativeRedis)
		(*in).DeepCopyInto(*out)
	}
	if in.External != nil {
		in, out := &in.External, &out.External
		*out = new(RedisConfig)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisBufferService.
func (in *RedisBufferService) DeepCopy() *RedisBufferService {
	if in == nil {
		return nil
	}
	out := new(RedisBufferService)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *RedisConfig) DeepCopyInto(out *RedisConfig) {
	*out = *in
	if in.Password != nil {
		in, out := &in.Password, &out.Password
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	if in.SentinelPassword != nil {
		in, out := &in.SentinelPassword, &out.SentinelPassword
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisConfig.
func (in *RedisConfig) DeepCopy() *RedisConfig {
	if in == nil {
		return nil
	}
	out := new(RedisConfig)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *RedisSettings) DeepCopyInto(out *RedisSettings) {
	*out = *in
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisSettings.
func (in *RedisSettings) DeepCopy() *RedisSettings {
	if in == nil {
		return nil
	}
	out := new(RedisSettings)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *SASL) DeepCopyInto(out *SASL) {
	*out = *in
	if in.Mechanism != nil {
		in, out := &in.Mechanism, &out.Mechanism
		*out = new(SASLType)
		**out = **in
	}
	if in.GSSAPI != nil {
		in, out := &in.GSSAPI, &out.GSSAPI
		*out = new(GSSAPI)
		(*in).DeepCopyInto(*out)
	}
	if in.Plain != nil {
		in, out := &in.Plain, &out.Plain
		*out = new(SASLPlain)
		(*in).DeepCopyInto(*out)
	}
	if in.SCRAMSHA256 != nil {
		in, out := &in.SCRAMSHA256, &out.SCRAMSHA256
		*out = new(SASLPlain)
		(*in).DeepCopyInto(*out)
	}
	if in.SCRAMSHA512 != nil {
		in, out := &in.SCRAMSHA512, &out.SCRAMSHA512
		*out = new(SASLPlain)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SASL.
func (in *SASL) DeepCopy() *SASL {
	if in == nil {
		return nil
	}
	out := new(SASL)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *SASLPlain) DeepCopyInto(out *SASLPlain) {
	*out = *in
	if in.UserSecret != nil {
		in, out := &in.UserSecret, &out.UserSecret
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	if in.PasswordSecret != nil {
		in, out := &in.PasswordSecret, &out.PasswordSecret
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SASLPlain.
func (in *SASLPlain) DeepCopy() *SASLPlain {
	if in == nil {
		return nil
	}
	out := new(SASLPlain)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Scale) DeepCopyInto(out *Scale) {
	*out = *in
	if in.Min != nil {
		in, out := &in.Min, &out.Min
		*out = new(int32)
		**out = **in
	}
	if in.Max != nil {
		in, out := &in.Max, &out.Max
		*out = new(int32)
		**out = **in
	}
	if in.LookbackSeconds != nil {
		in, out := &in.LookbackSeconds, &out.LookbackSeconds
		*out = new(uint32)
		**out = **in
	}
	if in.DeprecatedCooldownSeconds != nil {
		in, out := &in.DeprecatedCooldownSeconds, &out.DeprecatedCooldownSeconds
		*out = new(uint32)
		**out = **in
	}
	if in.ZeroReplicaSleepSeconds != nil {
		in, out := &in.ZeroReplicaSleepSeconds, &out.ZeroReplicaSleepSeconds
		*out = new(uint32)
		**out = **in
	}
	if in.TargetProcessingSeconds != nil {
		in, out := &in.TargetProcessingSeconds, &out.TargetProcessingSeconds
		*out = new(uint32)
		**out = **in
	}
	if in.TargetBufferAvailability != nil {
		in, out := &in.TargetBufferAvailability, &out.TargetBufferAvailability
		*out = new(uint32)
		**out = **in
	}
	if in.ReplicasPerScale != nil {
		in, out := &in.ReplicasPerScale, &out.ReplicasPerScale
		*out = new(uint32)
		**out = **in
	}
	if in.ScaleUpCooldownSeconds != nil {
		in, out := &in.ScaleUpCooldownSeconds, &out.ScaleUpCooldownSeconds
		*out = new(uint32)
		**out = **in
	}
	if in.ScaleDownCooldownSeconds != nil {
		in, out := &in.ScaleDownCooldownSeconds, &out.ScaleDownCooldownSeconds
		*out = new(uint32)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Scale.
func (in *Scale) DeepCopy() *Scale {
	if in == nil {
		return nil
	}
	out := new(Scale)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *SessionWindow) DeepCopyInto(out *SessionWindow) {
	*out = *in
	if in.Timeout != nil {
		in, out := &in.Timeout, &out.Timeout
		*out = new(metav1.Duration)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SessionWindow.
func (in *SessionWindow) DeepCopy() *SessionWindow {
	if in == nil {
		return nil
	}
	out := new(SessionWindow)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *SideInput) DeepCopyInto(out *SideInput) {
	*out = *in
	if in.Container != nil {
		in, out := &in.Container, &out.Container
		*out = new(Container)
		(*in).DeepCopyInto(*out)
	}
	if in.Volumes != nil {
		in, out := &in.Volumes, &out.Volumes
		*out = make([]v1.Volume, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	if in.Trigger != nil {
		in, out := &in.Trigger, &out.Trigger
		*out = new(SideInputTrigger)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SideInput.
func (in *SideInput) DeepCopy() *SideInput {
	if in == nil {
		return nil
	}
	out := new(SideInput)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *SideInputTrigger) DeepCopyInto(out *SideInputTrigger) {
	*out = *in
	if in.Timezone != nil {
		in, out := &in.Timezone, &out.Timezone
		*out = new(string)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SideInputTrigger.
func (in *SideInputTrigger) DeepCopy() *SideInputTrigger {
	if in == nil {
		return nil
	}
	out := new(SideInputTrigger)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *SideInputsManagerTemplate) DeepCopyInto(out *SideInputsManagerTemplate) {
	*out = *in
	in.AbstractPodTemplate.DeepCopyInto(&out.AbstractPodTemplate)
	if in.ContainerTemplate != nil {
		in, out := &in.ContainerTemplate, &out.ContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.InitContainerTemplate != nil {
		in, out := &in.InitContainerTemplate, &out.InitContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SideInputsManagerTemplate.
func (in *SideInputsManagerTemplate) DeepCopy() *SideInputsManagerTemplate {
	if in == nil {
		return nil
	}
	out := new(SideInputsManagerTemplate)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Sink) DeepCopyInto(out *Sink) {
	*out = *in
	in.AbstractSink.DeepCopyInto(&out.AbstractSink)
	if in.Fallback != nil {
		in, out := &in.Fallback, &out.Fallback
		*out = new(AbstractSink)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Sink.
func (in *Sink) DeepCopy() *Sink {
	if in == nil {
		return nil
	}
	out := new(Sink)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *SlidingWindow) DeepCopyInto(out *SlidingWindow) {
	*out = *in
	if in.Length != nil {
		in, out := &in.Length, &out.Length
		*out = new(metav1.Duration)
		**out = **in
	}
	if in.Slide != nil {
		in, out := &in.Slide, &out.Slide
		*out = new(metav1.Duration)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SlidingWindow.
func (in *SlidingWindow) DeepCopy() *SlidingWindow {
	if in == nil {
		return nil
	}
	out := new(SlidingWindow)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Source) DeepCopyInto(out *Source) {
	*out = *in
	if in.Generator != nil {
		in, out := &in.Generator, &out.Generator
		*out = new(GeneratorSource)
		(*in).DeepCopyInto(*out)
	}
	if in.Kafka != nil {
		in, out := &in.Kafka, &out.Kafka
		*out = new(KafkaSource)
		(*in).DeepCopyInto(*out)
	}
	if in.HTTP != nil {
		in, out := &in.HTTP, &out.HTTP
		*out = new(HTTPSource)
		(*in).DeepCopyInto(*out)
	}
	if in.Nats != nil {
		in, out := &in.Nats, &out.Nats
		*out = new(NatsSource)
		(*in).DeepCopyInto(*out)
	}
	if in.UDTransformer != nil {
		in, out := &in.UDTransformer, &out.UDTransformer
		*out = new(UDTransformer)
		(*in).DeepCopyInto(*out)
	}
	if in.UDSource != nil {
		in, out := &in.UDSource, &out.UDSource
		*out = new(UDSource)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Source.
func (in *Source) DeepCopy() *Source {
	if in == nil {
		return nil
	}
	out := new(Source)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Status) DeepCopyInto(out *Status) {
	*out = *in
	if in.Conditions != nil {
		in, out := &in.Conditions, &out.Conditions
		*out = make([]metav1.Condition, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Status.
func (in *Status) DeepCopy() *Status {
	if in == nil {
		return nil
	}
	out := new(Status)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *TLS) DeepCopyInto(out *TLS) {
	*out = *in
	if in.CACertSecret != nil {
		in, out := &in.CACertSecret, &out.CACertSecret
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	if in.CertSecret != nil {
		in, out := &in.CertSecret, &out.CertSecret
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	if in.KeySecret != nil {
		in, out := &in.KeySecret, &out.KeySecret
		*out = new(v1.SecretKeySelector)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLS.
func (in *TLS) DeepCopy() *TLS {
	if in == nil {
		return nil
	}
	out := new(TLS)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *TagConditions) DeepCopyInto(out *TagConditions) {
	*out = *in
	if in.Operator != nil {
		in, out := &in.Operator, &out.Operator
		*out = new(LogicOperator)
		**out = **in
	}
	if in.Values != nil {
		in, out := &in.Values, &out.Values
		*out = make([]string, len(*in))
		copy(*out, *in)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TagConditions.
func (in *TagConditions) DeepCopy() *TagConditions {
	if in == nil {
		return nil
	}
	out := new(TagConditions)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Templates) DeepCopyInto(out *Templates) {
	*out = *in
	if in.DaemonTemplate != nil {
		in, out := &in.DaemonTemplate, &out.DaemonTemplate
		*out = new(DaemonTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.JobTemplate != nil {
		in, out := &in.JobTemplate, &out.JobTemplate
		*out = new(JobTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.SideInputsManagerTemplate != nil {
		in, out := &in.SideInputsManagerTemplate, &out.SideInputsManagerTemplate
		*out = new(SideInputsManagerTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.VertexTemplate != nil {
		in, out := &in.VertexTemplate, &out.VertexTemplate
		*out = new(VertexTemplate)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Templates.
func (in *Templates) DeepCopy() *Templates {
	if in == nil {
		return nil
	}
	out := new(Templates)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Transformer) DeepCopyInto(out *Transformer) {
	*out = *in
	if in.Args != nil {
		in, out := &in.Args, &out.Args
		*out = make([]string, len(*in))
		copy(*out, *in)
	}
	if in.KWArgs != nil {
		in, out := &in.KWArgs, &out.KWArgs
		*out = make(map[string]string, len(*in))
		for key, val := range *in {
			(*out)[key] = val
		}
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Transformer.
func (in *Transformer) DeepCopy() *Transformer {
	if in == nil {
		return nil
	}
	out := new(Transformer)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *UDF) DeepCopyInto(out *UDF) {
	*out = *in
	if in.Container != nil {
		in, out := &in.Container, &out.Container
		*out = new(Container)
		(*in).DeepCopyInto(*out)
	}
	if in.Builtin != nil {
		in, out := &in.Builtin, &out.Builtin
		*out = new(Function)
		(*in).DeepCopyInto(*out)
	}
	if in.GroupBy != nil {
		in, out := &in.GroupBy, &out.GroupBy
		*out = new(GroupBy)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UDF.
func (in *UDF) DeepCopy() *UDF {
	if in == nil {
		return nil
	}
	out := new(UDF)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *UDSink) DeepCopyInto(out *UDSink) {
	*out = *in
	in.Container.DeepCopyInto(&out.Container)
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UDSink.
func (in *UDSink) DeepCopy() *UDSink {
	if in == nil {
		return nil
	}
	out := new(UDSink)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *UDSource) DeepCopyInto(out *UDSource) {
	*out = *in
	if in.Container != nil {
		in, out := &in.Container, &out.Container
		*out = new(Container)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UDSource.
func (in *UDSource) DeepCopy() *UDSource {
	if in == nil {
		return nil
	}
	out := new(UDSource)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *UDTransformer) DeepCopyInto(out *UDTransformer) {
	*out = *in
	if in.Container != nil {
		in, out := &in.Container, &out.Container
		*out = new(Container)
		(*in).DeepCopyInto(*out)
	}
	if in.Builtin != nil {
		in, out := &in.Builtin, &out.Builtin
		*out = new(Transformer)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UDTransformer.
func (in *UDTransformer) DeepCopy() *UDTransformer {
	if in == nil {
		return nil
	}
	out := new(UDTransformer)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Vertex) DeepCopyInto(out *Vertex) {
	*out = *in
	out.TypeMeta = in.TypeMeta
	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
	in.Spec.DeepCopyInto(&out.Spec)
	in.Status.DeepCopyInto(&out.Status)
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Vertex.
func (in *Vertex) DeepCopy() *Vertex {
	if in == nil {
		return nil
	}
	out := new(Vertex)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *Vertex) DeepCopyObject() runtime.Object {
	if c := in.DeepCopy(); c != nil {
		return c
	}
	return nil
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *VertexInstance) DeepCopyInto(out *VertexInstance) {
	*out = *in
	if in.Vertex != nil {
		in, out := &in.Vertex, &out.Vertex
		*out = new(Vertex)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VertexInstance.
func (in *VertexInstance) DeepCopy() *VertexInstance {
	if in == nil {
		return nil
	}
	out := new(VertexInstance)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *VertexLimits) DeepCopyInto(out *VertexLimits) {
	*out = *in
	if in.ReadBatchSize != nil {
		in, out := &in.ReadBatchSize, &out.ReadBatchSize
		*out = new(uint64)
		**out = **in
	}
	if in.ReadTimeout != nil {
		in, out := &in.ReadTimeout, &out.ReadTimeout
		*out = new(metav1.Duration)
		**out = **in
	}
	if in.BufferMaxLength != nil {
		in, out := &in.BufferMaxLength, &out.BufferMaxLength
		*out = new(uint64)
		**out = **in
	}
	if in.BufferUsageLimit != nil {
		in, out := &in.BufferUsageLimit, &out.BufferUsageLimit
		*out = new(uint32)
		**out = **in
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VertexLimits.
func (in *VertexLimits) DeepCopy() *VertexLimits {
	if in == nil {
		return nil
	}
	out := new(VertexLimits)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *VertexList) DeepCopyInto(out *VertexList) {
	*out = *in
	out.TypeMeta = in.TypeMeta
	in.ListMeta.DeepCopyInto(&out.ListMeta)
	if in.Items != nil {
		in, out := &in.Items, &out.Items
		*out = make([]Vertex, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VertexList.
func (in *VertexList) DeepCopy() *VertexList {
	if in == nil {
		return nil
	}
	out := new(VertexList)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (in *VertexList) DeepCopyObject() runtime.Object {
	if c := in.DeepCopy(); c != nil {
		return c
	}
	return nil
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *VertexSpec) DeepCopyInto(out *VertexSpec) {
	*out = *in
	in.AbstractVertex.DeepCopyInto(&out.AbstractVertex)
	if in.Replicas != nil {
		in, out := &in.Replicas, &out.Replicas
		*out = new(int32)
		**out = **in
	}
	if in.FromEdges != nil {
		in, out := &in.FromEdges, &out.FromEdges
		*out = make([]CombinedEdge, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	if in.ToEdges != nil {
		in, out := &in.ToEdges, &out.ToEdges
		*out = make([]CombinedEdge, len(*in))
		for i := range *in {
			(*in)[i].DeepCopyInto(&(*out)[i])
		}
	}
	in.Watermark.DeepCopyInto(&out.Watermark)
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VertexSpec.
func (in *VertexSpec) DeepCopy() *VertexSpec {
	if in == nil {
		return nil
	}
	out := new(VertexSpec)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *VertexStatus) DeepCopyInto(out *VertexStatus) {
	*out = *in
	in.LastScaledAt.DeepCopyInto(&out.LastScaledAt)
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VertexStatus.
func (in *VertexStatus) DeepCopy() *VertexStatus {
	if in == nil {
		return nil
	}
	out := new(VertexStatus)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *VertexTemplate) DeepCopyInto(out *VertexTemplate) {
	*out = *in
	in.AbstractPodTemplate.DeepCopyInto(&out.AbstractPodTemplate)
	if in.ContainerTemplate != nil {
		in, out := &in.ContainerTemplate, &out.ContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	if in.InitContainerTemplate != nil {
		in, out := &in.InitContainerTemplate, &out.InitContainerTemplate
		*out = new(ContainerTemplate)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VertexTemplate.
func (in *VertexTemplate) DeepCopy() *VertexTemplate {
	if in == nil {
		return nil
	}
	out := new(VertexTemplate)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Watermark) DeepCopyInto(out *Watermark) {
	*out = *in
	if in.MaxDelay != nil {
		in, out := &in.MaxDelay, &out.MaxDelay
		*out = new(metav1.Duration)
		**out = **in
	}
	if in.IdleSource != nil {
		in, out := &in.IdleSource, &out.IdleSource
		*out = new(IdleSource)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Watermark.
func (in *Watermark) DeepCopy() *Watermark {
	if in == nil {
		return nil
	}
	out := new(Watermark)
	in.DeepCopyInto(out)
	return out
}

// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (in *Window) DeepCopyInto(out *Window) {
	*out = *in
	if in.Fixed != nil {
		in, out := &in.Fixed, &out.Fixed
		*out = new(FixedWindow)
		(*in).DeepCopyInto(*out)
	}
	if in.Sliding != nil {
		in, out := &in.Sliding, &out.Sliding
		*out = new(SlidingWindow)
		(*in).DeepCopyInto(*out)
	}
	if in.Session != nil {
		in, out := &in.Session, &out.Session
		*out = new(SessionWindow)
		(*in).DeepCopyInto(*out)
	}
	return
}

// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Window.
func (in *Window) DeepCopy() *Window {
	if in == nil {
		return nil
	}
	out := new(Window)
	in.DeepCopyInto(out)
	return out
}