v1alpha1

package

Go to main page

Versions in this module

v1

v1.4.0

Nov 8, 2024

Changes in this version

+ const EnvExecuteRustBinary

+ const ISBSvcPhaseDeleting

+ const KeyInstance

type InterStepBufferService

+ func (isbs InterStepBufferService) GetType() ISBSvcType

type KafkaSink

+ SetKey bool

type KafkaSource

+ KafkaVersion string

v1.3.3

Oct 10, 2024

Changes in this version

type Container

+ Ports []corev1.ContainerPort

v1.3.2

Sep 26, 2024

Changes in this version

+ const MonoVertexPhasePaused

+ const NumaContainerLivezFailureThreshold

+ const NumaContainerLivezInitialDelaySeconds

+ const NumaContainerLivezPeriodSeconds

+ const NumaContainerLivezTimeoutSeconds

+ const NumaContainerReadyzFailureThreshold

+ const NumaContainerReadyzInitialDelaySeconds

+ const NumaContainerReadyzPeriodSeconds

+ const NumaContainerReadyzTimeoutSeconds

+ const UDContainerLivezFailureThreshold

+ const UDContainerLivezInitialDelaySeconds

+ const UDContainerLivezPeriodSeconds

+ const UDContainerLivezTimeoutSeconds

+ const VertexConditionDeployed

+ func GetProbeFailureThresholdOr(probe *Probe, defaultValue int32) int32

+ func GetProbeInitialDelaySecondsOr(probe *Probe, defaultValue int32) int32

+ func GetProbePeriodSecondsOr(probe *Probe, defaultValue int32) int32

+ func GetProbeSuccessThresholdOr(probe *Probe, defaultValue int32) int32

+ func GetProbeTimeoutSecondsOr(probe *Probe, defaultValue int32) int32

type AbstractVertex

+ UpdateStrategy UpdateStrategy

type Container

+ LivenessProbe *Probe

+ ReadinessProbe *Probe

type ContainerTemplate

+ LivenessProbe *Probe

+ ReadinessProbe *Probe

type MonoVertex

+ func (mv MonoVertex) CalculateReplicas() int

+ type MonoVertexLifecycle struct

+ DesiredPhase MonoVertexPhase

+ func (*MonoVertexLifecycle) Descriptor() ([]byte, []int)

+ func (*MonoVertexLifecycle) ProtoMessage()

+ func (in *MonoVertexLifecycle) DeepCopy() *MonoVertexLifecycle

+ func (in *MonoVertexLifecycle) DeepCopyInto(out *MonoVertexLifecycle)

+ func (lc MonoVertexLifecycle) GetDesiredPhase() MonoVertexPhase

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

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

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

+ func (m *MonoVertexLifecycle) Reset()

+ func (m *MonoVertexLifecycle) Size() (n int)

+ func (m *MonoVertexLifecycle) Unmarshal(dAtA []byte) error

+ func (m *MonoVertexLifecycle) XXX_DiscardUnknown()

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

+ func (m *MonoVertexLifecycle) XXX_Merge(src proto.Message)

+ func (m *MonoVertexLifecycle) XXX_Size() int

+ func (m *MonoVertexLifecycle) XXX_Unmarshal(b []byte) error

+ func (this *MonoVertexLifecycle) String() string

type MonoVertexSpec

+ Lifecycle MonoVertexLifecycle

+ UpdateStrategy UpdateStrategy

type MonoVertexStatus

+ DesiredReplicas uint32

+ UpdatedReadyReplicas uint32

+ func (mvs *MonoVertexStatus) MarkPhasePaused()

type PipelineStatus

+ DrainedOnPause bool

+ func (pls *PipelineStatus) MarkDrainedOnPauseFalse()

+ func (pls *PipelineStatus) MarkDrainedOnPauseTrue()

+ type Probe struct

+ FailureThreshold *int32

+ InitialDelaySeconds *int32

+ PeriodSeconds *int32

+ SuccessThreshold *int32

+ TimeoutSeconds *int32

+ func (*Probe) Descriptor() ([]byte, []int)

+ func (*Probe) ProtoMessage()

+ func (in *Probe) DeepCopy() *Probe

+ func (in *Probe) DeepCopyInto(out *Probe)

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

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

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

+ func (m *Probe) Reset()

+ func (m *Probe) Size() (n int)

+ func (m *Probe) Unmarshal(dAtA []byte) error

+ func (m *Probe) XXX_DiscardUnknown()

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

+ func (m *Probe) XXX_Merge(src proto.Message)

+ func (m *Probe) XXX_Size() int

+ func (m *Probe) XXX_Unmarshal(b []byte) error

+ func (this *Probe) String() string

+ type RollingUpdateStrategy struct

+ MaxUnavailable *intstr.IntOrString

+ func (*RollingUpdateStrategy) Descriptor() ([]byte, []int)

+ func (*RollingUpdateStrategy) ProtoMessage()

+ func (in *RollingUpdateStrategy) DeepCopy() *RollingUpdateStrategy

+ func (in *RollingUpdateStrategy) DeepCopyInto(out *RollingUpdateStrategy)

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

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

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

+ func (m *RollingUpdateStrategy) Reset()

+ func (m *RollingUpdateStrategy) Size() (n int)

+ func (m *RollingUpdateStrategy) Unmarshal(dAtA []byte) error

+ func (m *RollingUpdateStrategy) XXX_DiscardUnknown()

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

+ func (m *RollingUpdateStrategy) XXX_Merge(src proto.Message)

+ func (m *RollingUpdateStrategy) XXX_Size() int

+ func (m *RollingUpdateStrategy) XXX_Unmarshal(b []byte) error

+ func (rus RollingUpdateStrategy) GetMaxUnavailable() intstr.IntOrString

+ func (this *RollingUpdateStrategy) String() string

+ type UpdateStrategy struct

+ RollingUpdate *RollingUpdateStrategy

+ Type UpdateStrategyType

+ func (*UpdateStrategy) Descriptor() ([]byte, []int)

+ func (*UpdateStrategy) ProtoMessage()

+ func (in *UpdateStrategy) DeepCopy() *UpdateStrategy

+ func (in *UpdateStrategy) DeepCopyInto(out *UpdateStrategy)

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

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

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

+ func (m *UpdateStrategy) Reset()

+ func (m *UpdateStrategy) Size() (n int)

+ func (m *UpdateStrategy) Unmarshal(dAtA []byte) error

+ func (m *UpdateStrategy) XXX_DiscardUnknown()

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

+ func (m *UpdateStrategy) XXX_Merge(src proto.Message)

+ func (m *UpdateStrategy) XXX_Size() int

+ func (m *UpdateStrategy) XXX_Unmarshal(b []byte) error

+ func (this *UpdateStrategy) String() string

+ func (us UpdateStrategy) GetRollingUpdateStrategy() RollingUpdateStrategy

+ func (us UpdateStrategy) GetUpdateStrategyType() UpdateStrategyType

+ type UpdateStrategyType string

+ const RollingUpdateStrategyType

type VertexStatus

+ DesiredReplicas uint32

+ UpdatedReadyReplicas uint32

+ func (vs *VertexStatus) MarkDeployFailed(reason, message string)

+ func (vs *VertexStatus) MarkDeployed()

v1.3.1

Sep 3, 2024

Changes in this version

+ const ComponentControllerManager

+ const DefaultOnFailureRetryStrategy

+ const DefaultRetryInterval

+ const DefaultRetrySteps

type AbstractPodTemplate

+ ResourceClaims []corev1.PodResourceClaim

+ type Backoff struct

+ Interval *metav1.Duration

+ Steps *uint32

+ func (*Backoff) Descriptor() ([]byte, []int)

+ func (*Backoff) ProtoMessage()

+ func (in *Backoff) DeepCopy() *Backoff

+ func (in *Backoff) DeepCopyInto(out *Backoff)

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

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

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

+ func (m *Backoff) Reset()

+ func (m *Backoff) Size() (n int)

+ func (m *Backoff) Unmarshal(dAtA []byte) error

+ func (m *Backoff) XXX_DiscardUnknown()

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

+ func (m *Backoff) XXX_Merge(src proto.Message)

+ func (m *Backoff) XXX_Size() int

+ func (m *Backoff) XXX_Unmarshal(b []byte) error

+ func (this *Backoff) String() string

type MonoVertexStatus

+ CurrentHash string

+ CurrentReplicas uint32

+ ReadyReplicas uint32

+ UpdateHash string

+ UpdatedReplicas uint32

+ type OnFailureRetryStrategy string

+ const OnFailureDrop

+ const OnFailureFallback

+ const OnFailureRetry

+ type RetryStrategy struct

+ BackOff *Backoff

+ OnFailure *OnFailureRetryStrategy

+ func (*RetryStrategy) Descriptor() ([]byte, []int)

+ func (*RetryStrategy) ProtoMessage()

+ func (in *RetryStrategy) DeepCopy() *RetryStrategy

+ func (in *RetryStrategy) DeepCopyInto(out *RetryStrategy)

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

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

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

+ func (m *RetryStrategy) Reset()

+ func (m *RetryStrategy) Size() (n int)

+ func (m *RetryStrategy) Unmarshal(dAtA []byte) error

+ func (m *RetryStrategy) XXX_DiscardUnknown()

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

+ func (m *RetryStrategy) XXX_Merge(src proto.Message)

+ func (m *RetryStrategy) XXX_Size() int

+ func (m *RetryStrategy) XXX_Unmarshal(b []byte) error

+ func (r RetryStrategy) GetBackoff() wait.Backoff

+ func (r RetryStrategy) GetOnFailureRetryStrategy() OnFailureRetryStrategy

+ func (this *RetryStrategy) String() string

type Scale

+ DeprecatedReplicasPerScale *uint32

+ ReplicasPerScaleDown *uint32

+ ReplicasPerScaleUp *uint32

+ func (s Scale) GetReplicasPerScaleDown() int

+ func (s Scale) GetReplicasPerScaleUp() int

type Sink

+ RetryStrategy RetryStrategy

type VertexStatus

+ CurrentHash string

+ CurrentReplicas uint32

+ ReadyReplicas uint32

+ UpdateHash string

+ UpdatedReplicas uint32

v1.3.0

Aug 19, 2024

Changes in this version

+ const CallbackEnabledKey

+ const CallbackURLKey

+ const ComponentMonoVertex

+ const ComponentMonoVertexDaemon

+ const ControllerMonoVertex

+ const CtrServing

+ const DefaultKafkaHandlerChannelSize

+ const DefaultReadTimeout

+ const DefaultServingTTL

+ const EnvCallbackEnabled

+ const EnvCallbackURL

+ const EnvMonoVertexName

+ const EnvMonoVertexObject

+ const EnvServingAuthToken

+ const EnvServingHostIP

+ const EnvServingJetstreamStream

+ const EnvServingMinPipelineSpec

+ const EnvServingObject

+ const EnvServingPort

+ const EnvServingStoreTTL

+ const ISBSvcConditionChildrenResourcesHealthy

+ const KeyMetaCallbackURL

+ const KeyMonoVertexName

+ const MonoVertexConditionDaemonHealthy

+ const MonoVertexConditionDeployed

+ const MonoVertexDaemonServicePort

+ const MonoVertexMetricsPort

+ const MonoVertexMetricsPortName

+ const MonoVertexPhaseFailed

+ const MonoVertexPhaseRunning

+ const MonoVertexPhaseUnknown

+ const MonoVertexPodsHealthy

+ const MonoVertexStatusCritical

+ const MonoVertexStatusHealthy

+ const MonoVertexStatusUnhealthy

+ const MonoVertexStatusUnknown

+ const MonoVertexStatusWarning

+ const NumaflowRustBinary

+ const PipelineConditionDaemonServiceHealthy

+ const PipelineConditionSideInputsManagersHealthy

+ const PipelineConditionVerticesHealthy

+ const ServingSourceContainer

+ const VertexConditionPodsHealthy

+ var MonoVertexGroupVersionKind = SchemeGroupVersion.WithKind("MonoVertex")

+ var MonoVertexGroupVersionResource = SchemeGroupVersion.WithResource("monovertices")

type GeneratorSource

+ ValueBlob *string

+ type GetMonoVertexDaemonDeploymentReq struct

+ DefaultResources corev1.ResourceRequirements

+ Env []corev1.EnvVar

+ Image string

+ PullPolicy corev1.PullPolicy

+ func (*GetMonoVertexDaemonDeploymentReq) Descriptor() ([]byte, []int)

+ func (*GetMonoVertexDaemonDeploymentReq) ProtoMessage()

+ func (in *GetMonoVertexDaemonDeploymentReq) DeepCopy() *GetMonoVertexDaemonDeploymentReq

+ func (in *GetMonoVertexDaemonDeploymentReq) DeepCopyInto(out *GetMonoVertexDaemonDeploymentReq)

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

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

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

+ func (m *GetMonoVertexDaemonDeploymentReq) Reset()

+ func (m *GetMonoVertexDaemonDeploymentReq) Size() (n int)

+ func (m *GetMonoVertexDaemonDeploymentReq) Unmarshal(dAtA []byte) error

+ func (m *GetMonoVertexDaemonDeploymentReq) XXX_DiscardUnknown()

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

+ func (m *GetMonoVertexDaemonDeploymentReq) XXX_Merge(src proto.Message)

+ func (m *GetMonoVertexDaemonDeploymentReq) XXX_Size() int

+ func (m *GetMonoVertexDaemonDeploymentReq) XXX_Unmarshal(b []byte) error

+ func (this *GetMonoVertexDaemonDeploymentReq) String() string

+ type GetMonoVertexPodSpecReq struct

