package
1.0.0-beta.4
Repository: https://github.com/practo/tipoca-stream.git
Documentation: pkg.go.dev

# Constants

MaskActive tells the current MaskFileVersion.
MaskRealtime tells the SinkGroup has been reloaded with new mask version and is realtime and it is waiting to be released.
MaskReloading tells the current MaskFileVersion is not same as the MaskFileVersion specified(i.e.

# Variables

AddToScheme adds the types in this group-version to the given scheme.
GroupVersion is group version used to register these objects.
SchemeBuilder is used to add go types to the GroupVersionKind scheme.

# Structs

DeploymentUnit is used to specify how many topics will run together in a unit and how much resources it needs.
No description provided by the author
No description provided by the author
RedshiftBatcherSpec defines the desired state of RedshiftBatcher.
RedshiftLoaderSpec defines the desired state of RedshifLoader.
RedshiftPodTemplateSpec supports a subset of `v1/PodTemplateSpec` that the operator explicitly permits.
+kubebuilder:subresource:status RedshiftSink is the Schema for the redshiftsinks API.
RedshiftSinkList contains a list of RedshiftSink.
RedshiftSinkSpec defines the desired state of RedshiftSink.
RedshiftSinkStatus defines the observed state of RedshiftSink.
No description provided by the author
SinkGroup is the group of batcher and loader pods based on the mask version, target table and the topic release status.
SinkGroupSpec defines the specification for one of the three sinkgroups: 1.
TopicMaskStatus store the mask status of a single topic.

# Type aliases

MaskPhase is a label for the condition of a masking at the current time.