Documentation
¶
Index ¶
- Constants
- func Build(id string, ctx cruntime.ReconcileRequestContext) (base.Engine, error)
- type Alluxio
- type AlluxioEngine
- func (e *AlluxioEngine) AssignNodesToCache(desiredNum int32) (currentScheduleNum int32, err error)
- func (e *AlluxioEngine) CheckAndUpdateRuntimeStatus() (ready bool, err error)
- func (e *AlluxioEngine) CheckMasterReady() (ready bool, err error)
- func (e *AlluxioEngine) CheckRuntimeHealthy() (err error)
- func (e *AlluxioEngine) CheckWorkersReady() (ready bool, err error)
- func (e *AlluxioEngine) CreateVolume() (err error)
- func (e *AlluxioEngine) DeleteVolume() (err error)
- func (e *AlluxioEngine) FreeStorageBytes() (value int64, err error)
- func (e *AlluxioEngine) IsSetupDone() (done bool, err error)
- func (e *AlluxioEngine) PrepareUFS() (err error)
- func (e *AlluxioEngine) SetupMaster() (err error)
- func (e *AlluxioEngine) SetupWorkers() (err error)
- func (e *AlluxioEngine) ShouldCheckUFS() (should bool, err error)
- func (e *AlluxioEngine) ShouldSetupMaster() (should bool, err error)
- func (e *AlluxioEngine) ShouldSetupWorkers() (should bool, err error)
- func (e *AlluxioEngine) Shutdown() (err error)
- func (e *AlluxioEngine) SyncReplicas(ctx cruntime.ReconcileRequestContext) (err error)
- func (e *AlluxioEngine) TotalFileNums() (value int64, err error)
- func (e *AlluxioEngine) TotalStorageBytes() (value int64, err error)
- func (e *AlluxioEngine) UpdateCacheOfDataset() (err error)
- func (e *AlluxioEngine) UpdateDatasetStatus(phase datav1alpha1.DatasetPhase) (err error)
- func (e *AlluxioEngine) UsedStorageBytes() (value int64, err error)
- type Fuse
- type ImageInfo
- type Journal
- type Level
- type Master
- type Metastore
- type ShortCircuit
- type Tieredstore
- type UserInfo
- type Worker
Constants ¶
View Source
const ( CSI_DRIVER = "fuse.csi.fluid.io" ALLUXIO_MOUNT = "/alluxio-mnt" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Alluxio ¶
type Alluxio struct {
FullnameOverride string `yaml:"fullnameOverride"`
ImageInfo `yaml:",inline"`
UserInfo `yaml:",inline"`
NodeSelector map[string]string `yaml:"nodeSelector,omitempty"`
JvmOptions []string `yaml:"jvmOptions,omitempty"`
Properties map[string]string `yaml:"properties,omitempty"`
Master Master `yaml:"master,omitempty"`
Worker Worker `yaml:"worker,omitempty"`
Fuse Fuse `yaml:"fuse,omitempty"`
Tieredstore Tieredstore `yaml:"tieredstore,omitempty"`
Metastore Metastore `yaml:"metastore,omitempty"`
Journal Journal `yaml:"journal,omitempty"`
ShortCircuit ShortCircuit `yaml:"shortCircuit,omitempty"`
}
The value yaml file
type AlluxioEngine ¶
type AlluxioEngine struct {
Log logr.Logger
client.Client
// contains filtered or unexported fields
}
* * Alluxio Engine implements the Engine interface
func (*AlluxioEngine) AssignNodesToCache ¶
func (e *AlluxioEngine) AssignNodesToCache(desiredNum int32) (currentScheduleNum int32, err error)
AssignNodesToCache finds nodes
func (*AlluxioEngine) CheckAndUpdateRuntimeStatus ¶
func (e *AlluxioEngine) CheckAndUpdateRuntimeStatus() (ready bool, err error)
init the status of the engine when it's ready
func (*AlluxioEngine) CheckMasterReady ¶
func (e *AlluxioEngine) CheckMasterReady() (ready bool, err error)
Is the master ready
func (*AlluxioEngine) CheckRuntimeHealthy ¶
func (e *AlluxioEngine) CheckRuntimeHealthy() (err error)
CheckRuntimeHealthy checks the healthy of the runtime
func (*AlluxioEngine) CheckWorkersReady ¶
func (e *AlluxioEngine) CheckWorkersReady() (ready bool, err error)
are the workers ready
func (*AlluxioEngine) CreateVolume ¶
func (e *AlluxioEngine) CreateVolume() (err error)
CreateVolume creates volume
func (*AlluxioEngine) DeleteVolume ¶
func (e *AlluxioEngine) DeleteVolume() (err error)
DeleteVolume creates volume
func (*AlluxioEngine) FreeStorageBytes ¶
func (e *AlluxioEngine) FreeStorageBytes() (value int64, err error)
func (*AlluxioEngine) IsSetupDone ¶
func (e *AlluxioEngine) IsSetupDone() (done bool, err error)
IsSetupDone checks the setup is done
func (*AlluxioEngine) PrepareUFS ¶
func (e *AlluxioEngine) PrepareUFS() (err error)
Prepare the mounts and metadata
func (*AlluxioEngine) SetupMaster ¶
func (e *AlluxioEngine) SetupMaster() (err error)
setup the cache master
func (*AlluxioEngine) SetupWorkers ¶
func (e *AlluxioEngine) SetupWorkers() (err error)
setup the cache worker
func (*AlluxioEngine) ShouldCheckUFS ¶
func (e *AlluxioEngine) ShouldCheckUFS() (should bool, err error)
ShouldCheckUFS checks if it requires checking UFS
func (*AlluxioEngine) ShouldSetupMaster ¶
func (e *AlluxioEngine) ShouldSetupMaster() (should bool, err error)
ShouldSetupMaster checks if we need setup the master
func (*AlluxioEngine) ShouldSetupWorkers ¶
func (e *AlluxioEngine) ShouldSetupWorkers() (should bool, err error)
ShouldSetupWorkers checks if we need setup the workers
func (*AlluxioEngine) Shutdown ¶
func (e *AlluxioEngine) Shutdown() (err error)
func (*AlluxioEngine) SyncReplicas ¶
func (e *AlluxioEngine) SyncReplicas(ctx cruntime.ReconcileRequestContext) (err error)
SyncReplicas syncs the replicas
func (*AlluxioEngine) TotalFileNums ¶
func (e *AlluxioEngine) TotalFileNums() (value int64, err error)
func (*AlluxioEngine) TotalStorageBytes ¶
func (e *AlluxioEngine) TotalStorageBytes() (value int64, err error)
func (*AlluxioEngine) UpdateCacheOfDataset ¶
func (e *AlluxioEngine) UpdateCacheOfDataset() (err error)
func (*AlluxioEngine) UpdateDatasetStatus ¶
func (e *AlluxioEngine) UpdateDatasetStatus(phase datav1alpha1.DatasetPhase) (err error)
Bind to the dataset
func (*AlluxioEngine) UsedStorageBytes ¶
func (e *AlluxioEngine) UsedStorageBytes() (value int64, err error)
type Fuse ¶
type Fuse struct {
Image string `yaml:"image,omitempty"`
NodeSelector map[string]string `yaml:"nodeSelector,omitempty"`
ImageTag string `yaml:"imageTag,omitempty"`
ImagePullPolicy string `yaml:"imagePullPolicy,omitempty"`
Properties map[string]string `yaml:"properties,omitempty"`
Env map[string]string `yaml:"env,omitempty"`
JvmOptions []string `yaml:"jvmOptions,omitempty"`
MountPath string `yaml:"mountPath,omitempty"`
ShortCircuitPolicy string `yaml:"shortCircuitPolicy,omitempty"`
Args []string `yaml:"args,omitempty"`
HostNetwork bool `yaml:"hostNetwork,omitempty"`
Enabled bool `yaml:"enabled,omitempty"`
Resources common.Resources `yaml:"resources,omitempty"`
}
type Level ¶
type Level struct {
Alias string `yaml:"alias,omitempty"`
Level int `yaml:"level"`
Mediumtype string `yaml:"mediumtype,omitempty"`
Type string `yaml:"type,omitempty"`
Path string `yaml:"path,omitempty"`
Quota string `yaml:"quota,omitempty"`
High string `yaml:"high,omitempty"`
Low string `yaml:"low,omitempty"`
}
type Master ¶
type Master struct {
JvmOptions []string `yaml:"jvmOptions,omitempty"`
Env map[string]string `yaml:"env,omitempty"`
NodeSelector map[string]string `yaml:"nodeSelector,omitempty"`
Properties map[string]string `yaml:"properties,omitempty"`
Replicas int32 `yaml:"replicaCount,omitempty"`
HostNetwork bool `yaml:"hostNetwork,omitempty"`
Resources common.Resources `yaml:"resources,omitempty"`
}
type ShortCircuit ¶
type Tieredstore ¶
type Tieredstore struct {
Levels []Level `yaml:"levels,omitempty"`
}
type Worker ¶
type Worker struct {
JvmOptions []string `yaml:"jvmOptions,omitempty"`
Env map[string]string `yaml:"env,omitempty"`
NodeSelector map[string]string `yaml:"nodeSelector,omitempty"`
Properties map[string]string `yaml:"properties,omitempty"`
HostNetwork bool `yaml:"hostNetwork,omitempty"`
Resources common.Resources `yaml:"resources,omitempty"`
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.