Versions in this module Expand all Collapse all v1 v1.14.2 Feb 25, 2025 Changes in this version + const BatchModeDisable + const BatchModeEnable + const DefaultBatchSize + const DefaultBatchTimeout + const DefaultWorkerTerminationTimeout + const ExplicitAckModeDisable + const ExplicitAckModeEnable + const ExplicitAckModeExplicitOnly + const FunctionAnnotationForceUpdate + const FunctionAnnotationPrevState + const FunctionAnnotationSkipBuild + const FunctionAnnotationSkipDeploy + const FunctionSecretMountPath + const NuclioFlexVolumeSecretNamePrefix + const NvidiaGPUResourceName + const ReferencePrefix + const ReferenceToEnvVarPrefix + const SecretContentKey + const SecretTypeFunctionConfig + const SecretTypeV3ioFuse + var FixableValidationErrors = []string + func BatchModeEnabled(batchConfiguration *BatchConfiguration) bool + func ExplicitAckEnabled(mode ExplicitAckMode) bool + func ExplicitAckModeInSlice(ackMode ExplicitAckMode, ackModes []ExplicitAckMode) bool + func FunctionStateInSlice(functionState FunctionState, functionStates []FunctionState) bool + func FunctionStateProvisioned(functionState FunctionState) bool + func FunctionStateProvisioning(functionState FunctionState) bool + func GetFunctionIngresses(config *Config) map[string]Ingress + func GetTriggersByKind(triggers map[string]Trigger, kind string) map[string]Trigger + func GetTriggersByKinds(triggers map[string]Trigger, kinds []string) map[string]Trigger + func IsPreviousFunctionStateAllowedToBeSet(prevState FunctionState) bool + func ParseHandler(handler string) (string, string, error) + func ResolveFunctionServiceType(functionSpec *Spec, defaultServiceType v1.ServiceType) v1.ServiceType + func RuntimeSupportExplicitAck(runtime string) bool + func RuntimeSupportsBatching(runtime string) bool + func ShouldSkipBuild(annotations map[string]string) bool + func ShouldSkipDeploy(annotations map[string]string) bool + func TriggerKindSupportsBatching(triggerKind string) bool + type AutoScaleDisplayType string + const AutoScaleMetricTypeInt + const AutoScaleMetricTypePercentage + type AutoScaleMetric struct + DisplayType AutoScaleDisplayType + SourceType autosv2.MetricSourceType + type BatchConfiguration struct + BatchSize int + Mode BatchMode + Timeout string + type BatchMode string + type Build struct + AddedObjectPaths map[string]string + Args map[string]string + BaseImage string + BaseImageRegistry string + BuildTimeoutSeconds *int64 + BuilderServiceAccount string + CodeEntryAttributes map[string]interface{} + CodeEntryType string + Commands []string + Dependencies []string + Directives map[string][]Directive + Flags []string + FunctionConfigPath string + FunctionSourceCode string + Image string + Mode BuildMode + NoBaseImagesPull bool + NoCache bool + NoCleanup bool + Offline bool + OnbuildImage string + Path string + Registry string + RuntimeAttributes map[string]interface{} + ScriptPaths []string + TempDir string + Timestamp int64 + type BuildMode string + const AlwaysBuild + const NeverBuild + type Checkpoint *string + type Config struct + Meta Meta + Spec Spec + func GetFunctionConfigFromInterface(functionConfigInterface interface{}) *Config + func NewConfig() *Config + func (c *Config) AddPrevStateAnnotation(state string) + func (c *Config) AddSkipAnnotations() + func (c *Config) CleanFunctionSpec() + func (c *Config) EnrichWithNodeSelectors(nodeSelector map[string]string) + func (c *Config) EnrichWithTolerations(tolerations []v1.Toleration) + func (c *Config) GetProjectName() (string, error) + func (c *Config) PrepareFunctionForExport(exportOptions *common.ExportFunctionOptions) + func (c *Config) PruneAffinityNodeSelectorRequirement(nodeSelectorRequirements []v1.NodeSelectorRequirement, mode string) + func (c *Config) PruneNodeSelector(nodeSelector map[string]string) + func (c *Config) PruneTolerations(tolerations []v1.Toleration) + type ConfigWithStatus struct + Status Status + type DataBinding struct + Attributes map[string]interface{} + Class string + Kind string + Name string + Path string + Query string + Secret string + URL string + type Directive struct + Kind string + Value string + type ExplicitAckMode string + type FunctionState string + const FunctionStateBuilding + const FunctionStateConfiguringResources + const FunctionStateError + const FunctionStateImported + const FunctionStateReady + const FunctionStateScaledToZero + const FunctionStateUnhealthy + const FunctionStateWaitingForBuild + const FunctionStateWaitingForResourceConfiguration + const FunctionStateWaitingForScaleResourcesFromZero + const FunctionStateWaitingForScaleResourcesToZero + type Ingress struct + Host string + IngressClassName string + PathType networkingv1.PathType + Paths []string + TLS IngressTLS + type IngressTLS struct + Hosts []string + SecretName string + type LoggerSink struct + Level string + Sink string + type Meta struct + Annotations map[string]string + Labels map[string]string + Name string + Namespace string + ResourceVersion string + func (m *Meta) AddSkipBuildAnnotation() + func (m *Meta) AddSkipDeployAnnotation() + func (m *Meta) GetUniqueID() string + func (m *Meta) RemoveSkipBuildAnnotation() + func (m *Meta) RemoveSkipDeployAnnotation() + type Metric struct + SourceType string + ThresholdValue int64 + WindowSize string + type Partition struct + Checkpoint Checkpoint + ID string + type Platform struct + Attributes map[string]interface{} + type Reader struct + func NewReader(parentLogger logger.Logger) (*Reader, error) + func (r *Reader) Read(reader io.Reader, configType string, config *Config) error + func (r *Reader) ReadFunctionConfigFile(functionConfigPath string, config *Config) error + type RunOnPreemptibleNodeMode string + const RunOnPreemptibleNodesAllow + const RunOnPreemptibleNodesConstrain + const RunOnPreemptibleNodesNone + const RunOnPreemptibleNodesPrevent + type ScaleResource struct + MetricName string + Threshold int + WindowSize string + type ScaleToZeroSpec struct + ScaleResources []ScaleResource + type ScaleToZeroStatus struct + LastScaleEvent scalertypes.ScaleEvent + LastScaleEventTime *time.Time + type Scrubber struct + func NewScrubber(parentLogger logger.Logger, sensitiveFields []*regexp.Regexp, ...) *Scrubber + func (s *Scrubber) ConvertMapToConfig(mapConfig interface{}) (interface{}, error) + func (s *Scrubber) RestoreFunctionConfig(ctx context.Context, functionConfig *Config, platformName string) (*Config, error) + func (s *Scrubber) ScrubFunctionConfig(ctx context.Context, functionConfig *Config) (*Config, error) + func (s *Scrubber) ValidateReference(objectToScrub interface{}, existingSecretMap map[string]string, ...) error + type Spec struct + Affinity *v1.Affinity + Alias string + AutoScaleMetrics []AutoScaleMetric + Build Build + CustomScalingMetricSpecs []autosv2.MetricSpec + DataBindings map[string]DataBinding + DealerURI string + DeploymentStrategy *appsv1.DeploymentStrategy + Description string + Devices []string + Disable bool + DisableDefaultHTTPTrigger *bool + DisableSensitiveFieldsMasking bool + Env []v1.EnvVar + EnvFrom []v1.EnvFromSource + EventTimeout string + Handler string + HostIPC bool + Image string + ImageHash string + ImagePullPolicy v1.PullPolicy + ImagePullSecrets string + InitContainers []*v1.Container + LoggerSinks []LoggerSink + MaxReplicas *int + MinReplicas *int + NodeName string + NodeSelector map[string]string + Platform Platform + PreemptionMode RunOnPreemptibleNodeMode + PreemptionPolicy *v1.PreemptionPolicy + PriorityClassName string + Publish bool + ReadinessTimeoutSeconds int + Replicas *int + Resources v1.ResourceRequirements + RunRegistry string + Runtime string + RuntimeAttributes map[string]interface{} + ScaleToZero *ScaleToZeroSpec + SecurityContext *v1.PodSecurityContext + ServiceAccount string + ServiceType v1.ServiceType + Sidecars []*v1.Container + TargetCPU int + Tolerations []v1.Toleration + Triggers map[string]Trigger + Version int + Volumes []Volume + WaitReadinessTimeoutBeforeFailure bool + func (s *Spec) DeepCopyInto(out *Spec) + func (s *Spec) GetEventTimeout() (time.Duration, error) + func (s *Spec) GetHTTPPort() int + func (s *Spec) PositiveGPUResourceLimit() bool + type Status struct + APIGateways []string + ContainerImage string + EnrichedNodeSelector map[string]string + ExternalInvocationURLs []string + HTTPPort int + InternalInvocationURLs []string + Logs []map[string]interface{} + Message string + ScaleToZero *ScaleToZeroStatus + State FunctionState + func (s *Status) DeepCopyInto(out *Status) + func (s *Status) InvocationURLs() []string + type Trigger struct + Annotations map[string]string + Attributes map[string]interface{} + Batch *BatchConfiguration + Class string + Disabled bool + ExplicitAckMode ExplicitAckMode + Kind string + MaxTaskAllocation int + MaxWorkers int + Mode TriggerWorkMode + Name string + NumWorkers int + Partitions []Partition + Password string + Paths []string + Secret string + TotalTasks int + URL string + Username string + WaitExplicitAckDuringRebalanceTimeout string + WorkerAllocatorName string + WorkerAvailabilityTimeoutMilliseconds *int + WorkerTerminationTimeout string + func GetDefaultHTTPTrigger() Trigger + type TriggerWorkMode string + const AsyncTriggerWorkMode + const SyncTriggerWorkMode + type Volume struct + Volume v1.Volume + VolumeMount v1.VolumeMount
Go to main page