+ DefaultResources corev1.ResourceRequirements

+ Env []corev1.EnvVar

+ Image string

+ PullPolicy corev1.PullPolicy

+ func (*GetMonoVertexPodSpecReq) Descriptor() ([]byte, []int)

+ func (*GetMonoVertexPodSpecReq) ProtoMessage()

+ func (in *GetMonoVertexPodSpecReq) DeepCopy() *GetMonoVertexPodSpecReq

+ func (in *GetMonoVertexPodSpecReq) DeepCopyInto(out *GetMonoVertexPodSpecReq)

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

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

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

+ func (m *GetMonoVertexPodSpecReq) Reset()

+ func (m *GetMonoVertexPodSpecReq) Size() (n int)

+ func (m *GetMonoVertexPodSpecReq) Unmarshal(dAtA []byte) error

+ func (m *GetMonoVertexPodSpecReq) XXX_DiscardUnknown()

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

+ func (m *GetMonoVertexPodSpecReq) XXX_Merge(src proto.Message)

+ func (m *GetMonoVertexPodSpecReq) XXX_Size() int

+ func (m *GetMonoVertexPodSpecReq) XXX_Unmarshal(b []byte) error

+ func (this *GetMonoVertexPodSpecReq) String() string

type GetVertexPodSpecReq

+ PipelineSpec PipelineSpec

+ ServingSourceStreamName string

type InterStepBufferServiceStatus

+ ObservedGeneration int64

+ func (iss *InterStepBufferServiceStatus) IsHealthy() bool

+ func (iss *InterStepBufferServiceStatus) MarkChildrenResourceHealthy(reason, message string)

+ func (iss *InterStepBufferServiceStatus) MarkChildrenResourceUnHealthy(reason, message string)

+ func (iss *InterStepBufferServiceStatus) SetObservedGeneration(value int64)

+ type JetStreamSource struct

+ Auth *NatsAuth

+ Stream string

+ TLS *TLS

+ URL string

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

+ func (*JetStreamSource) ProtoMessage()

+ func (in *JetStreamSource) DeepCopy() *JetStreamSource

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

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

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

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

+ func (m *JetStreamSource) Reset()

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

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

+ func (m *JetStreamSource) XXX_DiscardUnknown()

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

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

+ func (m *JetStreamSource) XXX_Size() int

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

+ func (this *JetStreamSource) String() string

+ type MonoVertex struct

+ Spec MonoVertexSpec

+ Status MonoVertexStatus

+ func (*MonoVertex) Descriptor() ([]byte, []int)

+ func (*MonoVertex) ProtoMessage()

+ func (in *MonoVertex) DeepCopy() *MonoVertex

+ func (in *MonoVertex) DeepCopyInto(out *MonoVertex)

+ func (in *MonoVertex) DeepCopyObject() runtime.Object

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

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

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

+ func (m *MonoVertex) Reset()

+ func (m *MonoVertex) Size() (n int)

+ func (m *MonoVertex) Unmarshal(dAtA []byte) error

+ func (m *MonoVertex) XXX_DiscardUnknown()

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

+ func (m *MonoVertex) XXX_Merge(src proto.Message)

+ func (m *MonoVertex) XXX_Size() int

+ func (m *MonoVertex) XXX_Unmarshal(b []byte) error

+ func (mv MonoVertex) GetDaemonDeploymentName() string

+ func (mv MonoVertex) GetDaemonDeploymentObj(req GetMonoVertexDaemonDeploymentReq) (*appv1.Deployment, error)

+ func (mv MonoVertex) GetDaemonServiceName() string

+ func (mv MonoVertex) GetDaemonServiceObj() *corev1.Service

+ func (mv MonoVertex) GetDaemonServiceURL() string

+ func (mv MonoVertex) GetHeadlessServiceName() string

+ func (mv MonoVertex) GetPodSpec(req GetMonoVertexPodSpecReq) (*corev1.PodSpec, error)

+ func (mv MonoVertex) GetReplicas() int

+ func (mv MonoVertex) GetServiceObjs() []*corev1.Service

+ func (mv MonoVertex) Scalable() bool

+ func (this *MonoVertex) String() string

+ type MonoVertexLimits struct

+ ReadBatchSize *uint64

+ ReadTimeout *metav1.Duration

+ func (*MonoVertexLimits) Descriptor() ([]byte, []int)

+ func (*MonoVertexLimits) ProtoMessage()

+ func (in *MonoVertexLimits) DeepCopy() *MonoVertexLimits

+ func (in *MonoVertexLimits) DeepCopyInto(out *MonoVertexLimits)

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

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

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

+ func (m *MonoVertexLimits) Reset()

+ func (m *MonoVertexLimits) Size() (n int)

+ func (m *MonoVertexLimits) Unmarshal(dAtA []byte) error

+ func (m *MonoVertexLimits) XXX_DiscardUnknown()

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

+ func (m *MonoVertexLimits) XXX_Merge(src proto.Message)

+ func (m *MonoVertexLimits) XXX_Size() int

+ func (m *MonoVertexLimits) XXX_Unmarshal(b []byte) error

+ func (mvl MonoVertexLimits) GetReadBatchSize() uint64

+ func (mvl MonoVertexLimits) GetReadTimeout() time.Duration

+ func (this *MonoVertexLimits) String() string

+ type MonoVertexList struct

+ Items []MonoVertex

+ func (*MonoVertexList) Descriptor() ([]byte, []int)

+ func (*MonoVertexList) ProtoMessage()

+ func (in *MonoVertexList) DeepCopy() *MonoVertexList

+ func (in *MonoVertexList) DeepCopyInto(out *MonoVertexList)

+ func (in *MonoVertexList) DeepCopyObject() runtime.Object

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

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

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

+ func (m *MonoVertexList) Reset()

+ func (m *MonoVertexList) Size() (n int)

+ func (m *MonoVertexList) Unmarshal(dAtA []byte) error

+ func (m *MonoVertexList) XXX_DiscardUnknown()

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

+ func (m *MonoVertexList) XXX_Merge(src proto.Message)

+ func (m *MonoVertexList) XXX_Size() int

+ func (m *MonoVertexList) XXX_Unmarshal(b []byte) error

+ func (this *MonoVertexList) String() string

+ type MonoVertexPhase string

+ type MonoVertexSpec struct

+ ContainerTemplate *ContainerTemplate

+ DaemonTemplate *DaemonTemplate

+ InitContainers []corev1.Container

+ Limits *MonoVertexLimits

+ Replicas *int32

+ Scale Scale

+ Sidecars []corev1.Container

+ Sink *Sink

+ Source *Source

+ Volumes []corev1.Volume

+ func (*MonoVertexSpec) Descriptor() ([]byte, []int)

+ func (*MonoVertexSpec) ProtoMessage()

+ func (in *MonoVertexSpec) DeepCopy() *MonoVertexSpec

+ func (in *MonoVertexSpec) DeepCopyInto(out *MonoVertexSpec)

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

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

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

+ func (m *MonoVertexSpec) Reset()

+ func (m *MonoVertexSpec) Size() (n int)

+ func (m *MonoVertexSpec) Unmarshal(dAtA []byte) error

+ func (m *MonoVertexSpec) XXX_DiscardUnknown()

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

+ func (m *MonoVertexSpec) XXX_Merge(src proto.Message)

+ func (m *MonoVertexSpec) XXX_Size() int

+ func (m *MonoVertexSpec) XXX_Unmarshal(b []byte) error

+ func (mvspec MonoVertexSpec) DeepCopyWithoutReplicas() MonoVertexSpec

+ func (this *MonoVertexSpec) String() string

+ type MonoVertexStatus struct

+ LastScaledAt metav1.Time

+ LastUpdated metav1.Time

+ Message string

+ ObservedGeneration int64

+ Phase MonoVertexPhase

+ Reason string

+ Replicas uint32

+ Selector string

+ func (*MonoVertexStatus) Descriptor() ([]byte, []int)

+ func (*MonoVertexStatus) ProtoMessage()

+ func (in *MonoVertexStatus) DeepCopy() *MonoVertexStatus

+ func (in *MonoVertexStatus) DeepCopyInto(out *MonoVertexStatus)

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

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

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

+ func (m *MonoVertexStatus) Reset()

+ func (m *MonoVertexStatus) Size() (n int)

+ func (m *MonoVertexStatus) Unmarshal(dAtA []byte) error

+ func (m *MonoVertexStatus) XXX_DiscardUnknown()

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

+ func (m *MonoVertexStatus) XXX_Merge(src proto.Message)

+ func (m *MonoVertexStatus) XXX_Size() int

+ func (m *MonoVertexStatus) XXX_Unmarshal(b []byte) error

+ func (mvs *MonoVertexStatus) InitConditions()

+ func (mvs *MonoVertexStatus) IsHealthy() bool

+ func (mvs *MonoVertexStatus) MarkDaemonHealthy()

+ func (mvs *MonoVertexStatus) MarkDaemonUnHealthy(reason, message string)

+ func (mvs *MonoVertexStatus) MarkDeployFailed(reason, message string)

+ func (mvs *MonoVertexStatus) MarkDeployed()

+ func (mvs *MonoVertexStatus) MarkPhase(phase MonoVertexPhase, reason, message string)

+ func (mvs *MonoVertexStatus) MarkPhaseFailed(reason, message string)

+ func (mvs *MonoVertexStatus) MarkPhaseRunning()

+ func (mvs *MonoVertexStatus) MarkPodHealthy(reason, message string)

+ func (mvs *MonoVertexStatus) MarkPodNotHealthy(reason, message string)

+ func (mvs *MonoVertexStatus) SetObservedGeneration(value int64)

+ func (this *MonoVertexStatus) String() string

type Pipeline

+ func (p Pipeline) GetServingSourceStreamNames() []string

type PipelineStatus

+ MapUDFCount *uint32

+ ObservedGeneration int64

+ ReduceUDFCount *uint32

+ func (pls *PipelineStatus) IsHealthy() bool

+ func (pls *PipelineStatus) MarkDaemonServiceHealthy()

+ func (pls *PipelineStatus) MarkDaemonServiceUnHealthy(reason, message string)

+ func (pls *PipelineStatus) MarkSideInputsManagersHealthy()

+ func (pls *PipelineStatus) MarkSideInputsManagersHealthyWithReason(reason, message string)

+ func (pls *PipelineStatus) MarkSideInputsManagersUnHealthy(reason, message string)

+ func (pls *PipelineStatus) MarkVerticesHealthy()

+ func (pls *PipelineStatus) MarkVerticesUnHealthy(reason, message string)

+ func (pls *PipelineStatus) SetObservedGeneration(value int64)

+ type ServingSource struct

+ Auth *Authorization

+ MsgIDHeaderKey *string

+ Service bool

+ Store *ServingStore

+ func (*ServingSource) Descriptor() ([]byte, []int)

+ func (*ServingSource) ProtoMessage()

+ func (in *ServingSource) DeepCopy() *ServingSource

+ func (in *ServingSource) DeepCopyInto(out *ServingSource)

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

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

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

+ func (m *ServingSource) Reset()

+ func (m *ServingSource) Size() (n int)

+ func (m *ServingSource) Unmarshal(dAtA []byte) error

+ func (m *ServingSource) XXX_DiscardUnknown()

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

+ func (m *ServingSource) XXX_Merge(src proto.Message)

+ func (m *ServingSource) XXX_Size() int

+ func (m *ServingSource) XXX_Unmarshal(b []byte) error

+ func (this *ServingSource) String() string

+ type ServingStore struct

+ TTL *metav1.Duration

+ URL *string

+ func (*ServingStore) Descriptor() ([]byte, []int)

+ func (*ServingStore) ProtoMessage()

+ func (in *ServingStore) DeepCopy() *ServingStore

+ func (in *ServingStore) DeepCopyInto(out *ServingStore)

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

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

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

+ func (m *ServingStore) Reset()

+ func (m *ServingStore) Size() (n int)

+ func (m *ServingStore) Unmarshal(dAtA []byte) error

+ func (m *ServingStore) XXX_DiscardUnknown()

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

+ func (m *ServingStore) XXX_Merge(src proto.Message)

+ func (m *ServingStore) XXX_Size() int

+ func (m *ServingStore) XXX_Unmarshal(b []byte) error

+ func (ss *ServingStore) GetTTL() *metav1.Duration

+ func (this *ServingStore) String() string

type Source

+ JetStream *JetStreamSource

+ Serving *ServingSource

type Vertex

+ func (v Vertex) GetServingSourceStreamName() string

type VertexSpec

+ func (vs VertexSpec) DeepCopyWithoutReplicas() VertexSpec

type VertexStatus

+ ObservedGeneration int64

+ func (vs *VertexStatus) InitConditions()

+ func (vs *VertexStatus) IsHealthy() bool

+ func (vs *VertexStatus) MarkPodHealthy(reason, message string)

+ func (vs *VertexStatus) MarkPodNotHealthy(reason, message string)

+ func (vs *VertexStatus) SetObservedGeneration(value int64)

v1.3.0-rc1

Aug 9, 2024

v1.2.2

Nov 15, 2024

v1.2.1

May 7, 2024

v1.2.0

May 3, 2024

Changes in this version

+ const CtrFallbackUdsink

+ const DefaultCompactWALPath

+ const DefaultGCEventsWALEventsPath

+ const DefaultGCEventsWALRotationDuration

+ const DefaultGCEventsWALRotationEventsCount

+ const DefaultGCEventsWALSyncDuration

+ const DefaultPnfBatchSize

+ const DefaultPnfFlushDuration

+ const DefaultSegmentWALPath

+ const DefaultWALCompactionDuration

