alluxio

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 5, 2020 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source
const (
	CSI_DRIVER = "fuse.csi.fluid.io"

	ALLUXIO_MOUNT = "/alluxio-mnt"
)

Variables

This section is empty.

Functions

func Build

* * build the Alluxio Engine

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 ImageInfo

type ImageInfo struct {
	Image           string `yaml:"image"`
	ImageTag        string `yaml:"imageTag"`
	ImagePullPolicy string `yaml:"imagePullPolicy"`
}

type Journal

type Journal struct {
	VolumeType string `yaml:"volumeType,omitempty"`
	Size       string `yaml:"size,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 Metastore

type Metastore struct {
	VolumeType string `yaml:"volumeType,omitempty"`
	Size       string `yaml:"size,omitempty"`
}

type ShortCircuit

type ShortCircuit struct {
	Enable     bool   `yaml:"enable,omitempty"`
	Policy     string `yaml:"policy,omitempty"`
	VolumeType string `yaml:"volumeType,omitempty"`
}

type Tieredstore

type Tieredstore struct {
	Levels []Level `yaml:"levels,omitempty"`
}

type UserInfo

type UserInfo struct {
	User    int `yaml:"user"`
	Group   int `yaml:"group"`
	FSGroup int `yaml:"fsGroup"`
}

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"`
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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