package
0.10.3
Repository: https://github.com/argoproj-labs/argo-dataflow.git
Documentation: pkg.go.dev

# Functions

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Constants

how many messages between commits, therefore potential duplicates during disruption.
the pipeline completed.
added if any step is currently running.
added if any terminator step terminated.
container names.
No description provided by the author
No description provided by the author
env vars.
enable debug flags, maybe "true" or CSV, e.g.
default "quay.io/argoproj".
allows providing a list of imagePullSecrets as a comma delimited string (eg.
No description provided by the author
how long between peeking (default 4m).
No description provided by the author
No description provided by the author
default "".
No description provided by the author
how long to wait between any scaling events (including peeking) default "4m".
No description provided by the author
use Unix Domain Socket, default "true".
default "15s".
messages are sent as an array where each element is a base 64 encoded.
messages are sent as an array where each element is a string.
all messages are sent one by one - probably not what you want.
label/annotation keys.
No description provided by the author
No description provided by the author
hash of the object.
No description provided by the author
No description provided by the author
No description provided by the author
the step name without pipeline name prefix.
the authorization header which must be used by the main container to speak to the sidecar.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Variables

AddToScheme adds the types in this group-version to the given scheme.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
GroupVersion is group version used to register these objects.
No description provided by the author
No description provided by the author
MetaID is a unique ID for the message.
MetaSource is the source of the messages as a Unique Resource Identifier (URI).
MetaTime is the time of the message.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
SchemeBuilder is used to add go types to the GroupVersionKind scheme.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Structs

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
+kubebuilder:object:root=true +kubebuilder:resource:shortName=pl +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Phase",type=string,JSONPath=`.status.phase` +kubebuilder:printcolumn:name="Message",type=string,JSONPath=`.status.message`.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:subresource:scale:specpath=.spec.replicas,statuspath=.status.replicas,selectorpath=.status.selector +kubebuilder:printcolumn:name="Phase",type=string,JSONPath=`.status.phase` +kubebuilder:printcolumn:name="Reason",type=string,JSONPath=`.status.reason` +kubebuilder:printcolumn:name="Message",type=string,JSONPath=`.status.message` +kubebuilder:printcolumn:name="Desired",type=string,JSONPath=`.spec.replicas` +kubebuilder:printcolumn:name="Current",type=string,JSONPath=`.status.replicas`.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Type aliases

No description provided by the author
+kubebuilder:validation:Enum="";JSONBytesArray;JSONStringArray.
+kubebuilder:validation:Enum=First;Last.
No description provided by the author
+kubebuilder:validation:Enum="";Pending;Running;Succeeded;Failed.
+kubebuilder:validation:Enum=golang1-16;golang1-17;java16;python3-9;node16.
No description provided by the author
No description provided by the author
+kubebuilder:validation:Enum="";Pending;Running;Succeeded;Failed.
No description provided by the author
+kubebuilder:validation:Enum="";None;NamespaceName;NamespacedPipelineName.