+ const DefaultWALCompactorMaxFileSize

+ const DefaultWALCompactorSyncDuration

+ const DefaultWALMaxSyncSize

+ const DefaultWALSegmentRotationDuration

+ const DefaultWALSegmentSize

+ const DefaultWALSyncDuration

+ const EnvLeaderElectionLeaseDuration

+ const EnvLeaderElectionLeaseRenewDeadline

+ const EnvLeaderElectionLeaseRenewPeriod

+ const EnvUDContainerType

+ const KeysDelimitter

+ const PipelineStatusCritical

+ const PipelineStatusDeleting

+ const PipelineStatusHealthy

+ const PipelineStatusInactive

+ const PipelineStatusUnhealthy

+ const PipelineStatusUnknown

+ const PipelineStatusWarning

+ const UDContainerFallbackSink

+ const UDContainerFunction

+ const UDContainerSideInputs

+ const UDContainerSink

+ const UDContainerSource

+ const UDContainerTransformer

+ type AbstractSink struct

+ Blackhole *Blackhole

+ Kafka *KafkaSink

+ Log *Log

+ UDSink *UDSink

+ func (*AbstractSink) Descriptor() ([]byte, []int)

+ func (*AbstractSink) ProtoMessage()

+ func (a *AbstractSink) IsAnySinkSpecified() bool

+ func (in *AbstractSink) DeepCopy() *AbstractSink

+ func (in *AbstractSink) DeepCopyInto(out *AbstractSink)

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

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

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

+ func (m *AbstractSink) Reset()

+ func (m *AbstractSink) Size() (n int)

+ func (m *AbstractSink) Unmarshal(dAtA []byte) error

+ func (m *AbstractSink) XXX_DiscardUnknown()

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

+ func (m *AbstractSink) XXX_Merge(src proto.Message)

+ func (m *AbstractSink) XXX_Size() int

+ func (m *AbstractSink) XXX_Unmarshal(b []byte) error

+ func (this *AbstractSink) String() string

type AbstractVertex

+ func (av AbstractVertex) HasFallbackUDSink() bool

type FixedWindow

+ Streaming bool

type GeneratorSource

+ Jitter *metav1.Duration

+ type NoStore struct

+ func (*NoStore) Descriptor() ([]byte, []int)

+ func (*NoStore) ProtoMessage()

+ func (in *NoStore) DeepCopy() *NoStore

+ func (in *NoStore) DeepCopyInto(out *NoStore)

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

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

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

+ func (m *NoStore) Reset()

+ func (m *NoStore) Size() (n int)

+ func (m *NoStore) Unmarshal(dAtA []byte) error

+ func (m *NoStore) XXX_DiscardUnknown()

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

+ func (m *NoStore) XXX_Merge(src proto.Message)

+ func (m *NoStore) XXX_Size() int

+ func (m *NoStore) XXX_Unmarshal(b []byte) error

+ func (this *NoStore) String() string

type PBQStorage

+ NoStore *NoStore

+ type SessionWindow struct

+ Timeout *metav1.Duration

+ func (*SessionWindow) Descriptor() ([]byte, []int)

+ func (*SessionWindow) ProtoMessage()

+ func (in *SessionWindow) DeepCopy() *SessionWindow

+ func (in *SessionWindow) DeepCopyInto(out *SessionWindow)

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

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

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

+ func (m *SessionWindow) Reset()

+ func (m *SessionWindow) Size() (n int)

+ func (m *SessionWindow) Unmarshal(dAtA []byte) error

+ func (m *SessionWindow) XXX_DiscardUnknown()

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

+ func (m *SessionWindow) XXX_Merge(src proto.Message)

+ func (m *SessionWindow) XXX_Size() int

+ func (m *SessionWindow) XXX_Unmarshal(b []byte) error

+ func (this *SessionWindow) String() string

type Sink

+ Fallback *AbstractSink

type SlidingWindow

+ Streaming bool

type Vertex

+ func (v Vertex) HasFallbackUDSink() bool

type Window

+ Session *SessionWindow

v1.2.0-rc5

Apr 24, 2024

v1.2.0-rc4

Apr 18, 2024

v1.2.0-rc3

Apr 9, 2024

v1.2.0-rc2

Apr 3, 2024

v1.2.0-rc1

Mar 26, 2024

v1.1.7

Mar 15, 2024

Changes in this version

type KafkaSource

+ IncludeHeaders bool

v1.1.6

Feb 27, 2024

Changes in this version

type GetDaemonDeploymentReq

+ DefaultResources corev1.ResourceRequirements

type GetJetStreamStatefulSetSpecReq

+ DefaultResources corev1.ResourceRequirements

type GetRedisStatefulSetSpecReq

+ DefaultResources corev1.ResourceRequirements

type GetSideInputDeploymentReq

+ DefaultResources corev1.ResourceRequirements

type GetVertexPodSpecReq

+ DefaultResources corev1.ResourceRequirements

type SASL

+ SCRAMSHA256 *SASLPlain

+ SCRAMSHA512 *SASLPlain

v1.1.5

Jan 23, 2024

v1.1.4

Jan 20, 2024

v1.1.3

Jan 15, 2024

v1.1.2

Jan 2, 2024

v1.1.1

Dec 21, 2023

v1.1.0

Dec 18, 2023

Changes in this version

+ const ComponentUXServer

+ type IdleSource struct

+ IncrementBy *metav1.Duration

+ StepInterval *metav1.Duration

+ Threshold *metav1.Duration

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

+ func (*IdleSource) ProtoMessage()

+ func (in *IdleSource) DeepCopy() *IdleSource

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

+ func (is IdleSource) GetIncrementBy() time.Duration

+ func (is IdleSource) GetStepInterval() time.Duration

+ func (is IdleSource) GetThreshold() time.Duration

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

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

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

+ func (m *IdleSource) Reset()

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

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

+ func (m *IdleSource) XXX_DiscardUnknown()

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

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

+ func (m *IdleSource) XXX_Size() int

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

+ func (this *IdleSource) String() string

type Watermark

+ IdleSource *IdleSource

v1.0.0

Nov 3, 2023

v1.0.0-rc4

Nov 3, 2023

v1.0.0-rc3

Nov 2, 2023

v1.0.0-rc2

Nov 1, 2023

v1.0.0-rc1

Oct 27, 2023

v0

v0.11.0

Oct 13, 2023

Changes in this version

+ const KeyPauseTimestamp

+ const RemovePauseTimestampPatch

type Lifecycle

+ PauseGracePeriodSeconds *int32

+ func (lc Lifecycle) GetPauseGracePeriodSeconds() int32

v0.11.0-rc2

Oct 4, 2023

v0.11.0-rc1

Oct 3, 2023

v0.10.1

Sep 15, 2023

v0.10.0

Sep 6, 2023

Changes in this version

+ const ComponentSideInputManager

+ const CtrInitSideInputs

+ const CtrSideInputsWatcher

+ const CtrUdSideInput

+ const CtrUdsource

+ const EnvGoDebug

+ const EnvSideInputObject

+ const KeySideInputName

+ const PathSideInputsMount

type AbstractVertex

+ SideInputs []string

+ SideInputsContainerTemplate *ContainerTemplate

+ func (av AbstractVertex) IsUDSource() bool

+ type GetSideInputDeploymentReq struct

+ Env []corev1.EnvVar

+ ISBSvcType ISBSvcType

+ Image string

+ PullPolicy corev1.PullPolicy

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

+ func (*GetSideInputDeploymentReq) ProtoMessage()

+ func (in *GetSideInputDeploymentReq) DeepCopy() *GetSideInputDeploymentReq

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

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

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

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

+ func (m *GetSideInputDeploymentReq) Reset()

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

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

+ func (m *GetSideInputDeploymentReq) XXX_DiscardUnknown()

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

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

+ func (m *GetSideInputDeploymentReq) XXX_Size() int

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

+ func (this *GetSideInputDeploymentReq) String() string

type GetVertexPodSpecReq

+ SideInputsStoreName string

type Pipeline

+ func (p Pipeline) GetSideInputsManagerDeploymentName(sideInputName string) string

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

+ func (p Pipeline) GetSideInputsStoreName() string

+ func (p Pipeline) HasSideInputs() bool

type PipelineSpec

+ SideInputs []SideInput

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

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

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

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

type Scale

+ DeprecatedCooldownSeconds *uint32

+ ScaleDownCooldownSeconds *uint32

+ ScaleUpCooldownSeconds *uint32

+ func (s Scale) GetScaleDownCooldownSeconds() int

+ func (s Scale) GetScaleUpCooldownSeconds() int

+ type SideInput struct

+ Container *Container

+ Name string

+ Trigger *SideInputTrigger

+ Volumes []corev1.Volume

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

+ func (*SideInput) ProtoMessage()

+ func (in *SideInput) DeepCopy() *SideInput

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

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

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

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

+ func (m *SideInput) Reset()

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

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

+ func (m *SideInput) XXX_DiscardUnknown()

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

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

+ func (m *SideInput) XXX_Size() int

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

+ func (this *SideInput) String() string

+ type SideInputTrigger struct

+ Schedule string

+ Timezone *string

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

+ func (*SideInputTrigger) ProtoMessage()

+ func (in *SideInputTrigger) DeepCopy() *SideInputTrigger

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

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

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

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

+ func (m *SideInputTrigger) Reset()

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

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

+ func (m *SideInputTrigger) XXX_DiscardUnknown()

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

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

+ func (m *SideInputTrigger) XXX_Size() int

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

+ func (this *SideInputTrigger) String() string

+ type SideInputsManagerTemplate struct

+ ContainerTemplate *ContainerTemplate

+ InitContainerTemplate *ContainerTemplate

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

+ func (*SideInputsManagerTemplate) ProtoMessage()

+ func (in *SideInputsManagerTemplate) DeepCopy() *SideInputsManagerTemplate

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

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

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

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

+ func (m *SideInputsManagerTemplate) Reset()

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

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

+ func (m *SideInputsManagerTemplate) XXX_DiscardUnknown()

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

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

+ func (m *SideInputsManagerTemplate) XXX_Size() int

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

+ func (this *SideInputsManagerTemplate) String() string

type Source

+ UDSource *UDSource

type Templates

+ SideInputsManagerTemplate *SideInputsManagerTemplate

+ VertexTemplate *VertexTemplate

+ type UDSource struct

+ Container *Container

+ func (*UDSource) Descriptor() ([]byte, []int)

+ func (*UDSource) ProtoMessage()

+ func (in *UDSource) DeepCopy() *UDSource

+ func (in *UDSource) DeepCopyInto(out *UDSource)

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

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

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

+ func (m *UDSource) Reset()

+ func (m *UDSource) Size() (n int)

+ func (m *UDSource) Unmarshal(dAtA []byte) error

+ func (m *UDSource) XXX_DiscardUnknown()

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

+ func (m *UDSource) XXX_Merge(src proto.Message)

+ func (m *UDSource) XXX_Size() int

+ func (m *UDSource) XXX_Unmarshal(b []byte) error

+ func (this *UDSource) String() string

type Vertex

+ func (v Vertex) HasSideInputs() bool

+ func (v Vertex) IsUDSource() bool

+ type VertexTemplate struct

+ ContainerTemplate *ContainerTemplate

+ InitContainerTemplate *ContainerTemplate

+ func (*VertexTemplate) Descriptor() ([]byte, []int)

+ func (*VertexTemplate) ProtoMessage()

+ func (in *VertexTemplate) DeepCopy() *VertexTemplate

+ func (in *VertexTemplate) DeepCopyInto(out *VertexTemplate)

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

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

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

+ func (m *VertexTemplate) Reset()

+ func (m *VertexTemplate) Size() (n int)

+ func (m *VertexTemplate) Unmarshal(dAtA []byte) error

+ func (m *VertexTemplate) XXX_DiscardUnknown()

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

+ func (m *VertexTemplate) XXX_Merge(src proto.Message)

+ func (m *VertexTemplate) XXX_Size() int

+ func (m *VertexTemplate) XXX_Unmarshal(b []byte) error

+ func (this *VertexTemplate) String() string

v0.9.3

Sep 5, 2023

v0.9.2

Aug 23, 2023

v0.9.1

Aug 11, 2023

v0.9.0

Aug 2, 2023

Changes in this version

type AbstractVertex

+ func (av AbstractVertex) GetPartitionCount() int

type CombinedEdge

+ FromVertexPartitionCount *int32

+ ToVertexPartitionCount *int32

+ func (ce CombinedEdge) GetToVertexPartitionCount() int

type Edge

+ func (e Edge) GetEdgeName() string

type Vertex

+ func (v Vertex) GetPartitionCount() int

v0.9.0-rc2

Jul 13, 2023

v0.9.0-rc1

Jul 11, 2023

v0.8.1

May 30, 2023

Changes in this version

+ const MapUdfStreamKey

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

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

+ func GenerateSinkBucketName(namespace, pipelineName, vertex string) string

+ func GenerateSourceBucketName(namespace, pipeline, vertex string) string

type AbstractVertex

+ Partitions *int32

+ func (av AbstractVertex) GetPartitions() int

+ func (av AbstractVertex) GetVertexType() VertexType

+ func (av AbstractVertex) HasUDTransformer() bool

+ func (av AbstractVertex) IsASink() bool

+ func (av AbstractVertex) IsASource() bool

+ func (av AbstractVertex) IsMapUDF() bool

+ func (av AbstractVertex) IsReduceUDF() bool

+ func (av AbstractVertex) IsUDSink() bool

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

+ type CombinedEdge struct

+ FromVertexLimits *VertexLimits

+ FromVertexPartitions *int32

