jindofsx

type Fuse struct {
	Args           []string            `json:"args"`
	HostPath       string              `json:"hostPath"`
	NodeSelector   map[string]string   `json:"nodeSelector,omitempty"`
	FuseProperties map[string]string   `json:"properties"`
	Global         bool                `json:"global,omitempty"`
	RunAs          string              `json:"runAs,omitempty"`
	Tolerations    []corev1.Toleration `json:"tolerations,omitempty"`
	Labels         map[string]string   `json:"labels,omitempty"`
	Annotations    map[string]string   `json:"annotations,omitempty"`
	CriticalPod    bool                `json:"criticalPod,omitempty"`
	Resources      Resources           `json:"resources,omitempty"`
	MountPath      string              `json:"mountPath,omitempty"`
	Mode           string              `json:"mode,omitempty"`
	Env            map[string]string   `json:"env,omitempty"`
	HostPID        bool                `json:"hostPID,omitempty"`
}

type HadoopConfig struct {
	ConfigMap       string `json:"configMap"`
	IncludeHdfsSite bool   `json:"includeHdfsSite"`
	IncludeCoreSite bool   `json:"includeCoreSite"`
}

type Jindo struct {
	Image               string                 `json:"image"`
	ImageTag            string                 `json:"imageTag"`
	ImagePullPolicy     string                 `json:"imagePullPolicy"`
	FuseImage           string                 `json:"fuseImage"`
	FuseImageTag        string                 `json:"fuseImageTag"`
	FuseImagePullPolicy string                 `json:"fuseImagePullPolicy"`
	User                int                    `json:"user"`
	Group               int                    `json:"group"`
	UseHostNetwork      bool                   `json:"useHostNetwork"`
	Properties          map[string]string      `json:"properties"`
	Master              Master                 `json:"master"`
	Worker              Worker                 `json:"worker"`
	Fuse                Fuse                   `json:"fuse"`
	Mounts              Mounts                 `json:"mounts"`
	HadoopConfig        HadoopConfig           `json:"hadoopConfig,omitempty"`
	Secret              string                 `json:"secret,omitempty"`
	Tolerations         []corev1.Toleration    `json:"tolerations,omitempty"`
	InitPortCheck       common.InitPortCheck   `json:"initPortCheck,omitempty"`
	LogConfig           map[string]string      `json:"logConfig,omitempty"`
	FuseLogConfig       map[string]string      `json:"fuseLogConfig,omitempty"`
	PlacementMode       string                 `json:"placement,omitempty"`
	Owner               *common.OwnerReference `json:"owner,omitempty"`
	RuntimeIdentity     common.RuntimeIdentity `json:"runtimeIdentity"`
	ClusterDomain       string                 `json:"clusterDomain,omitempty"`
	UFSVolumes          []UFSVolume            `json:"ufsVolumes,omitempty"`
	SecretKey           string                 `json:"secretKey,omitempty"`
	SecretValue         string                 `json:"secretValue,omitempty"`
	UseStsToken         bool                   `json:"UseStsToken"`
	MountType           string                 `json:"mountType,omitempty"`
}

type JindoFSxEngine struct {
	Log logr.Logger
	client.Client

	MetadataSyncDoneCh chan base.MetadataSyncResult

	Recorder record.EventRecorder
	*ctrl.Helper
	// contains filtered or unexported fields
}

type Level struct {
	Path       string `json:"path,omitempty"`
	Type       string `json:"type,omitempty"`
	MediumType string `json:"mediumType,omitempty"`
	Quota      string `json:"quota,omitempty"`
}

type Master struct {
	ReplicaCount        int                  `json:"replicaCount"`
	Resources           Resources            `json:"resources"`
	NodeSelector        map[string]string    `json:"nodeSelector,omitempty"`
	MasterProperties    map[string]string    `json:"properties"`
	FileStoreProperties map[string]string    `json:"fileStoreProperties"`
	TokenProperties     map[string]string    `json:"secretProperties"`
	Port                Ports                `json:"ports,omitempty"`
	OssKey              string               `json:"osskey,omitempty"`
	OssSecret           string               `json:"osssecret,omitempty"`
	Tolerations         []corev1.Toleration  `json:"tolerations,omitempty"`
	DnsServer           string               `json:"dnsServer,omitempty"`
	NameSpace           string               `json:"namespace,omitempty"`
	Labels              map[string]string    `json:"labels,omitempty"`
	Annotations         map[string]string    `json:"annotations,omitempty"`
	ServiceCount        int                  `json:"svccount"`
	Env                 map[string]string    `json:"env,omitempty"`
	VolumeMounts        []corev1.VolumeMount `json:"volumeMounts,omitempty"`
	Volumes             []corev1.Volume      `json:"volumes,omitempty"`
}

type Mounts struct {
	Master            map[string]*Level `json:"master"`
	WorkersAndClients map[string]*Level `json:"workersAndClients"`
}

type Ports struct {
	Rpc  int `json:"rpc,omitempty"`
	Raft int `json:"raft,omitempty"`
}

type Resource struct {
	CPU    string `json:"cpu"`
	Memory string `json:"memory"`
}

type Resources struct {
	Limits   Resource `json:"limits"`
	Requests Resource `json:"requests"`
}

type UFSVolume struct {
	Name          string `json:"name"`
	SubPath       string `json:"subPath,omitempty"`
	ContainerPath string `json:"containerPath"`
	ReadOnly      bool   `json:"readOnly"`
}

type Worker struct {
	ReplicaCount     int                 `json:"replicaCount"`
	Resources        Resources           `json:"resources,omitempty"`
	NodeSelector     map[string]string   `json:"nodeSelector,omitempty"`
	WorkerProperties map[string]string   `json:"properties"`
	Port             Ports               `json:"ports,omitempty"`
	Tolerations      []corev1.Toleration `json:"tolerations,omitempty"`
	// Affinity         corev1.Affinity       `json:"affinity,omitempty"`
	Labels      map[string]string `json:"labels,omitempty"`
	Annotations map[string]string `json:"annotations,omitempty"`
	Path        string            `json:"dataPath"`
	Env         map[string]string `json:"env,omitempty"`
}