package
0.21.6
Repository: https://github.com/streamnative/function-mesh.git
Documentation: pkg.go.dev

# Functions

No description provided by the author
NewConfig constructs a Config with the given unstructured configuration data.

# Constants

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
BatchSourceClass the source class for batch source.
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
LogLevelAll indicates that all logs are logged and is only available for the Java runtime.
LogLevelDebug indicates the debugging purposes, available for Python, Go and Java runtime.
LogLevelError indicates the errors have occurred, available for Python, Go and Java runtime.
LogLevelFatal indicates the server is unusable, available for Python, Go and Java runtime.
LogLevelInfo indicates the normal purposes, available for Python, Go and Java runtime.
LogLevelOff indicates no logging and is only available for the Java runtime.
LogLevelPanic indicates the server is panic and is only available for the Go runtime.
LogLevelTrace indicates the detailed debugging purposes, available for Python, Go and Java runtime.
LogLevelWarn indicates the unexpected purposes, available for Python, Go and Java runtime.
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

# 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.
SchemeGroupVersion is group version used to register these objects added for generated clientset.

# Structs

No description provided by the author
BackendConfig is the Schema of the global configs for all functions, sinks and sources +kubebuilder:pruning:PreserveUnknownFields.
BackendConfigList contains a list of BackendConfig.
BackendConfigPodPolicy defines the policy for the pod TODO: Support more fields from PodPolicy.
BackendConfigSpec defines the desired state of BackendConfig +kubebuilder:validation:Optional.
BackendConfigStatus defines the observed state of BackendConfig.
No description provided by the author
Config represents untyped YAML configuration.
No description provided by the author
No description provided by the author
No description provided by the author
Function is the Schema for the functions API +kubebuilder:pruning:PreserveUnknownFields.
FunctionList contains a list of Function.
FunctionMesh is the Schema for the functionmeshes API.
FunctionMeshList contains a list of FunctionMesh.
FunctionMeshSpec defines the desired state of FunctionMesh.
FunctionMeshStatus defines the observed state of FunctionMesh.
FunctionSpec defines the desired state of Function +kubebuilder:validation:Optional.
FunctionStatus defines the observed state of Function.
No description provided by the author
GenericRuntime contains the generic runtime configs +kubebuilder:validation:Optional.
GoRuntime contains the golang runtime configs +kubebuilder:validation:Optional.
No description provided by the author
JavaRuntime contains the java runtime configs +kubebuilder:validation:Optional.
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
PythonRuntime contains the python runtime configs +kubebuilder:validation:Optional.
ResourceCondition The `Status` of a given `Condition` and the `Action` needed to reach the `Status`.
No description provided by the author
No description provided by the author
No description provided by the author
Sink is the Schema for the sinks API +kubebuilder:pruning:PreserveUnknownFields.
SinkList contains a list of Topic.
SinkSpec defines the desired state of Topic +kubebuilder:validation:Optional.
SinkStatus defines the observed state of Topic.
Source is the Schema for the sources API +kubebuilder:pruning:PreserveUnknownFields.
SourceList contains a list of Source.
SourceSpec defines the desired state of Source +kubebuilder:validation:Optional.
SourceStatus defines the observed state of Source.
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
No description provided by the author
CompressionType enum type +kubebuilder:validation:Enum=NONE;LZ4;ZLIB;ZSTD;SNAPPY.
+kubebuilder:validation:Enum=json;text.
+kubebuilder:validation:Enum=yaml;xml;ini.
LogLevel describes the level of the logging +kubebuilder:validation:Enum=off;trace;debug;info;warn;error;fatal;all;panic.
LogTopicAgent enum type +kubebuilder:validation:Enum=runtime;sidecar.
ProcessGuarantee enum type +kubebuilder:validation:Enum=atleast_once;atmost_once;effectively_once;manual.
No description provided by the author
No description provided by the author
SubscribePosition enum type +kubebuilder:validation:Enum=latest;earliest.
TriggeringPolicy is using to determine if a rollover should occur.