+ FromVertexType VertexType

+ ToVertexLimits *VertexLimits

+ ToVertexPartitions *int32

+ ToVertexType VertexType

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

+ func (*CombinedEdge) ProtoMessage()

+ func (ce CombinedEdge) GetFromVertexPartitions() int

+ func (ce CombinedEdge) GetToVertexPartitions() int

+ func (in *CombinedEdge) DeepCopy() *CombinedEdge

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

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

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

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

+ func (m *CombinedEdge) Reset()

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

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

+ func (m *CombinedEdge) XXX_DiscardUnknown()

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

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

+ func (m *CombinedEdge) XXX_Size() int

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

+ func (this *CombinedEdge) String() string

+ type DeprecatedEdgeLimits struct

+ BufferMaxLength *uint64

+ BufferUsageLimit *uint32

+ func (*DeprecatedEdgeLimits) Descriptor() ([]byte, []int)

+ func (*DeprecatedEdgeLimits) ProtoMessage()

+ func (in *DeprecatedEdgeLimits) DeepCopy() *DeprecatedEdgeLimits

+ func (in *DeprecatedEdgeLimits) DeepCopyInto(out *DeprecatedEdgeLimits)

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

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

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

+ func (m *DeprecatedEdgeLimits) Reset()

+ func (m *DeprecatedEdgeLimits) Size() (n int)

+ func (m *DeprecatedEdgeLimits) Unmarshal(dAtA []byte) error

+ func (m *DeprecatedEdgeLimits) XXX_DiscardUnknown()

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

+ func (m *DeprecatedEdgeLimits) XXX_Merge(src proto.Message)

+ func (m *DeprecatedEdgeLimits) XXX_Size() int

+ func (m *DeprecatedEdgeLimits) XXX_Unmarshal(b []byte) error

+ func (this *DeprecatedEdgeLimits) String() string

type Edge

+ DeprecatedLimits *DeprecatedEdgeLimits

+ DeprecatedParallelism *int32

type JetStreamConfig

+ StreamConfig string

type Pipeline

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

+ func (p Pipeline) GetAllBuckets() []string

+ func (p Pipeline) NumOfPartitions(vertex string) int

type Vertex

+ func (v Vertex) GetFromBuckets() []string

+ func (v Vertex) GetPartitions() int

+ func (v Vertex) GetToBuckets() []string

+ func (v Vertex) GetVertexType() VertexType

+ func (v Vertex) MapUdfStreamEnabled() (bool, error)

+ func (v Vertex) OwnedBuffers() []string

v0.8.0

Apr 26, 2023

Changes in this version

+ const EnvCPULimit

+ const EnvCPURequest

+ const EnvMemoryLimit

+ const EnvMemoryRequest

+ var MessageTagAll = fmt.Sprintf("%U__ALL__", '\\')

+ var MessageTagDrop = fmt.Sprintf("%U__DROP__", '\\')

type ForwardConditions

+ Tags *TagConditions

type GSSAPI

+ UsernameSecret *corev1.SecretKeySelector

type GroupBy

+ AllowedLateness *metav1.Duration

type KafkaSink

+ SASL *SASL

+ type LogicOperator string

+ const LogicOperatorAnd

+ const LogicOperatorNot

+ const LogicOperatorOr

type SASLPlain

+ UserSecret *corev1.SecretKeySelector

+ type TagConditions struct

+ Operator *LogicOperator

+ Values []string

+ func (*TagConditions) Descriptor() ([]byte, []int)

+ func (*TagConditions) ProtoMessage()

+ func (in *TagConditions) DeepCopy() *TagConditions

+ func (in *TagConditions) DeepCopyInto(out *TagConditions)

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

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

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

+ func (m *TagConditions) Reset()

+ func (m *TagConditions) Size() (n int)

+ func (m *TagConditions) Unmarshal(dAtA []byte) error

+ func (m *TagConditions) XXX_DiscardUnknown()

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

+ func (m *TagConditions) XXX_Merge(src proto.Message)

+ func (m *TagConditions) XXX_Size() int

+ func (m *TagConditions) XXX_Unmarshal(b []byte) error

+ func (tc TagConditions) GetOperator() LogicOperator

+ func (this *TagConditions) String() string

v0.8.0-rc1

Apr 14, 2023

v0.7.3

Apr 3, 2023

Changes in this version

+ type BufferFullWritingStrategy string

+ const DiscardLatest

+ const RetryUntilSuccess

type ContainerTemplate

+ EnvFrom []corev1.EnvFromSource

type Edge

+ OnFull *BufferFullWritingStrategy

+ func (e Edge) BufferFullWritingStrategy() BufferFullWritingStrategy

+ type GSSAPI struct

+ AuthType *KRB5AuthType

+ KerberosConfigSecret *corev1.SecretKeySelector

+ KeytabSecret *corev1.SecretKeySelector

+ PasswordSecret *corev1.SecretKeySelector

+ Realm string

+ ServiceName string

+ Username string

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

+ func (*GSSAPI) ProtoMessage()

+ func (in *GSSAPI) DeepCopy() *GSSAPI

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

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

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

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

+ func (m *GSSAPI) Reset()

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

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

+ func (m *GSSAPI) XXX_DiscardUnknown()

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

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

+ func (m *GSSAPI) XXX_Size() int

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

+ func (this *GSSAPI) String() string

+ type KRB5AuthType string

+ const KRB5KeytabAuth

+ const KRB5UserAuth

type KafkaSource

+ SASL *SASL

+ type RedisStreamsSource struct

+ ConsumerGroup string

+ ReadFromBeginning bool

+ Stream string

+ TLS *TLS

+ func (*RedisStreamsSource) Descriptor() ([]byte, []int)

+ func (*RedisStreamsSource) ProtoMessage()

+ func (in *RedisStreamsSource) DeepCopy() *RedisStreamsSource

+ func (in *RedisStreamsSource) DeepCopyInto(out *RedisStreamsSource)

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

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

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

+ func (m *RedisStreamsSource) Reset()

+ func (m *RedisStreamsSource) Size() (n int)

+ func (m *RedisStreamsSource) Unmarshal(dAtA []byte) error

+ func (m *RedisStreamsSource) XXX_DiscardUnknown()

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

+ func (m *RedisStreamsSource) XXX_Merge(src proto.Message)

+ func (m *RedisStreamsSource) XXX_Size() int

+ func (m *RedisStreamsSource) XXX_Unmarshal(b []byte) error

+ func (this *RedisStreamsSource) String() string

+ type SASL struct

+ GSSAPI *GSSAPI

+ Mechanism *SASLType

+ Plain *SASLPlain

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

+ func (*SASL) ProtoMessage()

+ func (in *SASL) DeepCopy() *SASL

+ func (in *SASL) DeepCopyInto(out *SASL)

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

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

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

+ func (m *SASL) Reset()

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

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

+ func (m *SASL) XXX_DiscardUnknown()

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

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

+ func (m *SASL) XXX_Size() int

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

+ func (this *SASL) String() string

+ type SASLPlain struct

+ Handshake bool

+ PasswordSecret *corev1.SecretKeySelector

+ User string

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

+ func (*SASLPlain) ProtoMessage()

+ func (in *SASLPlain) DeepCopy() *SASLPlain

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

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

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

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

+ func (m *SASLPlain) Reset()

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

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

+ func (m *SASLPlain) XXX_DiscardUnknown()

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

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

+ func (m *SASLPlain) XXX_Size() int

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

+ func (this *SASLPlain) String() string

+ type SASLType string

+ const SASLTypeGSSAPI

+ const SASLTypeOAuth

+ const SASLTypePlaintext

+ const SASLTypeSCRAMSHA256

+ const SASLTypeSCRAMSHA512

type Source

+ RedisStreams *RedisStreamsSource

v0.7.2

Mar 13, 2023

Changes in this version

+ const DefaultTargetBufferAvailability

+ const EnvLeaderElectionDisabled

type AbstractPodTemplate

+ DNSConfig *corev1.PodDNSConfig

+ DNSPolicy corev1.DNSPolicy

type Container

+ EnvFrom []corev1.EnvFromSource

+ ImagePullPolicy *corev1.PullPolicy

type GeneratorSource

+ KeyCount *int32

+ Value *uint64

type Scale

+ DeprecatedTargetBufferUsage *uint32

+ TargetBufferAvailability *uint32

+ func (s Scale) GetTargetBufferAvailability() int

v0.7.1

Feb 14, 2023

Changes in this version

+ const CtrUdtransformer

+ const DefaultGRPCMaxMessageSize

+ const EnvGRPCMaxMessageSize

+ const EnvHealthCheckDisabled

+ const EnvPPROF

type AbstractPodTemplate

+ AutomountServiceAccountToken *bool

+ RuntimeClassName *string

type Container

+ SecurityContext *corev1.SecurityContext

type Source

+ UDTransformer *UDTransformer

+ type Transformer struct

+ Args []string

+ KWArgs map[string]string

+ Name string

+ func (*Transformer) Descriptor() ([]byte, []int)

+ func (*Transformer) ProtoMessage()

+ func (in *Transformer) DeepCopy() *Transformer

+ func (in *Transformer) DeepCopyInto(out *Transformer)

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

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

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

+ func (m *Transformer) Reset()

+ func (m *Transformer) Size() (n int)

+ func (m *Transformer) Unmarshal(dAtA []byte) error

+ func (m *Transformer) XXX_DiscardUnknown()

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

+ func (m *Transformer) XXX_Merge(src proto.Message)

+ func (m *Transformer) XXX_Size() int

+ func (m *Transformer) XXX_Unmarshal(b []byte) error

+ func (this *Transformer) String() string

+ type UDTransformer struct

+ Builtin *Transformer

+ Container *Container

+ func (*UDTransformer) Descriptor() ([]byte, []int)

+ func (*UDTransformer) ProtoMessage()

+ func (in *UDTransformer) DeepCopy() *UDTransformer

+ func (in *UDTransformer) DeepCopyInto(out *UDTransformer)

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

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

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

+ func (m *UDTransformer) Reset()

+ func (m *UDTransformer) Size() (n int)

+ func (m *UDTransformer) Unmarshal(dAtA []byte) error

+ func (m *UDTransformer) XXX_DiscardUnknown()

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

+ func (m *UDTransformer) XXX_Merge(src proto.Message)

+ func (m *UDTransformer) XXX_Size() int

+ func (m *UDTransformer) XXX_Unmarshal(b []byte) error

+ func (this *UDTransformer) String() string

type Vertex

+ func (v Vertex) HasUDTransformer() bool

v0.7.0

Jan 13, 2023

Changes in this version

+ var DefaultAccessMode = corev1.ReadWriteOnce

+ var DefaultVolumeSize = apiresource.MustParse("20Gi")

+ type BasicAuth struct

+ Password *corev1.SecretKeySelector

+ User *corev1.SecretKeySelector

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

+ func (*BasicAuth) ProtoMessage()

+ func (in *BasicAuth) DeepCopy() *BasicAuth

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

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

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

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

+ func (m *BasicAuth) Reset()

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

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

+ func (m *BasicAuth) XXX_DiscardUnknown()

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

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

+ func (m *BasicAuth) XXX_Size() int

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

+ func (this *BasicAuth) String() string

+ type NatsAuth struct

+ Basic *BasicAuth

+ NKey *corev1.SecretKeySelector

+ Token *corev1.SecretKeySelector

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

+ func (*NatsAuth) ProtoMessage()

+ func (in *NatsAuth) DeepCopy() *NatsAuth

+ func (in *NatsAuth) DeepCopyInto(out *NatsAuth)

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

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

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

+ func (m *NatsAuth) Reset()

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

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

+ func (m *NatsAuth) XXX_DiscardUnknown()

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

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

+ func (m *NatsAuth) XXX_Size() int

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

+ func (this *NatsAuth) String() string

+ type NatsSource struct

+ Auth *NatsAuth

+ Queue string

+ Subject string

+ TLS *TLS

+ URL string

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

+ func (*NatsSource) ProtoMessage()

+ func (in *NatsSource) DeepCopy() *NatsSource

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

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

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

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

+ func (m *NatsSource) Reset()

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

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

+ func (m *NatsSource) XXX_DiscardUnknown()

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

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

+ func (m *NatsSource) XXX_Size() int

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

+ func (this *NatsSource) String() string

type PBQStorage

+ EmptyDir *corev1.EmptyDirVolumeSource

+ type SlidingWindow struct

+ Length *metav1.Duration

+ Slide *metav1.Duration

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

+ func (*SlidingWindow) ProtoMessage()

+ func (in *SlidingWindow) DeepCopy() *SlidingWindow

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

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

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

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

+ func (m *SlidingWindow) Reset()

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

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

+ func (m *SlidingWindow) XXX_DiscardUnknown()

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

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

+ func (m *SlidingWindow) XXX_Size() int

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

+ func (this *SlidingWindow) String() string

type Source

+ Nats *NatsSource

type Window

+ Sliding *SlidingWindow

v0.7.0-rc1

Dec 16, 2022

v0.6.5

Dec 7, 2022

Changes in this version

+ const DefaultKeyForNonKeyedData

+ const KeyDefaultContainer

type Vertex

+ func (v Vertex) IsUDSink() bool

v0.6.4

Nov 29, 2022

Changes in this version

+ const DefaultStorePath

v0.6.3

Nov 18, 2022

Changes in this version

type AbstractVertex

+ Sidecars []corev1.Container

+ type Blackhole struct

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

+ func (*Blackhole) ProtoMessage()

+ func (in *Blackhole) DeepCopy() *Blackhole

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

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

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

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

+ func (m *Blackhole) Reset()

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

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

