thin

package

Go to main page

Versions in this module

v1

v1.0.8

Oct 30, 2025

Changes in this version

type Fuse

+ Annotations map[string]string

+ Labels map[string]string

v1.0.7

Sep 19, 2025

Changes in this version

type Fuse

+ Lifecycle *corev1.Lifecycle

v1.0.6

Jul 10, 2025

Changes in this version

type Worker

+ Enabled bool

v1.0.5

Feb 24, 2025

Changes in this version

type ThinEngine

+ Recorder record.EventRecorder

type ThinValue

+ OwnerDatasetId string

v1.0.4

Dec 26, 2024

v1.0.3

Oct 17, 2024

Changes in this version

type Fuse

+ ImagePullSecrets []corev1.LocalObjectReference

type ThinValue

+ ImagePullSecrets []corev1.LocalObjectReference

type Worker

+ ImagePullSecrets []corev1.LocalObjectReference

v1.0.2

Aug 28, 2024

Changes in this version

type ThinEngine

+ func (t *ThinEngine) Validate(ctx cruntime.ReconcileRequestContext) (err error)

v1.0.1

Jul 10, 2024

v1.0.0

Apr 18, 2024

Changes in this version

+ const EnvFuseConfigStorage

type Config

+ AccessModes []corev1.PersistentVolumeAccessMode

type Fuse

+ ConfigStorage string

+ HostPID bool

v0

v0.9.3

Mar 13, 2024

v0.9.2

Sep 19, 2023 GO-2024-2644

GO-2024-2644: Fluid vulnerable to OS Command Injection for Fluid Users with JuicefsRuntime in github.com/fluid-cloudnative/fluid

v0.9.1

Jun 15, 2023 GO-2024-2644

GO-2024-2644: Fluid vulnerable to OS Command Injection for Fluid Users with JuicefsRuntime in github.com/fluid-cloudnative/fluid

v0.9.0

May 24, 2023 GO-2024-2644

GO-2024-2644: Fluid vulnerable to OS Command Injection for Fluid Users with JuicefsRuntime in github.com/fluid-cloudnative/fluid

Changes in this version

+ const CheckMetadataSyncDoneTimeoutMillisec

+ const MetadataSyncNotDoneMsg

+ func Build(id string, ctx cruntime.ReconcileRequestContext) (base.Engine, error)

+ func CheckReferenceDatasetRuntime(client client.Client, runtime *datav1alpha1.ThinRuntime) (bool, error)

+ func Precheck(client client.Client, key types.NamespacedName) (found bool, err error)

+ type Config struct

+ Mounts []datav1alpha1.Mount

+ PersistentVolumeAttrs map[string]*corev1.CSIPersistentVolumeSource

+ PersistentVolumeMountOptions map[string][]string

+ RuntimeOptions map[string]string

+ TargetPath string

+ type Fuse struct

+ Args []string

+ CacheDir string

+ Command []string

+ ConfigValue string

+ CriticalPod bool

+ Enabled bool

+ Envs []corev1.EnvVar

+ HostNetwork bool

+ Image string

+ ImagePullPolicy string

+ ImageTag string

+ LivenessProbe *corev1.Probe

+ NodeSelector map[string]string

+ Ports []corev1.ContainerPort

+ ReadinessProbe *corev1.Probe

+ Resources common.Resources

+ TargetPath string

+ VolumeMounts []corev1.VolumeMount

+ Volumes []corev1.Volume

+ type RuntimeSetConfig struct

+ Fuses []string

+ Workers []string

+ type ThinEngine struct

+ Log logr.Logger

+ MetadataSyncDoneCh chan base.MetadataSyncResult

+ UnitTest bool

+ func (t *ThinEngine) BindToDataset() (err error)

+ func (t *ThinEngine) CheckAndUpdateRuntimeStatus() (ready bool, err error)

+ func (t *ThinEngine) CreateDataMigrateJob(ctx cruntime.ReconcileRequestContext, ...) error

+ func (t *ThinEngine) FreeStorageBytes() (int64, error)

+ func (t *ThinEngine) GetDataOperationValueFile(ctx cruntime.ReconcileRequestContext, object client.Object, ...) (valueFileName string, err error)

+ func (t *ThinEngine) GetRunningPodsOfDaemonset(dsName string, namespace string) (pods []corev1.Pod, err error)

+ func (t *ThinEngine) SyncMetadata() (err error)

+ func (t *ThinEngine) TotalFileNums() (int64, error)

+ func (t *ThinEngine) TotalStorageBytes() (int64, error)

+ func (t *ThinEngine) UpdateCacheOfDataset() (err error)

+ func (t *ThinEngine) UpdateDatasetStatus(phase datav1alpha1.DatasetPhase) (err error)

+ func (t *ThinEngine) UpdateRuntimeSetConfigIfNeeded() (updated bool, err error)

+ func (t *ThinEngine) UsedStorageBytes() (int64, error)

+ func (t ThinEngine) AssignNodesToCache(desiredNum int32) (currentNum int32, err error)

+ func (t ThinEngine) CheckExistenceOfPath(targetDataload datav1alpha1.DataLoad) (notExist bool, err error)

+ func (t ThinEngine) CheckMasterReady() (ready bool, err error)

+ func (t ThinEngine) CheckRuntimeHealthy() (err error)

+ func (t ThinEngine) CheckRuntimeReady() (ready bool)

+ func (t ThinEngine) CheckWorkersReady() (ready bool, err error)

+ func (t ThinEngine) CreateDataLoadJob(ctx cruntime.ReconcileRequestContext, targetDataload datav1alpha1.DataLoad) error

+ func (t ThinEngine) CreateVolume() (err error)

+ func (t ThinEngine) DeleteVolume() (err error)

+ func (t ThinEngine) PrepareUFS() (err error)

+ func (t ThinEngine) SetupMaster() (err error)

+ func (t ThinEngine) SetupWorkers() (err error)

+ func (t ThinEngine) ShouldCheckUFS() (should bool, err error)

+ func (t ThinEngine) ShouldSetupMaster() (should bool, err error)

+ func (t ThinEngine) ShouldSetupWorkers() (should bool, err error)

+ func (t ThinEngine) ShouldUpdateUFS() (ufsToUpdate *utils.UFSToUpdate)

+ func (t ThinEngine) Shutdown() (err error)

+ func (t ThinEngine) SyncReplicas(ctx cruntime.ReconcileRequestContext) (err error)

+ func (t ThinEngine) SyncRuntime(ctx cruntime.ReconcileRequestContext) (changed bool, err error)

+ func (t ThinEngine) SyncScheduleInfoToCacheNodes() (err error)

+ func (t ThinEngine) UpdateOnUFSChange(ufsToUpdate *utils.UFSToUpdate) (ready bool, err error)

+ type ThinValue struct

+ FullnameOverride string

+ Fuse Fuse

+ NodeSelector map[string]string

+ Owner *common.OwnerReference

+ PlacementMode string

+ RuntimeIdentity common.RuntimeIdentity

+ RuntimeValue string

+ Tolerations []corev1.Toleration

+ Worker Worker

+ type Worker struct

+ CacheDir string

+ Envs []corev1.EnvVar

+ HostNetwork bool

+ Image string

+ ImagePullPolicy string

+ ImageTag string

+ LivenessProbe *corev1.Probe

+ NodeSelector map[string]string

+ Ports []corev1.ContainerPort

+ ReadinessProbe *corev1.Probe

+ Resources common.Resources

+ VolumeMounts []corev1.VolumeMount

+ Volumes []corev1.Volume

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL