base

Jul 10, 2025

Changes in this version

type Fuse

+ Name string

type RuntimeInfo

+ func (info *RuntimeInfo) GetFuseName() string

+ func (info *RuntimeInfo) SetFuseName(fuseName string)

type RuntimeInfoInterface

+ GetFuseName func() string

+ SetFuseName func(fuseName string)

Feb 24, 2025

Changes in this version

type Conventions

+ GetExclusiveLabelValue func() string

type RuntimeInfo

+ func (info *RuntimeInfo) GetExclusiveLabelValue() string

+ func (info *RuntimeInfo) GetOwnerDatasetUID() string

+ func (info *RuntimeInfo) SetOwnerDatasetUID(datasetUID types.UID)

type RuntimeInfoInterface

+ GetOwnerDatasetUID func() string

+ SetOwnerDatasetUID func(alias types.UID)

Oct 17, 2024

Changes in this version

+ const MountModeSelectAll

+ const MountModeSelectNone

+ var SupportedMountModes = []MountMode

+ func ParseMountModeSelectorFromStr(mountModeStr string) (mountModeSelector, error)

+ type Conventions interface

+ GetCommonLabelName func() string

+ GetDatasetNumLabelName func() string

+ GetFuseLabelName func() string

+ GetLabelNameForDisk func() string

+ GetLabelNameForMemory func() string

+ GetLabelNameForTotal func() string

+ GetPersistentVolumeName func() string

+ GetRuntimeLabelName func() string

+ GetWorkerStatefulsetName func() string

type Fuse

+ MetricsScrapeTarget mountModeSelector

+ type MountMode string

+ const MountPodMountMode

+ const SidecarMountMode

type RuntimeInfo

+ func (info *RuntimeInfo) GetAnnotations() map[string]string

+ func (info *RuntimeInfo) GetFuseMetricsScrapeTarget() mountModeSelector

+ func (info *RuntimeInfo) GetWorkerStatefulsetName() string

type RuntimeInfoInterface

+ GetAnnotations func() map[string]string

+ GetFuseMetricsScrapeTarget func() mountModeSelector

type RuntimeInfoOption

+ func WithAnnotations(annotations map[string]string) RuntimeInfoOption

+ func WithClientMetrics(clientMetrics datav1alpha1.ClientMetrics) RuntimeInfoOption

+ func WithTieredStore(tieredStore datav1alpha1.TieredStore) RuntimeInfoOption

Aug 28, 2024

Changes in this version

type Engine

+ Validate func(ctx cruntime.ReconcileRequestContext) (err error)

type Implement

+ Validate func(ctx cruntime.ReconcileRequestContext) (err error)

type TemplateEngine

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

Jul 10, 2024

Changes in this version

type RuntimeInfo

+ func (info *RuntimeInfo) GetFuseNodeSelector() (nodeSelector map[string]string)

+ func (info *RuntimeInfo) SetFuseNodeSelector(nodeSelector map[string]string)

type RuntimeInfoInterface

+ GetFuseNodeSelector func() (nodeSelector map[string]string)

+ SetFuseNodeSelector func(nodeSelector map[string]string)

Apr 18, 2024

Changes in this version

+ func GetPhysicalDatasetFromMounts(mounts []datav1alpha1.Mount) []types.NamespacedName

+ func GetPhysicalDatasetSubPath(virtualDataset *datav1alpha1.Dataset) []string

type RuntimeInfo

+ func (info *RuntimeInfo) GetFuseContainerTemplate() (template *common.FuseInjectionTemplate, err error)

type RuntimeInfoInterface

+ GetFuseContainerTemplate func() (template *common.FuseInjectionTemplate, err error)

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

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

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

+ func CheckReferenceDataset(dataset *datav1alpha1.Dataset) (check bool, err error)

+ func GetDataOperationKey(object client.Object) string

+ func GetDatasetRefName(name, namespace string) string

+ func GetMetadataListFromAnnotation(accessor metav1.ObjectMetaAccessor) (ret []datav1alpha1.Metadata)

+ func GetMountedDatasetNamespacedName(virtualDataset *datav1alpha1.Dataset) []types.NamespacedName

+ func GetMountedDatasetSubPath(virtualDataset *datav1alpha1.Dataset) []string

+ func GetRuntimeAndType(client client.Client, boundedRuntime *datav1alpha1.Runtime) (runtime client.Object, runtimeType string, err error)

+ func GetRuntimeStatus(client client.Client, runtimeType, name, namespace string) (status *datav1alpha1.RuntimeStatus, err error)

+ func InstallDataOperationHelmIfNotExist(ctx cruntime.ReconcileRequestContext, object client.Object, ...) (err error)

+ func RecordDatasetMetrics(result MetadataSyncResult, datasetNamespace, datasetName string, ...)

+ func ReleaseTargetDataset(ctx cruntime.ReconcileRequestContext, object client.Object, ...) error

+ func SafeClose(ch chan MetadataSyncResult) (closed bool)

+ func SafeSend(ch chan MetadataSyncResult, result MetadataSyncResult) (closed bool)

+ func SetDataOperationInTargetDataset(ctx cruntime.ReconcileRequestContext, object client.Object, ...) error

+ type DataOperator interface

+ Operate func(ctx cruntime.ReconcileRequestContext, object client.Object, ...) (ctrl.Result, error)

+ type DataOperatorYamlGenerator interface

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

+ type Databackuper interface

+ BackupData func(ctx cruntime.ReconcileRequestContext, targetDataBackup datav1alpha1.DataBackup) (ctrl.Result, error)

+ type Datamigrater interface

+ MigrateData func(ctx cruntime.ReconcileRequestContext, ...) (err error)

type Implement

+ CreateDataMigrateJob func(ctx cruntime.ReconcileRequestContext, ...) error

type Level

+ VolumeSource datav1alpha1.VolumeSource

+ type MetadataSyncResult struct

+ Done bool

+ Err error

+ FileNum string

+ StartTime time.Time

+ UfsTotal string

type RuntimeInfo

+ func (info *RuntimeInfo) GetMetadataList() []datav1alpha1.Metadata

type RuntimeInfoInterface

+ GetMetadataList func() []datav1alpha1.Metadata

+ type RuntimeInfoOption func(info *RuntimeInfo)

+ func WithMetadataList(metadataList []datav1alpha1.Metadata) RuntimeInfoOption

type TemplateEngine

+ func (t *TemplateEngine) MigrateData(ctx cruntime.ReconcileRequestContext, ...) (err error)

+ func (t *TemplateEngine) Operate(ctx cruntime.ReconcileRequestContext, object client.Object, ...) (ctrl.Result, error)

Jul 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

May 8, 2023 GO-2024-2644

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

Mar 27, 2023 GO-2023-1763 +1 more

  GO-2023-1763: On a compromised node, the fluid-csi service account can be used to modify node specs in github.com/fluid-cloudnative/fluid

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

Feb 18, 2023 GO-2023-1763 +1 more

  GO-2023-1763: On a compromised node, the fluid-csi service account can be used to modify node specs in github.com/fluid-cloudnative/fluid

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

Jan 7, 2023 GO-2023-1763 +1 more

  GO-2023-1763: On a compromised node, the fluid-csi service account can be used to modify node specs in github.com/fluid-cloudnative/fluid

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

Nov 8, 2022 GO-2023-1763 +1 more

  GO-2023-1763: On a compromised node, the fluid-csi service account can be used to modify node specs in github.com/fluid-cloudnative/fluid

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

Oct 3, 2022 GO-2023-1763 +1 more

  GO-2023-1763: On a compromised node, the fluid-csi service account can be used to modify node specs in github.com/fluid-cloudnative/fluid

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

Sep 3, 2022 GO-2023-1763 +1 more

  GO-2023-1763: On a compromised node, the fluid-csi service account can be used to modify node specs in github.com/fluid-cloudnative/fluid

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

Changes in this version

type Implement

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

type Level

+ VolumeType common.VolumeType

Mar 2, 2022 GO-2023-1763 +1 more

  GO-2023-1763: On a compromised node, the fluid-csi service account can be used to modify node specs in github.com/fluid-cloudnative/fluid

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

Changes in this version

type Fuse

+ CleanPolicy datav1alpha1.FuseCleanPolicy

type Implement

+ SyncScheduleInfoToCacheNodes func() (err error)

type RuntimeInfo

+ func (info *RuntimeInfo) GetFuseCleanPolicy() datav1alpha1.FuseCleanPolicy

+ func (info *RuntimeInfo) GetFuseLabelName() string

+ func (info *RuntimeInfo) GetTemplateToInjectForFuse(pvcName string, enableCacheDir bool) (template *common.FuseInjectionTemplate, err error)

+ func (info *RuntimeInfo) SetClient(client client.Client)

+ func (info *RuntimeInfo) SetupFuseCleanPolicy(policy datav1alpha1.FuseCleanPolicy)

type RuntimeInfoInterface

+ GetFuseCleanPolicy func() datav1alpha1.FuseCleanPolicy

+ GetFuseLabelName func() string

+ GetTemplateToInjectForFuse func(pvcName string, enableCache bool) (*common.FuseInjectionTemplate, error)

+ SetClient func(client client.Client)

+ SetupFuseCleanPolicy func(policy datav1alpha1.FuseCleanPolicy)

+ type RuntimeInterface interface

+ GetStatus func() *datav1alpha1.RuntimeStatus

+ Replicas func() int32

Aug 11, 2021 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

+ type Dataloader interface

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

+ CheckRuntimeReady func() (ready bool)

+ LoadData func(ctx cruntime.ReconcileRequestContext, targetDataload datav1alpha1.DataLoad) (err error)

type Implement

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

+ CheckRuntimeReady func() (ready bool)

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

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

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

type RuntimeInfo

+ func (info *RuntimeInfo) GetCommonLabelName() string

+ func (info *RuntimeInfo) GetDatasetNumLabelName() string

+ func (info *RuntimeInfo) GetLabelNameForDisk() string

+ func (info *RuntimeInfo) GetLabelNameForMemory() string

+ func (info *RuntimeInfo) GetLabelNameForTotal() string

+ func (info *RuntimeInfo) GetPersistentVolumeName() string

+ func (info *RuntimeInfo) GetRuntimeLabelName() string

+ func (info *RuntimeInfo) GetTieredStoreInfo() TieredStoreInfo

+ func (info *RuntimeInfo) IsDeprecatedNodeLabel() bool

+ func (info *RuntimeInfo) IsDeprecatedPVName() bool

+ func (info *RuntimeInfo) SetDeprecatedNodeLabel(deprecated bool)

+ func (info *RuntimeInfo) SetDeprecatedPVName(deprecated bool)

type RuntimeInfoInterface

+ func GetRuntimeInfo(client client.Client, name, namespace string) (RuntimeInfoInterface, error)

+ GetCommonLabelName func() string

+ GetDatasetNumLabelName func() string

+ GetLabelNameForDisk func() string

+ GetLabelNameForMemory func() string

+ GetLabelNameForTotal func() string

+ GetPersistentVolumeName func() string

+ GetRuntimeLabelName func() string

+ GetTieredStoreInfo func() TieredStoreInfo

+ IsDeprecatedNodeLabel func() bool

+ IsDeprecatedPVName func() bool

+ SetDeprecatedNodeLabel func(deprecated bool)

+ SetDeprecatedPVName func(deprecated bool)

type TemplateEngine

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

+ func (t *TemplateEngine) CheckRuntimeReady() (ready bool)

+ func (t *TemplateEngine) LoadData(ctx cruntime.ReconcileRequestContext, targetDataload datav1alpha1.DataLoad) (err error)

+ type TieredStoreInfo struct

+ Levels []Level

Mar 16, 2021 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

+ type CachePath struct

+ Path string

+ Quota *resource.Quantity

+ type Fuse struct

+ Global bool

+ NodeSelector map[string]string