+ func (m *Blackhole) XXX_DiscardUnknown()

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

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

+ func (m *Blackhole) XXX_Size() int

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

+ func (this *Blackhole) String() string

type Sink

+ Blackhole *Blackhole

v0.6.2

Nov 7, 2022

Changes in this version

+ const ComponentJob

+ const PathPBQMount

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

+ type AbstractPodTemplate struct

+ Affinity *corev1.Affinity

+ ImagePullSecrets []corev1.LocalObjectReference

+ Metadata *Metadata

+ NodeSelector map[string]string

+ Priority *int32

+ PriorityClassName string

+ SecurityContext *corev1.PodSecurityContext

+ ServiceAccountName string

+ Tolerations []corev1.Toleration

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

+ func (*AbstractPodTemplate) ProtoMessage()

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

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

+ func (in *AbstractPodTemplate) DeepCopy() *AbstractPodTemplate

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

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

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

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

+ func (m *AbstractPodTemplate) Reset()

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

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

+ func (m *AbstractPodTemplate) XXX_DiscardUnknown()

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

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

+ func (m *AbstractPodTemplate) XXX_Size() int

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

+ func (this *AbstractPodTemplate) String() string

type AbstractVertex

+ InitContainerTemplate *ContainerTemplate

+ InitContainers []corev1.Container

type ContainerTemplate

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

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

+ type DaemonTemplate struct

+ ContainerTemplate *ContainerTemplate

+ InitContainerTemplate *ContainerTemplate

+ Replicas *int32

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

+ func (*DaemonTemplate) ProtoMessage()

+ func (in *DaemonTemplate) DeepCopy() *DaemonTemplate

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

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

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

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

+ func (m *DaemonTemplate) Reset()

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

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

+ func (m *DaemonTemplate) XXX_DiscardUnknown()

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

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

+ func (m *DaemonTemplate) XXX_Size() int

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

+ func (this *DaemonTemplate) String() string

type GroupBy

+ Storage *PBQStorage

+ type JobTemplate struct

+ BackoffLimit *int32

+ ContainerTemplate *ContainerTemplate

+ TTLSecondsAfterFinished *int32

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

+ func (*JobTemplate) ProtoMessage()

+ func (in *JobTemplate) DeepCopy() *JobTemplate

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

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

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

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

+ func (m *JobTemplate) Reset()

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

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

+ func (m *JobTemplate) XXX_DiscardUnknown()

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

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

+ func (m *JobTemplate) XXX_Size() int

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

+ func (this *JobTemplate) String() string

type NativeRedis

+ InitContainerTemplate *ContainerTemplate

+ type PBQStorage struct

+ PersistentVolumeClaim *PersistenceStrategy

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

+ func (*PBQStorage) ProtoMessage()

+ func (in *PBQStorage) DeepCopy() *PBQStorage

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

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

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

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

+ func (m *PBQStorage) Reset()

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

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

+ func (m *PBQStorage) XXX_DiscardUnknown()

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

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

+ func (m *PBQStorage) XXX_Size() int

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

+ func (this *PBQStorage) String() string

type PersistenceStrategy

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

type PipelineSpec

+ Templates *Templates

type PipelineStatus

+ SinkCount *uint32

+ SourceCount *uint32

+ UDFCount *uint32

+ VertexCount *uint32

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

+ type RedisBufferService struct

+ External *RedisConfig

+ Native *NativeRedis

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

+ func (*RedisBufferService) ProtoMessage()

+ func (in *RedisBufferService) DeepCopy() *RedisBufferService

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

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

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

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

+ func (m *RedisBufferService) Reset()

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

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

+ func (m *RedisBufferService) XXX_DiscardUnknown()

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

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

+ func (m *RedisBufferService) XXX_Size() int

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

+ func (this *RedisBufferService) String() string

+ type Templates struct

+ DaemonTemplate *DaemonTemplate

+ JobTemplate *JobTemplate

+ func (*Templates) Descriptor() ([]byte, []int)

+ func (*Templates) ProtoMessage()

+ func (in *Templates) DeepCopy() *Templates

+ func (in *Templates) DeepCopyInto(out *Templates)

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

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

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

+ func (m *Templates) Reset()

+ func (m *Templates) Size() (n int)

+ func (m *Templates) Unmarshal(dAtA []byte) error

+ func (m *Templates) XXX_DiscardUnknown()

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

+ func (m *Templates) XXX_Merge(src proto.Message)

+ func (m *Templates) XXX_Size() int

+ func (m *Templates) XXX_Unmarshal(b []byte) error

+ func (this *Templates) String() string

type Vertex

+ func (v Vertex) GetReplicas() int

type VertexSpec

+ Watermark Watermark

v0.6.1

Oct 27, 2022

Changes in this version

+ const DefaultReadBatchSize

+ const DefaultWindowDuration

+ const DefaultWindowType

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

type Edge

+ Parallelism *int32

+ type FixedWindow struct

+ Length *metav1.Duration

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

+ func (*FixedWindow) ProtoMessage()

+ func (in *FixedWindow) DeepCopy() *FixedWindow

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

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

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

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

+ func (m *FixedWindow) Reset()

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

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

+ func (m *FixedWindow) XXX_DiscardUnknown()

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

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

+ func (m *FixedWindow) XXX_Size() int

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

+ func (this *FixedWindow) String() string

+ type GroupBy struct

+ Keyed bool

+ Window Window

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

+ func (*GroupBy) ProtoMessage()

+ func (in *GroupBy) DeepCopy() *GroupBy

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

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

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

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

+ func (m *GroupBy) Reset()

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

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

+ func (m *GroupBy) XXX_DiscardUnknown()

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

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

+ func (m *GroupBy) XXX_Size() int

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

+ func (this *GroupBy) String() string

type InterStepBufferServiceStatus

+ Type ISBSvcType

+ func (isbsvc *InterStepBufferServiceStatus) SetType(typ ISBSvcType)

type Lifecycle

+ func (lc Lifecycle) GetDeleteGracePeriodSeconds() int32

+ func (lc Lifecycle) GetDesiredPhase() PipelinePhase

type Pipeline

+ func (p Pipeline) GetPipelineLimits() PipelineLimits

+ func (p Pipeline) ListAllEdges() []Edge

type UDF

+ GroupBy *GroupBy

type Vertex

+ func (v Vertex) IsMapUDF() bool

+ func (v Vertex) IsReduceUDF() bool

+ type VertexType string

+ const VertexTypeMapUDF

+ const VertexTypeReduceUDF

+ const VertexTypeSink

+ const VertexTypeSource

type Watermark

+ func (wm Watermark) GetMaxDelay() time.Duration

+ type Window struct

+ Fixed *FixedWindow

+ func (*Window) Descriptor() ([]byte, []int)

+ func (*Window) ProtoMessage()

+ func (in *Window) DeepCopy() *Window

+ func (in *Window) DeepCopyInto(out *Window)

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

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

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

+ func (m *Window) Reset()

+ func (m *Window) Size() (n int)

+ func (m *Window) Unmarshal(dAtA []byte) error

+ func (m *Window) XXX_DiscardUnknown()

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

+ func (m *Window) XXX_Merge(src proto.Message)

+ func (m *Window) XXX_Size() int

+ func (m *Window) XXX_Unmarshal(b []byte) error

+ func (this *Window) String() string

+ type WindowType string

+ const FixedType

+ const SessionType

+ const SlidingType

+ func (wt WindowType) String() string

v0.6.0

Oct 13, 2022

Changes in this version

+ const EnvISBSvcRedisClusterMaxRedirects

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

v0.5.6

Sep 20, 2022

Changes in this version

+ const DefaultPBQChannelBufferSize

+ const DefaultPBQReadBatchSize

+ const DefaultPBQReadTimeout

+ const DefaultStoreMaxBufferSize

+ const DefaultStoreSize

+ const DefaultStoreSyncDuration

+ const DefaultStoreType

+ const EnvWatermarkDisabled

+ const EnvWatermarkMaxDelay

+ const KeyMetaEventTime

+ type StoreType string

+ const FileSystemType

+ const InMemoryType

+ const NoOpType

+ func (st StoreType) String() string

type Watermark

+ Disabled bool

+ MaxDelay *metav1.Duration

v0.5.5

Sep 8, 2022

v0.5.4

Aug 6, 2022

Changes in this version

+ const DefaultCooldownSeconds

+ const DefaultLookbackSeconds

+ const DefaultMaxReplicas

+ const DefaultReplicasPerScale

+ const DefaultTargetBufferUsage

+ const DefaultTargetProcessingSeconds

+ const DefaultZeroReplicaSleepSeconds

type Pipeline

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

type PipelineLimits

+ ReadTimeout *metav1.Duration

type Scale

+ CooldownSeconds *uint32

+ Disabled bool

+ ReplicasPerScale *uint32

+ TargetBufferUsage *uint32

+ TargetProcessingSeconds *uint32

+ ZeroReplicaSleepSeconds *uint32

+ func (s Scale) GetCooldownSeconds() int

+ func (s Scale) GetLookbackSeconds() int

+ func (s Scale) GetMaxReplicas() int32

+ func (s Scale) GetMinReplicas() int32

+ func (s Scale) GetReplicasPerScale() int

+ func (s Scale) GetTargetBufferUsage() int

+ func (s Scale) GetTargetProcessingSeconds() int

+ func (s Scale) GetZeroReplicaSleepSeconds() int

type Vertex

+ func (v Vertex) IsUDF() bool

+ func (v Vertex) Scalable() bool

type VertexLimits

+ ReadTimeout *metav1.Duration

v0.5.3

Jul 8, 2022

Changes in this version

+ const VertexHTTPSPortName

+ const VertexMetricsPortName

type Edge

+ Limits *EdgeLimits

+ type EdgeLimits struct

+ BufferMaxLength *uint64

+ BufferUsageLimit *uint32

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

+ func (*EdgeLimits) ProtoMessage()

+ func (in *EdgeLimits) DeepCopy() *EdgeLimits

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

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

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

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

+ func (m *EdgeLimits) Reset()

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

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

+ func (m *EdgeLimits) XXX_DiscardUnknown()

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

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

+ func (m *EdgeLimits) XXX_Size() int

+ func (m *EdgeLimits) XXX_Unmarshal(b []byte) error

+ func (this *EdgeLimits) String() string

type Pipeline

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

type Scale

+ LookbackSeconds *int32

+ type VertexInstance struct

+ Hostname string

+ Replica int32

+ Vertex *Vertex

+ func (*VertexInstance) Descriptor() ([]byte, []int)

+ func (*VertexInstance) ProtoMessage()

+ func (in *VertexInstance) DeepCopy() *VertexInstance

+ func (in *VertexInstance) DeepCopyInto(out *VertexInstance)

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

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

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

+ func (m *VertexInstance) Reset()

+ func (m *VertexInstance) Size() (n int)

+ func (m *VertexInstance) Unmarshal(dAtA []byte) error

+ func (m *VertexInstance) XXX_DiscardUnknown()

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

+ func (m *VertexInstance) XXX_Merge(src proto.Message)

+ func (m *VertexInstance) XXX_Size() int

+ func (m *VertexInstance) XXX_Unmarshal(b []byte) error

+ func (this *VertexInstance) String() string

type VertexSpec

+ FromEdges []Edge

+ ToEdges []Edge

v0.5.2

Jun 13, 2022

Changes in this version

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

+ func GenerateSinkBufferName(namespace, pipelineName, vertex string) string

+ func GenerateSourceBufferName(namespace, pipelineName, vertex string) string

+ type Buffer struct

+ Name string

+ Type BufferType

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

+ func (*Buffer) ProtoMessage()

+ func (in *Buffer) DeepCopy() *Buffer

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

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

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

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

+ func (m *Buffer) Reset()

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

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

+ func (m *Buffer) XXX_DiscardUnknown()

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

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

+ func (m *Buffer) XXX_Size() int

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

+ func (this *Buffer) String() string

+ type BufferType string

+ const EdgeBuffer

+ const SinkBuffer

+ const SourceBuffer

type Pipeline

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

v0.5.1

Jun 2, 2022

v0.5.0

Jun 1, 2022

Changes in this version

+ const ComponentDaemon

+ const ComponentISBSvc

+ const ComponentVertex

+ const ControllerISBSvc

+ const ControllerPipeline

+ const ControllerVertex

+ const ControllerWatchdog

+ const CtrInit

+ const CtrMain

+ const CtrUdf

+ const CtrUdsink

+ const DaemonServicePort

+ const DefaultBufferLength

+ const DefaultBufferUsageLimit

+ const DefaultISBSvcName

+ const DefaultRedisSentinelMasterName

+ const DefaultRequeueAfter

+ const EnvDebug

+ const EnvISBSvcConfig

+ const EnvISBSvcJetStreamPassword

+ const EnvISBSvcJetStreamTLSEnabled

+ const EnvISBSvcJetStreamURL

+ const EnvISBSvcJetStreamUser

+ const EnvISBSvcRedisPassword

+ const EnvISBSvcRedisSentinelPassword

+ const EnvISBSvcRedisSentinelURL

+ const EnvISBSvcRedisURL

+ const EnvISBSvcRedisUser

+ const EnvISBSvcSentinelMaster

+ const EnvImage

+ const EnvImagePullPolicy

+ const EnvNamespace

+ const EnvPipelineName

+ const EnvPipelineObject

+ const EnvPod

+ const EnvReplica

+ const EnvUDFContentType

+ const EnvUDSinkContentType

+ const EnvVertexName

+ const EnvVertexObject

+ const EnvWatermarkOn

+ const ISBSvcConditionConfigured

