spec

Oct 23, 2023

Changes in this version

+ const DefaultGenericNodejsRunnerImage

+ const DefaultGenericPythonRunnerImage

+ const DefaultGenericRunnerImage

+ const DefaultGenericRunnerTag

+ func MakeGenericFunctionCommand(downloadPath, functionFile, language, clusterName, details, uid string, ...) []string

type RunnerImages

+ GenericRuntime map[string]string

Aug 25, 2023

Changes in this version

+ const DefaultFilebeatConfig

+ const DefaultFilebeatImage

+ const RunnerImageHasPulsarctl

+ const TokenAuthenticationPlugin

Aug 16, 2023

Changes in this version

+ const DefaultJavaLogConfigPathYAML

+ const JavaLogConfigFileXML

+ const JavaLogConfigFileYAML

+ func CheckIfHPAV2Beta2SpecIsEqual(spec *autoscalingv2beta2.HorizontalPodAutoscalerSpec, ...) bool

May 26, 2023

Changes in this version

+ const AnnotationNeedCleanup

+ const CleanupContainerName

+ const LabelPulsarCluster

+ const LabelPulsarClusterDeprecated

+ func MakeFunctionCleanUpJob(function *v1alpha1.Function) *v1.Job

+ func MakeSinkCleanUpJob(sink *v1alpha1.Sink) *v1.Job

+ func MakeSourceCleanUpJob(source *v1alpha1.Source) *v1.Job

+ func NeedCleanup(object metav1.Object) bool

+ func TriggerCleanup(ctx context.Context, k8sclient client.Client, restClient rest.Interface, ...) error

Jan 17, 2023

Changes in this version

+ const HTTPPrefix

+ const HTTPSPrefix

Dec 22, 2022

Changes in this version

+ const GrpcDir

+ const GrpcVolume

+ func MakeLivenessProbe(liveness *v1alpha1.Liveness) *corev1.Probe

Nov 17, 2022

Changes in this version

+ func MakeVPA(objectMeta *metav1.ObjectMeta, ...) *vpav1.VerticalPodAutoscaler

Oct 18, 2022

Changes in this version

+ const DownloadDir

+ const DownloaderImage

+ const DownloaderName

+ const DownloaderVolume

+ const PulsarctlExecutableFile

+ const WorkDir

Sep 19, 2022

Changes in this version

+ const OAuth2AuthenticationPlugin

+ const WindowFunctionConfigKeyName

+ const WindowFunctionExecutorClass

+ func CheckIfHPASpecIsEqual(spec *autov2beta2.HorizontalPodAutoscalerSpec, ...) bool

+ func CheckIfStatefulSetSpecIsEqual(spec *appsv1.StatefulSetSpec, desiredSpec *appsv1.StatefulSetSpec) bool

+ func GetNamespacedName(object metav1.Object, component string) string

Aug 19, 2022

Changes in this version

+ const DefaultJavaLogConfigPath

+ const DefaultPythonLogConfigPath

+ const EnvGoFunctionLogLevel

+ const JavaLogConfigDirectory

+ const JavaLogConfigFile

+ const PythonLogConfigFile

+ const PythonLogConifgDirectory

Jul 19, 2022

Changes in this version

+ const DefaultForAllowInsecure

+ const DefaultForEnableHostNameVerification

+ type TLSConfig interface

+ AllowInsecureConnection func() string

+ EnableHostnameVerification func() string

+ GetMountPath func() string

+ HasSecretVolume func() bool

+ IsEnabled func() bool

+ SecretKey func() string

+ SecretName func() string

Jun 22, 2022

Changes in this version

+ const AnnotationManaged

+ const AnnotationPrometheusPort

+ const AnnotationPrometheusScrape

+ const AppFunctionMesh

+ const ComponentFunction

+ const ComponentSink

+ const ComponentSource

+ const DefaultGoRunnerImage

+ const DefaultJavaRunnerImage

+ const DefaultPythonRunnerImage

+ const DefaultRunnerGroup

+ const DefaultRunnerGroupID

+ const DefaultRunnerImage

+ const DefaultRunnerPrefix

+ const DefaultRunnerTag

+ const DefaultRunnerUser

+ const DefaultRunnerUserID

+ const EnvGoFunctionConfigs

+ const EnvShardID

+ const FunctionsInstanceClasspath

+ const PackageNameFunctionPrefix

+ const PackageNameSinkPrefix

+ const PackageNameSourcePrefix

+ const PulsarAdminExecutableFile

+ var Configs = DefaultConfigs()

+ var GRPCPort = corev1.ContainerPort

+ var MetricsPort = corev1.ContainerPort

+ func IsManaged(object metav1.Object) bool

+ func MakeFunctionComponent(functionName string, mesh *v1alpha1.FunctionMesh, spec *v1alpha1.FunctionSpec) *v1alpha1.Function

+ func MakeFunctionContainer(function *v1alpha1.Function) *corev1.Container

+ func MakeFunctionHPA(function *v1alpha1.Function) *autov2beta2.HorizontalPodAutoscaler

+ func MakeFunctionObjectMeta(function *v1alpha1.Function) *metav1.ObjectMeta

+ func MakeFunctionService(function *v1alpha1.Function) *corev1.Service

+ func MakeFunctionStatefulSet(function *v1alpha1.Function) *appsv1.StatefulSet

+ func MakeGoFunctionCommand(downloadPath, goExecFilePath string, function *v1alpha1.Function) []string

+ func MakeHeadlessServiceName(serviceName string) string

+ func MakeJavaFunctionCommand(downloadPath, packageFile, name, clusterName, details, memory, ... string, ...) []string

+ func MakeMetricsFromBuiltinHPARules(builtinRules []v1alpha1.BuiltinHPARule) []autov2beta2.MetricSpec

+ func MakePodTemplate(container *corev1.Container, volumes []corev1.Volume, labels map[string]string, ...) *corev1.PodTemplateSpec

+ func MakePythonFunctionCommand(downloadPath, packageFile, name, clusterName, details, uid string, ...) []string

+ func MakeService(objectMeta *metav1.ObjectMeta, labels map[string]string) *corev1.Service

+ func MakeSinkCommand(sink *v1alpha1.Sink) []string

+ func MakeSinkComponent(sinkName string, mesh *v1alpha1.FunctionMesh, spec *v1alpha1.SinkSpec) *v1alpha1.Sink

+ func MakeSinkContainer(sink *v1alpha1.Sink) *corev1.Container

+ func MakeSinkHPA(sink *v1alpha1.Sink) *autov2beta2.HorizontalPodAutoscaler

+ func MakeSinkLabels(sink *v1alpha1.Sink) map[string]string

+ func MakeSinkObjectMeta(sink *v1alpha1.Sink) *metav1.ObjectMeta

+ func MakeSinkService(sink *v1alpha1.Sink) *corev1.Service

+ func MakeSinkServiceName(sink *v1alpha1.Sink) string

+ func MakeSinkStatefulSet(sink *v1alpha1.Sink) *appsv1.StatefulSet

+ func MakeSourceComponent(sourceName string, mesh *v1alpha1.FunctionMesh, spec *v1alpha1.SourceSpec) *v1alpha1.Source

+ func MakeSourceContainer(source *v1alpha1.Source) *corev1.Container

+ func MakeSourceHPA(source *v1alpha1.Source) *autov2beta2.HorizontalPodAutoscaler

+ func MakeSourceObjectMeta(source *v1alpha1.Source) *metav1.ObjectMeta

+ func MakeSourceService(source *v1alpha1.Source) *corev1.Service

+ func MakeSourceStatefulSet(source *v1alpha1.Source) *appsv1.StatefulSet

+ func MakeStatefulSet(objectMeta *metav1.ObjectMeta, replicas *int32, container *corev1.Container, ...) *appsv1.StatefulSet

+ func MakeStatefulSetSpec(replicas *int32, container *corev1.Container, volumes []corev1.Volume, ...) *appsv1.StatefulSetSpec

+ func ParseControllerConfigs(configFilePath string) error

+ type BuiltinAutoScaler interface

+ Metrics func() []autov2beta2.MetricSpec

+ func GetBuiltinAutoScaler(builtinRule v1alpha1.BuiltinHPARule) BuiltinAutoScaler

+ func NewHPARuleAverageUtilizationCPUPercent(cpuPercentage int32) BuiltinAutoScaler

+ func NewHPARuleAverageUtilizationMemoryPercent(memoryPercentage int32) BuiltinAutoScaler

+ type ControllerConfigs struct

+ ResourceAnnotations map[string]string

+ ResourceLabels map[string]string

+ RunnerImages RunnerImages

+ func DefaultConfigs() *ControllerConfigs

+ type GoFunctionConf struct

+ AutoACK bool

+ CPU float64

+ CleanupSubscription bool

+ ClusterName string

+ DeadLetterTopic string

+ Disk int64

+ ExpectedHealthCheckInterval int32

+ FuncID string

+ FuncVersion string

+ InstanceID int

+ IsRegexPatternSubscription bool

+ KillAfterIdle time.Duration

+ LogTopic string

+ MaxBufTuples int

+ MaxMessageRetries int32

+ MetricsPort int

+ Name string

+ NameSpace string

+ Parallelism int32

+ Port int

+ ProcessingGuarantees int32

+ PulsarServiceURL string

+ RAM int64

+ ReceiverQueueSize int32

+ Runtime int32

+ SecretsMap string

+ SinkSchemaType string

+ SinkSpecTopic string

+ SourceSchemaType string

+ SourceSpecTopic string

+ SubscriptionName string

+ SubscriptionType int32

+ Tenant string

+ TimeoutMs uint64

+ UserConfig string

+ type HPARuleAverageUtilizationCPUPercent struct

+ func (H *HPARuleAverageUtilizationCPUPercent) Metrics() []autov2beta2.MetricSpec

+ type HPARuleAverageUtilizationResourceMemoryPercent struct

+ func (H *HPARuleAverageUtilizationResourceMemoryPercent) Metrics() []autov2beta2.MetricSpec

+ type RunnerImages struct

+ Go string

+ Java string

+ Python string