type Implement

+ BindToDataset func() (err error)

+ type Level struct

+ CachePaths []CachePath

+ High string

+ Low string

+ MediumType common.MediumType

+ type RuntimeInfo struct

+ func (info *RuntimeInfo) GetCommonLabelname() string

+ func (info *RuntimeInfo) GetFuseDeployMode() (global bool, nodeSelector map[string]string)

+ func (info *RuntimeInfo) GetName() string

+ func (info *RuntimeInfo) GetNamespace() string

+ func (info *RuntimeInfo) GetRuntimeLabelname() string

+ func (info *RuntimeInfo) GetRuntimeType() string

+ func (info *RuntimeInfo) GetStoragetLabelname(read common.ReadType, storage common.StorageType) string

+ func (info *RuntimeInfo) GetTieredstoreInfo() TieredstoreInfo

+ func (info *RuntimeInfo) IsExclusive() bool

+ func (info *RuntimeInfo) SetupFuseDeployMode(global bool, nodeSelector map[string]string)

+ func (info *RuntimeInfo) SetupWithDataset(dataset *datav1alpha1.Dataset)

+ type RuntimeInfoInterface interface

+ GetCommonLabelname func() string

+ GetFuseDeployMode func() (global bool, nodeSelector map[string]string)

+ GetName func() string

+ GetNamespace func() string

+ GetRuntimeLabelname func() string

+ GetRuntimeType func() string

+ GetStoragetLabelname func(read common.ReadType, storage common.StorageType) string

+ GetTieredstoreInfo func() TieredstoreInfo

+ IsExclusive func() bool

+ SetupFuseDeployMode func(global bool, nodeSelector map[string]string)

+ SetupWithDataset func(dataset *datav1alpha1.Dataset)

+ func BuildRuntimeInfo(name string, namespace string, runtimeType string, ...) (runtime RuntimeInfoInterface, err error)

+ type TieredstoreInfo struct

+ Levels []Level

Nov 6, 2020 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

type Implement

+ SyncMetadata func() (err error)

Oct 1, 2020 GO-2024-2644

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

Sep 5, 2020 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

+ type Engine interface

+ CreateVolume func() (err error)

+ DeleteVolume func() (err error)

+ ID func() string

+ Setup func(ctx cruntime.ReconcileRequestContext) (ready bool, err error)

+ Shutdown func() error

+ Sync func(ctx cruntime.ReconcileRequestContext) error

+ type Implement interface

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

+ CheckAndUpdateRuntimeStatus func() (ready bool, err error)

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

+ CheckRuntimeHealthy func() (err error)

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

+ CreateVolume func() error

+ DeleteVolume func() (err error)

+ IsSetupDone func() (done bool, err error)

+ PrepareUFS func() (err error)

+ SetupMaster func() (err error)

+ SetupWorkers func() (err error)

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

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

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

+ Shutdown func() error

+ SyncReplicas func(ctx cruntime.ReconcileRequestContext) error

+ UpdateCacheOfDataset func() (err error)

+ UpdateDatasetStatus func(phase datav1alpha1.DatasetPhase) (err error)

+ type TemplateEngine struct

+ Context cruntime.ReconcileRequestContext

+ Id string

+ Log logr.Logger

+ func NewTemplateEngine(impl Implement, id string, context cruntime.ReconcileRequestContext) *TemplateEngine

+ func (b *TemplateEngine) Setup(ctx cruntime.ReconcileRequestContext) (ready bool, err error)

+ func (t *TemplateEngine) CreateVolume() (err error)

+ func (t *TemplateEngine) DeleteVolume() (err error)

+ func (t *TemplateEngine) ID() string

+ func (t *TemplateEngine) Shutdown() error

+ func (t *TemplateEngine) Sync(ctx cruntime.ReconcileRequestContext) (err error)

+ type UnderFileSystemService interface

+ FreeStorageBytes func() (int64, error)

+ TotalFileNums func() (int64, error)

+ TotalStorageBytes func() (int64, error)

+ UsedStorageBytes func() (int64, error)