+ const ISBSvcConditionDeployed

+ const ISBSvcPhaseFailed

+ const ISBSvcPhasePending

+ const ISBSvcPhaseRunning

+ const ISBSvcPhaseUnknown

+ const JetStreamClientAuthSecretPasswordKey

+ const JetStreamClientAuthSecretUserKey

+ const JetStreamClusterCACertKey

+ const JetStreamClusterCertKey

+ const JetStreamClusterPrivateKeyKey

+ const JetStreamConfigMapKey

+ const JetStreamServerCACertKey

+ const JetStreamServerCertKey

+ const JetStreamServerPrivateKeyKey

+ const JetStreamServerSecretAuthKey

+ const JetStreamServerSecretEncryptionKey

+ const KeyAppName

+ const KeyComponent

+ const KeyHash

+ const KeyISBSvcName

+ const KeyISBSvcType

+ const KeyManagedBy

+ const KeyMetaID

+ const KeyPartOf

+ const KeyPipelineName

+ const KeyReplica

+ const KeyVertexName

+ const PathVarRun

+ const PipelineConditionConfigured

+ const PipelineConditionDeployed

+ const PipelinePhaseDeleting

+ const PipelinePhaseFailed

+ const PipelinePhasePaused

+ const PipelinePhasePausing

+ const PipelinePhaseRunning

+ const PipelinePhaseSucceeded

+ const PipelinePhaseUnknown

+ const Project

+ const RedisAuthSecretKey

+ const UDFApplierMessageKey

+ const VertexHTTPSPort

+ const VertexMetricsPort

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")

+ var ISBGroupVersionKind = SchemeGroupVersion.WithKind("InterStepBufferService")

+ var ISBGroupVersionResource = SchemeGroupVersion.WithResource("interstepbufferservices")

+ var MessageKeyAll = fmt.Sprintf("%U__ALL__", '\\')

+ var MessageKeyDrop = fmt.Sprintf("%U__DROP__", '\\')

+ var PipelineGroupVersionKind = SchemeGroupVersion.WithKind("Pipeline")

+ var PipelineGroupVersionResource = SchemeGroupVersion.WithResource("pipelines")

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ var SchemeGroupVersion = schema.GroupVersion

+ var VertexGroupVersionKind = SchemeGroupVersion.WithKind("Vertex")

+ var VertexGroupVersionResource = SchemeGroupVersion.WithResource("vertices")

+ func GenerateBufferName(namespace, pipelineName, fromVetex, toVertex string) string

+ func Resource(resource string) schema.GroupResource

+ type AbstractVertex struct

+ Affinity *corev1.Affinity

+ ContainerTemplate *ContainerTemplate

+ ImagePullSecrets []corev1.LocalObjectReference

+ Limits *VertexLimits

+ Metadata *Metadata

+ Name string

+ NodeSelector map[string]string

+ Priority *int32

+ PriorityClassName string

+ Scale Scale

+ SecurityContext *corev1.PodSecurityContext

+ ServiceAccountName string

+ Sink *Sink

+ Source *Source

+ Tolerations []corev1.Toleration

+ UDF *UDF

+ Volumes []corev1.Volume

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

+ func (*AbstractVertex) ProtoMessage()

+ func (in *AbstractVertex) DeepCopy() *AbstractVertex

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

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

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

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

+ func (m *AbstractVertex) Reset()

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

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

+ func (m *AbstractVertex) XXX_DiscardUnknown()

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

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

+ func (m *AbstractVertex) XXX_Size() int

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

+ func (this *AbstractVertex) String() string

+ type Authorization struct

+ Token *corev1.SecretKeySelector

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

+ func (*Authorization) ProtoMessage()

+ func (in *Authorization) DeepCopy() *Authorization

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

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

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

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

+ func (m *Authorization) Reset()

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

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

+ func (m *Authorization) XXX_DiscardUnknown()

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

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

+ func (m *Authorization) XXX_Size() int

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

+ func (this *Authorization) String() string

+ type BufferServiceConfig struct

+ JetStream *JetStreamConfig

+ Redis *RedisConfig

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

+ func (*BufferServiceConfig) ProtoMessage()

+ func (in *BufferServiceConfig) DeepCopy() *BufferServiceConfig

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

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

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

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

+ func (m *BufferServiceConfig) Reset()

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

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

+ func (m *BufferServiceConfig) XXX_DiscardUnknown()

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

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

+ func (m *BufferServiceConfig) XXX_Size() int

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

+ func (this *BufferServiceConfig) String() string

+ type ConditionType string

+ const ConditionReady

+ type Container struct

+ Args []string

+ Command []string

+ Env []corev1.EnvVar

+ Image string

+ Resources corev1.ResourceRequirements

+ VolumeMounts []corev1.VolumeMount

+ func (*Container) Descriptor() ([]byte, []int)

+ func (*Container) ProtoMessage()

+ func (in *Container) DeepCopy() *Container

+ func (in *Container) DeepCopyInto(out *Container)

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

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

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

+ func (m *Container) Reset()

+ func (m *Container) Size() (n int)

+ func (m *Container) Unmarshal(dAtA []byte) error

+ func (m *Container) XXX_DiscardUnknown()

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

+ func (m *Container) XXX_Merge(src proto.Message)

+ func (m *Container) XXX_Size() int

+ func (m *Container) XXX_Unmarshal(b []byte) error

+ func (this *Container) String() string

+ type ContainerTemplate struct

+ Env []corev1.EnvVar

+ ImagePullPolicy corev1.PullPolicy

+ Resources corev1.ResourceRequirements

+ SecurityContext *corev1.SecurityContext

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

+ func (*ContainerTemplate) ProtoMessage()

+ func (in *ContainerTemplate) DeepCopy() *ContainerTemplate

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

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

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

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

+ func (m *ContainerTemplate) Reset()

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

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

+ func (m *ContainerTemplate) XXX_DiscardUnknown()

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

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

+ func (m *ContainerTemplate) XXX_Size() int

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

+ func (this *ContainerTemplate) String() string

+ type ContentType string

+ const JsonType

+ const MsgPackType

+ type Edge struct

+ Conditions *ForwardConditions

+ From string

+ To string

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

+ func (*Edge) ProtoMessage()

+ func (in *Edge) DeepCopy() *Edge

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

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

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

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

+ func (m *Edge) Reset()

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

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

+ func (m *Edge) XXX_DiscardUnknown()

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

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

+ func (m *Edge) XXX_Size() int

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

+ func (this *Edge) String() string

+ type ForwardConditions struct

+ KeyIn []string

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

+ func (*ForwardConditions) ProtoMessage()

+ func (in *ForwardConditions) DeepCopy() *ForwardConditions

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

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

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

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

+ func (m *ForwardConditions) Reset()

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

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

+ func (m *ForwardConditions) XXX_DiscardUnknown()

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

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

+ func (m *ForwardConditions) XXX_Size() int

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

+ func (this *ForwardConditions) String() string

+ type Function struct

+ Args []string

+ KWArgs map[string]string

+ Name string

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

+ func (*Function) ProtoMessage()

+ func (in *Function) DeepCopy() *Function

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

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

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

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

+ func (m *Function) Reset()

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

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

+ func (m *Function) XXX_DiscardUnknown()

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

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

+ func (m *Function) XXX_Size() int

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

+ func (this *Function) String() string

+ type GeneratorSource struct

+ Duration *metav1.Duration

+ MsgSize *int32

+ RPU *int64

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

+ func (*GeneratorSource) ProtoMessage()

+ func (in *GeneratorSource) DeepCopy() *GeneratorSource

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

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

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

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

+ func (m *GeneratorSource) Reset()

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

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

+ func (m *GeneratorSource) XXX_DiscardUnknown()

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

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

+ func (m *GeneratorSource) XXX_Size() int

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

+ func (this *GeneratorSource) String() string

+ type GetDaemonDeploymentReq struct

+ Env []corev1.EnvVar

+ ISBSvcType ISBSvcType

+ Image string

+ PullPolicy corev1.PullPolicy

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

+ func (*GetDaemonDeploymentReq) ProtoMessage()

+ func (in *GetDaemonDeploymentReq) DeepCopy() *GetDaemonDeploymentReq

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

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

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

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

+ func (m *GetDaemonDeploymentReq) Reset()

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

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

+ func (m *GetDaemonDeploymentReq) XXX_DiscardUnknown()

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

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

+ func (m *GetDaemonDeploymentReq) XXX_Size() int

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

+ func (this *GetDaemonDeploymentReq) String() string

+ type GetJetStreamServiceSpecReq struct

+ ClientPort int32

+ ClusterPort int32

+ Labels map[string]string

+ MetricsPort int32

+ MonitorPort int32

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

+ func (*GetJetStreamServiceSpecReq) ProtoMessage()

+ func (in *GetJetStreamServiceSpecReq) DeepCopy() *GetJetStreamServiceSpecReq

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

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

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

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

+ func (m *GetJetStreamServiceSpecReq) Reset()

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

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

+ func (m *GetJetStreamServiceSpecReq) XXX_DiscardUnknown()

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

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

+ func (m *GetJetStreamServiceSpecReq) XXX_Size() int

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

+ func (this *GetJetStreamServiceSpecReq) String() string

+ type GetJetStreamStatefulSetSpecReq struct

+ ClientPort int32

+ ClusterPort int32

+ ConfigMapName string

+ ConfigReloaderImage string

+ Labels map[string]string

+ MetricsExporterImage string

+ MetricsPort int32

+ MonitorPort int32

+ NatsImage string

+ PvcNameIfNeeded string

+ ServerAuthSecretName string

+ ServerEncryptionSecretName string

+ ServiceName string

+ StartCommand string

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

+ func (*GetJetStreamStatefulSetSpecReq) ProtoMessage()

+ func (in *GetJetStreamStatefulSetSpecReq) DeepCopy() *GetJetStreamStatefulSetSpecReq

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

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

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

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

+ func (m *GetJetStreamStatefulSetSpecReq) Reset()

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

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

+ func (m *GetJetStreamStatefulSetSpecReq) XXX_DiscardUnknown()

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

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

+ func (m *GetJetStreamStatefulSetSpecReq) XXX_Size() int

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

+ func (this *GetJetStreamStatefulSetSpecReq) String() string

+ type GetRedisServiceSpecReq struct

+ Labels map[string]string

+ RedisContainerPort int32

+ SentinelContainerPort int32

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

+ func (*GetRedisServiceSpecReq) ProtoMessage()

+ func (in *GetRedisServiceSpecReq) DeepCopy() *GetRedisServiceSpecReq

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

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

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

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

+ func (m *GetRedisServiceSpecReq) Reset()

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

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

+ func (m *GetRedisServiceSpecReq) XXX_DiscardUnknown()

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

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

+ func (m *GetRedisServiceSpecReq) XXX_Size() int

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

+ func (this *GetRedisServiceSpecReq) String() string

+ type GetRedisStatefulSetSpecReq struct

+ ConfConfigMapName string

+ CredentialSecretName string

+ HealthConfigMapName string

+ InitContainerImage string

+ Labels map[string]string

+ MetricsExporterImage string

+ PvcNameIfNeeded string

+ RedisContainerPort int32

+ RedisImage string

+ RedisMetricsContainerPort int32

+ ScriptsConfigMapName string

+ SentinelContainerPort int32

+ SentinelImage string

+ ServiceName string

+ TLSEnabled bool

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

+ func (*GetRedisStatefulSetSpecReq) ProtoMessage()

+ func (in *GetRedisStatefulSetSpecReq) DeepCopy() *GetRedisStatefulSetSpecReq

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

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

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

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

+ func (m *GetRedisStatefulSetSpecReq) Reset()

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

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

+ func (m *GetRedisStatefulSetSpecReq) XXX_DiscardUnknown()

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

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

+ func (m *GetRedisStatefulSetSpecReq) XXX_Size() int

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

+ func (this *GetRedisStatefulSetSpecReq) String() string

+ type GetVertexPodSpecReq struct

+ Env []corev1.EnvVar

+ ISBSvcType ISBSvcType

+ Image string

+ PullPolicy corev1.PullPolicy

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

+ func (*GetVertexPodSpecReq) ProtoMessage()

+ func (in *GetVertexPodSpecReq) DeepCopy() *GetVertexPodSpecReq

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

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

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

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

+ func (m *GetVertexPodSpecReq) Reset()

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

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

+ func (m *GetVertexPodSpecReq) XXX_DiscardUnknown()

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

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

+ func (m *GetVertexPodSpecReq) XXX_Size() int

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

+ func (this *GetVertexPodSpecReq) String() string

+ type HTTPSource struct

+ Auth *Authorization

+ Service bool

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

+ func (*HTTPSource) ProtoMessage()

+ func (in *HTTPSource) DeepCopy() *HTTPSource

+ func (in *HTTPSource) DeepCopyInto(out *HTTPSource)

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

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

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

+ func (m *HTTPSource) Reset()

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

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

+ func (m *HTTPSource) XXX_DiscardUnknown()

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

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

+ func (m *HTTPSource) XXX_Size() int

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

+ func (this *HTTPSource) String() string

+ type ISBSvcPhase string

+ type ISBSvcType string

+ const ISBSvcTypeJetStream

+ const ISBSvcTypeRedis

+ const ISBSvcTypeUnknown

+ type InterStepBufferService struct

+ Spec InterStepBufferServiceSpec

+ Status InterStepBufferServiceStatus

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

+ func (*InterStepBufferService) ProtoMessage()

+ func (in *InterStepBufferService) DeepCopy() *InterStepBufferService

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

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

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

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

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

+ func (m *InterStepBufferService) Reset()

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

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

+ func (m *InterStepBufferService) XXX_DiscardUnknown()

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

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

+ func (m *InterStepBufferService) XXX_Size() int

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

+ func (this *InterStepBufferService) String() string

+ type InterStepBufferServiceList struct

+ Items []InterStepBufferService

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

+ func (*InterStepBufferServiceList) ProtoMessage()

+ func (in *InterStepBufferServiceList) DeepCopy() *InterStepBufferServiceList

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

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

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

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

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

+ func (m *InterStepBufferServiceList) Reset()

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

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

+ func (m *InterStepBufferServiceList) XXX_DiscardUnknown()

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

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

+ func (m *InterStepBufferServiceList) XXX_Size() int

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

+ func (this *InterStepBufferServiceList) String() string

+ type InterStepBufferServiceSpec struct

+ JetStream *JetStreamBufferService

+ Redis *RedisBuferService

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

+ func (*InterStepBufferServiceSpec) ProtoMessage()

+ func (in *InterStepBufferServiceSpec) DeepCopy() *InterStepBufferServiceSpec

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

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

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

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

+ func (m *InterStepBufferServiceSpec) Reset()

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

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

+ func (m *InterStepBufferServiceSpec) XXX_DiscardUnknown()

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

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

+ func (m *InterStepBufferServiceSpec) XXX_Size() int

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

+ func (this *InterStepBufferServiceSpec) String() string

+ type InterStepBufferServiceStatus struct

+ Config BufferServiceConfig

+ Message string

+ Phase ISBSvcPhase

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

+ func (*InterStepBufferServiceStatus) ProtoMessage()

+ func (in *InterStepBufferServiceStatus) DeepCopy() *InterStepBufferServiceStatus

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

+ func (isbsvc *InterStepBufferServiceStatus) InitConditions()

+ func (isbsvc *InterStepBufferServiceStatus) MarkConfigured()

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

+ func (isbsvc *InterStepBufferServiceStatus) MarkDeployed()

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

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

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

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

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

+ func (m *InterStepBufferServiceStatus) Reset()

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

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

+ func (m *InterStepBufferServiceStatus) XXX_DiscardUnknown()

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

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

+ func (m *InterStepBufferServiceStatus) XXX_Size() int

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

+ func (this *InterStepBufferServiceStatus) String() string

+ type JetStreamBufferService struct

+ Affinity *corev1.Affinity

+ BufferConfig *string

+ ContainerTemplate *ContainerTemplate

+ Encryption bool

+ ImagePullSecrets []corev1.LocalObjectReference

+ Metadata *Metadata

+ MetricsContainerTemplate *ContainerTemplate

+ NodeSelector map[string]string

+ Persistence *PersistenceStrategy

+ Priority *int32

+ PriorityClassName string

+ ReloaderContainerTemplate *ContainerTemplate

+ Replicas *int32

+ SecurityContext *corev1.PodSecurityContext

+ ServiceAccountName string

+ Settings *string

+ StartArgs []string

+ TLS bool

+ Tolerations []corev1.Toleration

+ Version string

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

+ func (*JetStreamBufferService) ProtoMessage()

+ func (in *JetStreamBufferService) DeepCopy() *JetStreamBufferService

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

+ func (j JetStreamBufferService) GetReplicas() int

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

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

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

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

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

+ func (m *JetStreamBufferService) Reset()

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

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

+ func (m *JetStreamBufferService) XXX_DiscardUnknown()

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

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

+ func (m *JetStreamBufferService) XXX_Size() int

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

+ func (this *JetStreamBufferService) String() string

+ type JetStreamConfig struct

+ Auth *NATSAuth

+ BufferConfig string

+ TLSEnabled bool

+ URL string

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

+ func (*JetStreamConfig) ProtoMessage()

+ func (in *JetStreamConfig) DeepCopy() *JetStreamConfig

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

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

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

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

+ func (m *JetStreamConfig) Reset()

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

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

+ func (m *JetStreamConfig) XXX_DiscardUnknown()

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

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

+ func (m *JetStreamConfig) XXX_Size() int

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

+ func (this *JetStreamConfig) String() string

+ type KafkaSink struct

+ Brokers []string

+ Concurrency uint32

+ Config string

+ TLS *TLS

+ Topic string

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

+ func (*KafkaSink) ProtoMessage()

+ func (in *KafkaSink) DeepCopy() *KafkaSink

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

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

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

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

+ func (m *KafkaSink) Reset()

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

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

+ func (m *KafkaSink) XXX_DiscardUnknown()

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

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

+ func (m *KafkaSink) XXX_Size() int

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

+ func (this *KafkaSink) String() string

+ type KafkaSource struct

+ Brokers []string

+ Config string

+ ConsumerGroupName string

+ TLS *TLS

+ Topic string

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

+ func (*KafkaSource) ProtoMessage()

+ func (in *KafkaSource) DeepCopy() *KafkaSource

+ func (in *KafkaSource) DeepCopyInto(out *KafkaSource)

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

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

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

+ func (m *KafkaSource) Reset()

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

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

+ func (m *KafkaSource) XXX_DiscardUnknown()

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

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

+ func (m *KafkaSource) XXX_Size() int

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

+ func (this *KafkaSource) String() string

+ type Lifecycle struct

+ DeleteGracePeriodSeconds int32

+ DesiredPhase PipelinePhase

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

+ func (*Lifecycle) ProtoMessage()

+ func (in *Lifecycle) DeepCopy() *Lifecycle

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

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

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

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

+ func (m *Lifecycle) Reset()

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

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

+ func (m *Lifecycle) XXX_DiscardUnknown()

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

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

+ func (m *Lifecycle) XXX_Size() int

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

+ func (this *Lifecycle) String() string

+ type Log struct

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

+ func (*Log) ProtoMessage()

+ func (in *Log) DeepCopy() *Log

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

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

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

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

+ func (m *Log) Reset()

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

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

+ func (m *Log) XXX_DiscardUnknown()

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

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

+ func (m *Log) XXX_Size() int

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

+ func (this *Log) String() string

+ type Metadata struct

+ Annotations map[string]string

+ Labels map[string]string

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

+ func (*Metadata) ProtoMessage()

+ func (in *Metadata) DeepCopy() *Metadata

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

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

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

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

+ func (m *Metadata) Reset()

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

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

+ func (m *Metadata) XXX_DiscardUnknown()

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

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

+ func (m *Metadata) XXX_Size() int

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

+ func (this *Metadata) String() string

+ type NATSAuth struct

+ Password *corev1.SecretKeySelector

+ User *corev1.SecretKeySelector

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

+ func (*NATSAuth) ProtoMessage()

+ func (in *NATSAuth) DeepCopy() *NATSAuth

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

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

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

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

+ func (m *NATSAuth) Reset()

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

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

+ func (m *NATSAuth) XXX_DiscardUnknown()

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

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

+ func (m *NATSAuth) XXX_Size() int

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

+ func (this *NATSAuth) String() string

+ type NativeRedis struct

+ Affinity *corev1.Affinity

+ ImagePullSecrets []corev1.LocalObjectReference

+ Metadata *Metadata

+ MetricsContainerTemplate *ContainerTemplate

+ NodeSelector map[string]string

+ Persistence *PersistenceStrategy

+ Priority *int32

+ PriorityClassName string

+ RedisContainerTemplate *ContainerTemplate

+ Replicas *int32

+ SecurityContext *corev1.PodSecurityContext

+ SentinelContainerTemplate *ContainerTemplate

+ ServiceAccountName string

+ Settings *RedisSettings

+ Tolerations []corev1.Toleration

+ Version string

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

+ func (*NativeRedis) ProtoMessage()

+ func (in *NativeRedis) DeepCopy() *NativeRedis

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

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

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

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

+ func (m *NativeRedis) Reset()

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

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

+ func (m *NativeRedis) XXX_DiscardUnknown()

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

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

+ func (m *NativeRedis) XXX_Size() int

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

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

+ func (nr NativeRedis) GetReplicas() int

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

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

+ func (this *NativeRedis) String() string

+ type PersistenceStrategy struct

+ AccessMode *corev1.PersistentVolumeAccessMode

+ StorageClassName *string

+ VolumeSize *apiresource.Quantity

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

+ func (*PersistenceStrategy) ProtoMessage()

+ func (in *PersistenceStrategy) DeepCopy() *PersistenceStrategy

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

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

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

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

+ func (m *PersistenceStrategy) Reset()

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

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

+ func (m *PersistenceStrategy) XXX_DiscardUnknown()

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

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

+ func (m *PersistenceStrategy) XXX_Size() int

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

+ func (this *PersistenceStrategy) String() string

+ type Pipeline struct

+ Spec PipelineSpec

+ Status PipelineStatus

+ func (*Pipeline) Descriptor() ([]byte, []int)

+ func (*Pipeline) ProtoMessage()

+ func (in *Pipeline) DeepCopy() *Pipeline

+ func (in *Pipeline) DeepCopyInto(out *Pipeline)

+ func (in *Pipeline) DeepCopyObject() runtime.Object

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

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

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

+ func (m *Pipeline) Reset()

+ func (m *Pipeline) Size() (n int)

+ func (m *Pipeline) Unmarshal(dAtA []byte) error

+ func (m *Pipeline) XXX_DiscardUnknown()

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

+ func (m *Pipeline) XXX_Merge(src proto.Message)

+ func (m *Pipeline) XXX_Size() int

+ func (m *Pipeline) XXX_Unmarshal(b []byte) error

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

+ func (p Pipeline) GetAllBuffers() []string

+ func (p Pipeline) GetDaemonDeploymentName() string

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

+ func (p Pipeline) GetDaemonServiceName() string

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

+ func (p Pipeline) GetDaemonServiceURL() string

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

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

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

+ func (this *Pipeline) String() string

+ type PipelineLimits struct

+ BufferMaxLength *uint64

+ BufferUsageLimit *uint32

+ ReadBatchSize *uint64

+ UDFWorkers *uint32

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

+ func (*PipelineLimits) ProtoMessage()

+ func (in *PipelineLimits) DeepCopy() *PipelineLimits

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

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

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

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

+ func (m *PipelineLimits) Reset()

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

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

+ func (m *PipelineLimits) XXX_DiscardUnknown()

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

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

+ func (m *PipelineLimits) XXX_Size() int

+ func (m *PipelineLimits) XXX_Unmarshal(b []byte) error

+ func (this *PipelineLimits) String() string

+ type PipelineList struct

+ Items []Pipeline

+ func (*PipelineList) Descriptor() ([]byte, []int)

+ func (*PipelineList) ProtoMessage()

+ func (in *PipelineList) DeepCopy() *PipelineList

+ func (in *PipelineList) DeepCopyInto(out *PipelineList)

+ func (in *PipelineList) DeepCopyObject() runtime.Object

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

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

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

+ func (m *PipelineList) Reset()

+ func (m *PipelineList) Size() (n int)

+ func (m *PipelineList) Unmarshal(dAtA []byte) error

+ func (m *PipelineList) XXX_DiscardUnknown()

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

+ func (m *PipelineList) XXX_Merge(src proto.Message)

+ func (m *PipelineList) XXX_Size() int

+ func (m *PipelineList) XXX_Unmarshal(b []byte) error

+ func (this *PipelineList) String() string

+ type PipelinePhase string

+ type PipelineSpec struct

+ Edges []Edge

+ InterStepBufferServiceName string

+ Lifecycle Lifecycle

+ Limits *PipelineLimits

+ Vertices []AbstractVertex

+ Watermark Watermark

+ func (*PipelineSpec) Descriptor() ([]byte, []int)

+ func (*PipelineSpec) ProtoMessage()

+ func (in *PipelineSpec) DeepCopy() *PipelineSpec

+ func (in *PipelineSpec) DeepCopyInto(out *PipelineSpec)

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

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

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

+ func (m *PipelineSpec) Reset()

+ func (m *PipelineSpec) Size() (n int)

+ func (m *PipelineSpec) Unmarshal(dAtA []byte) error

+ func (m *PipelineSpec) XXX_DiscardUnknown()

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

+ func (m *PipelineSpec) XXX_Merge(src proto.Message)

+ func (m *PipelineSpec) XXX_Size() int

+ func (m *PipelineSpec) XXX_Unmarshal(b []byte) error

+ func (this *PipelineSpec) String() string

+ type PipelineStatus struct

+ LastUpdated metav1.Time

+ Message string

+ Phase PipelinePhase

+ func (*PipelineStatus) Descriptor() ([]byte, []int)

+ func (*PipelineStatus) ProtoMessage()

+ func (in *PipelineStatus) DeepCopy() *PipelineStatus

+ func (in *PipelineStatus) DeepCopyInto(out *PipelineStatus)

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

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

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

+ func (m *PipelineStatus) Reset()

+ func (m *PipelineStatus) Size() (n int)

+ func (m *PipelineStatus) Unmarshal(dAtA []byte) error

+ func (m *PipelineStatus) XXX_DiscardUnknown()

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

+ func (m *PipelineStatus) XXX_Merge(src proto.Message)

+ func (m *PipelineStatus) XXX_Size() int

+ func (m *PipelineStatus) XXX_Unmarshal(b []byte) error

+ func (pls *PipelineStatus) InitConditions()

+ func (pls *PipelineStatus) MarkConfigured()

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

+ func (pls *PipelineStatus) MarkDeployed()

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

+ func (pls *PipelineStatus) MarkPhaseDeleting()

+ func (pls *PipelineStatus) MarkPhasePaused()

+ func (pls *PipelineStatus) MarkPhasePausing()

+ func (pls *PipelineStatus) MarkPhaseRunning()

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

+ func (this *PipelineStatus) String() string

+ type RedisBuferService struct

+ External *RedisConfig

+ Native *NativeRedis

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

+ func (*RedisBuferService) ProtoMessage()

+ func (in *RedisBuferService) DeepCopy() *RedisBuferService

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

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

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

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

+ func (m *RedisBuferService) Reset()

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

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

+ func (m *RedisBuferService) XXX_DiscardUnknown()

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

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

+ func (m *RedisBuferService) XXX_Size() int

+ func (m *RedisBuferService) XXX_Unmarshal(b []byte) error

+ func (this *RedisBuferService) String() string

+ type RedisConfig struct

+ MasterName string

+ Password *corev1.SecretKeySelector

+ SentinelPassword *corev1.SecretKeySelector

+ SentinelURL string

+ URL string

+ User string

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

+ func (*RedisConfig) ProtoMessage()

+ func (in *RedisConfig) DeepCopy() *RedisConfig

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

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

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

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

+ func (m *RedisConfig) Reset()

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

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

+ func (m *RedisConfig) XXX_DiscardUnknown()

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

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

+ func (m *RedisConfig) XXX_Size() int

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

+ func (this *RedisConfig) String() string

+ type RedisSettings struct

+ Master string

+ Redis string

+ Replica string

+ Sentinel string

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

+ func (*RedisSettings) ProtoMessage()

+ func (in *RedisSettings) DeepCopy() *RedisSettings

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

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

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

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

+ func (m *RedisSettings) Reset()

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

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

+ func (m *RedisSettings) XXX_DiscardUnknown()

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

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

+ func (m *RedisSettings) XXX_Size() int

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

+ func (this *RedisSettings) String() string

+ type Scale struct

+ Max *int32

+ Min *int32

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

+ func (*Scale) ProtoMessage()

+ func (in *Scale) DeepCopy() *Scale

+ func (in *Scale) DeepCopyInto(out *Scale)

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

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

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

+ func (m *Scale) Reset()

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

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

+ func (m *Scale) XXX_DiscardUnknown()

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

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

+ func (m *Scale) XXX_Size() int

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

+ func (this *Scale) String() string

+ type Sink struct

+ Kafka *KafkaSink

+ Log *Log

+ UDSink *UDSink

+ func (*Sink) Descriptor() ([]byte, []int)

+ func (*Sink) ProtoMessage()

+ func (in *Sink) DeepCopy() *Sink

+ func (in *Sink) DeepCopyInto(out *Sink)

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

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

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

+ func (m *Sink) Reset()

+ func (m *Sink) Size() (n int)

+ func (m *Sink) Unmarshal(dAtA []byte) error

+ func (m *Sink) XXX_DiscardUnknown()

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

+ func (m *Sink) XXX_Merge(src proto.Message)

+ func (m *Sink) XXX_Size() int

+ func (m *Sink) XXX_Unmarshal(b []byte) error

+ func (this *Sink) String() string

+ type Source struct

+ Generator *GeneratorSource

+ HTTP *HTTPSource

+ Kafka *KafkaSource

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

+ func (*Source) ProtoMessage()

+ func (in *Source) DeepCopy() *Source

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

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

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

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

+ func (m *Source) Reset()

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

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

+ func (m *Source) XXX_DiscardUnknown()

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

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

+ func (m *Source) XXX_Size() int

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

+ func (this *Source) String() string

+ type Status struct

+ Conditions []metav1.Condition

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

+ func (*Status) ProtoMessage()

+ func (in *Status) DeepCopy() *Status

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

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

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

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

+ func (m *Status) Reset()

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

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

+ func (m *Status) XXX_DiscardUnknown()

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

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

+ func (m *Status) XXX_Size() int

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

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

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

+ func (s *Status) IsReady() bool

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

+ func (s *Status) MarkTrue(t ConditionType)

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

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

+ func (this *Status) String() string

+ type TLS struct

+ CACertSecret *corev1.SecretKeySelector

+ CertSecret *corev1.SecretKeySelector

+ InsecureSkipVerify bool

+ KeySecret *corev1.SecretKeySelector

+ func (*TLS) Descriptor() ([]byte, []int)

+ func (*TLS) ProtoMessage()

+ func (in *TLS) DeepCopy() *TLS

+ func (in *TLS) DeepCopyInto(out *TLS)

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

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

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

+ func (m *TLS) Reset()

+ func (m *TLS) Size() (n int)

+ func (m *TLS) Unmarshal(dAtA []byte) error

+ func (m *TLS) XXX_DiscardUnknown()

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

+ func (m *TLS) XXX_Merge(src proto.Message)

+ func (m *TLS) XXX_Size() int

+ func (m *TLS) XXX_Unmarshal(b []byte) error

+ func (this *TLS) String() string

+ type ToVertex struct

+ Conditions *ForwardConditions

+ Name string

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

+ func (*ToVertex) ProtoMessage()

+ func (in *ToVertex) DeepCopy() *ToVertex

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

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

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

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

+ func (m *ToVertex) Reset()

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

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

+ func (m *ToVertex) XXX_DiscardUnknown()

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

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

+ func (m *ToVertex) XXX_Size() int

+ func (m *ToVertex) XXX_Unmarshal(b []byte) error

+ func (this *ToVertex) String() string

+ type UDF struct

+ Builtin *Function

+ Container *Container

+ func (*UDF) Descriptor() ([]byte, []int)

+ func (*UDF) ProtoMessage()

+ func (in *UDF) DeepCopy() *UDF

+ func (in *UDF) DeepCopyInto(out *UDF)

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

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

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

+ func (m *UDF) Reset()

+ func (m *UDF) Size() (n int)

+ func (m *UDF) Unmarshal(dAtA []byte) error

+ func (m *UDF) XXX_DiscardUnknown()

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

+ func (m *UDF) XXX_Merge(src proto.Message)

+ func (m *UDF) XXX_Size() int

+ func (m *UDF) XXX_Unmarshal(b []byte) error

+ func (this *UDF) String() string

+ type UDSink struct

+ Container Container

+ func (*UDSink) Descriptor() ([]byte, []int)

+ func (*UDSink) ProtoMessage()

+ func (in *UDSink) DeepCopy() *UDSink

+ func (in *UDSink) DeepCopyInto(out *UDSink)

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

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

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

+ func (m *UDSink) Reset()

+ func (m *UDSink) Size() (n int)

+ func (m *UDSink) Unmarshal(dAtA []byte) error

+ func (m *UDSink) XXX_DiscardUnknown()

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

+ func (m *UDSink) XXX_Merge(src proto.Message)

+ func (m *UDSink) XXX_Size() int

+ func (m *UDSink) XXX_Unmarshal(b []byte) error

+ func (this *UDSink) String() string

+ type Vertex struct

+ Spec VertexSpec

+ Status VertexStatus

+ func (*Vertex) Descriptor() ([]byte, []int)

+ func (*Vertex) ProtoMessage()

+ func (in *Vertex) DeepCopy() *Vertex

+ func (in *Vertex) DeepCopyInto(out *Vertex)

+ func (in *Vertex) DeepCopyObject() runtime.Object

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

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

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

+ func (m *Vertex) Reset()

+ func (m *Vertex) Size() (n int)

+ func (m *Vertex) Unmarshal(dAtA []byte) error

+ func (m *Vertex) XXX_DiscardUnknown()

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

+ func (m *Vertex) XXX_Merge(src proto.Message)

+ func (m *Vertex) XXX_Size() int

+ func (m *Vertex) XXX_Unmarshal(b []byte) error

+ func (this *Vertex) String() string

+ func (v Vertex) GetFromBuffers() []string

+ func (v Vertex) GetHeadlessServiceName() string

+ func (v Vertex) GetPodSpec(req GetVertexPodSpecReq) (*corev1.PodSpec, error)

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

+ func (v Vertex) GetToBufferName(toVertexName string) string

+ func (v Vertex) GetToBuffers() []string

+ func (v Vertex) IsASink() bool

+ func (v Vertex) IsASource() bool

+ func (v Vertex) IsAnUDF() bool

+ type VertexLimits struct

+ BufferMaxLength *uint64

+ BufferUsageLimit *uint32

+ ReadBatchSize *uint64

+ UDFWorkers *uint32

+ func (*VertexLimits) Descriptor() ([]byte, []int)

+ func (*VertexLimits) ProtoMessage()

+ func (in *VertexLimits) DeepCopy() *VertexLimits

+ func (in *VertexLimits) DeepCopyInto(out *VertexLimits)

+ func (m *VertexLimits) Marshal() (dAtA []byte, err error)

+ func (m *VertexLimits) MarshalTo(dAtA []byte) (int, error)

+ func (m *VertexLimits) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VertexLimits) Reset()

+ func (m *VertexLimits) Size() (n int)

+ func (m *VertexLimits) Unmarshal(dAtA []byte) error

+ func (m *VertexLimits) XXX_DiscardUnknown()

+ func (m *VertexLimits) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VertexLimits) XXX_Merge(src proto.Message)

+ func (m *VertexLimits) XXX_Size() int

+ func (m *VertexLimits) XXX_Unmarshal(b []byte) error

+ func (this *VertexLimits) String() string

+ type VertexList struct

+ Items []Vertex

+ func (*VertexList) Descriptor() ([]byte, []int)

+ func (*VertexList) ProtoMessage()

+ func (in *VertexList) DeepCopy() *VertexList

+ func (in *VertexList) DeepCopyInto(out *VertexList)

+ func (in *VertexList) DeepCopyObject() runtime.Object

+ func (m *VertexList) Marshal() (dAtA []byte, err error)

+ func (m *VertexList) MarshalTo(dAtA []byte) (int, error)

+ func (m *VertexList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VertexList) Reset()

+ func (m *VertexList) Size() (n int)

+ func (m *VertexList) Unmarshal(dAtA []byte) error

+ func (m *VertexList) XXX_DiscardUnknown()

+ func (m *VertexList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VertexList) XXX_Merge(src proto.Message)

+ func (m *VertexList) XXX_Size() int

+ func (m *VertexList) XXX_Unmarshal(b []byte) error

+ func (this *VertexList) String() string

+ type VertexPhase string

+ const VertexPhaseFailed

+ const VertexPhasePending

+ const VertexPhaseRunning

+ const VertexPhaseSucceeded

+ const VertexPhaseUnknown

+ type VertexSpec struct

+ FromVertices []string

+ InterStepBufferServiceName string

+ PipelineName string

+ Replicas *int32

+ ToVertices []ToVertex

+ func (*VertexSpec) Descriptor() ([]byte, []int)

+ func (*VertexSpec) ProtoMessage()

+ func (in *VertexSpec) DeepCopy() *VertexSpec

+ func (in *VertexSpec) DeepCopyInto(out *VertexSpec)

+ func (m *VertexSpec) Marshal() (dAtA []byte, err error)

+ func (m *VertexSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *VertexSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VertexSpec) Reset()

+ func (m *VertexSpec) Size() (n int)

+ func (m *VertexSpec) Unmarshal(dAtA []byte) error

+ func (m *VertexSpec) XXX_DiscardUnknown()

+ func (m *VertexSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VertexSpec) XXX_Merge(src proto.Message)

+ func (m *VertexSpec) XXX_Size() int

+ func (m *VertexSpec) XXX_Unmarshal(b []byte) error

+ func (this *VertexSpec) String() string

+ func (vs VertexSpec) GetReplicas() int

+ func (vs VertexSpec) WithOutReplicas() VertexSpec

+ type VertexStatus struct

+ LastScaledAt metav1.Time

+ Message string

+ Phase VertexPhase

+ Reason string

+ Replicas uint32

+ Selector string

+ func (*VertexStatus) Descriptor() ([]byte, []int)

+ func (*VertexStatus) ProtoMessage()

+ func (in *VertexStatus) DeepCopy() *VertexStatus

+ func (in *VertexStatus) DeepCopyInto(out *VertexStatus)

+ func (m *VertexStatus) Marshal() (dAtA []byte, err error)

+ func (m *VertexStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *VertexStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VertexStatus) Reset()

+ func (m *VertexStatus) Size() (n int)

+ func (m *VertexStatus) Unmarshal(dAtA []byte) error

+ func (m *VertexStatus) XXX_DiscardUnknown()

+ func (m *VertexStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VertexStatus) XXX_Merge(src proto.Message)

+ func (m *VertexStatus) XXX_Size() int

+ func (m *VertexStatus) XXX_Unmarshal(b []byte) error

+ func (this *VertexStatus) String() string

+ func (vs *VertexStatus) MarkPhase(phase VertexPhase, reason, message string)

+ func (vs *VertexStatus) MarkPhaseFailed(reason, message string)

+ func (vs *VertexStatus) MarkPhaseRunning()

+ type Watermark struct

+ Propagate bool

+ func (*Watermark) Descriptor() ([]byte, []int)

+ func (*Watermark) ProtoMessage()

+ func (in *Watermark) DeepCopy() *Watermark

+ func (in *Watermark) DeepCopyInto(out *Watermark)

+ func (m *Watermark) Marshal() (dAtA []byte, err error)

+ func (m *Watermark) MarshalTo(dAtA []byte) (int, error)

+ func (m *Watermark) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Watermark) Reset()

+ func (m *Watermark) Size() (n int)

+ func (m *Watermark) Unmarshal(dAtA []byte) error

+ func (m *Watermark) XXX_DiscardUnknown()

+ func (m *Watermark) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Watermark) XXX_Merge(src proto.Message)

+ func (m *Watermark) XXX_Size() int

+ func (m *Watermark) XXX_Unmarshal(b []byte) error

+ func (this *Watermark) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL