storageclass

Documentation

Index

• Constants
• Variables
• func DefaultParityBlocks(drive int) int
• func Enabled(kvs config.KVS) bool
• func IsValid(sc string) bool
• func SetStorageClass(s config.Config, cfg Config)
• func ValidateParity(ssParity, setDriveCount int) error
• type Config
  • func LookupConfig(kvs config.KVS, setDriveCount int) (cfg Config, err error)
  • func (sCfg Config) GetParityForSC(sc string) (parity int)
  • func (sCfg *Config) UnmarshalJSON(data []byte) error
  • func (sCfg *Config) Update(newCfg Config)
• type StorageClass
  • func (sc *StorageClass) MarshalText() ([]byte, error)
  • func (sc *StorageClass) String() string
  • func (sc *StorageClass) UnmarshalText(b []byte) error

Constants

const (
	// Reduced redundancy storage class
	RRS = "REDUCED_REDUNDANCY"
	// Standard storage class
	STANDARD = "STANDARD"
)

Standard constants for all storage class

const (
	ClassStandard = "standard"
	ClassRRS      = "rrs"

	// Reduced redundancy storage class environment variable
	RRSEnv = "MINIO_STORAGE_CLASS_RRS"
	// Standard storage class environment variable
	StandardEnv = "MINIO_STORAGE_CLASS_STANDARD"
)

Standard constats for config info storage class

Variables

var ConfigLock sync.RWMutex

ConfigLock is a global lock for storage-class config

var (
	DefaultKVS = config.KVS{
		config.KV{
			Key:   ClassStandard,
			Value: "",
		},
		config.KV{
			Key:   ClassRRS,
			Value: "EC:1",
		},
	}
)

DefaultKVS - default storage class config

var (
	Help = config.HelpKVS{
		config.HelpKV{
			Key:         ClassStandard,
			Description: `set the parity count for default standard storage class` + defaultHelpPostfix(ClassStandard),
			Optional:    true,
			Type:        "string",
		},
		config.HelpKV{
			Key:         ClassRRS,
			Description: `set the parity count for reduced redundancy storage class` + defaultHelpPostfix(ClassRRS),
			Optional:    true,
			Type:        "string",
		},
		config.HelpKV{
			Key:         config.Comment,
			Description: config.DefaultComment,
			Optional:    true,
			Type:        "sentence",
		},
	}
)

Help template for storageclass feature.

Functions

func DefaultParityBlocks

func DefaultParityBlocks(drive int) int

DefaultParityBlocks returns default parity blocks for 'drive' count

func Enabled

func Enabled(kvs config.KVS) bool

Enabled returns if storageClass is enabled is enabled.

func IsValid

func IsValid(sc string) bool

IsValid - returns true if input string is a valid storage class kind supported.

func SetStorageClass

func SetStorageClass(s config.Config, cfg Config)

SetStorageClass - One time migration code needed, for migrating from older config to new for StorageClass.

func ValidateParity

func ValidateParity(ssParity, setDriveCount int) error

ValidateParity validate standard storage class parity.

Types

type Config

type Config struct {
	Standard StorageClass `json:"standard"`
	RRS      StorageClass `json:"rrs"`
	// contains filtered or unexported fields
}

Config storage class configuration

func LookupConfig

func LookupConfig(kvs config.KVS, setDriveCount int) (cfg Config, err error)

LookupConfig - lookup storage class config and override with valid environment settings if any.

func (Config) GetParityForSC

func (sCfg Config) GetParityForSC(sc string) (parity int)

GetParityForSC - Returns the data and parity drive count based on storage class If storage class is set using the env vars MINIO_STORAGE_CLASS_RRS and MINIO_STORAGE_CLASS_STANDARD or server config fields corresponding values are returned.

-- if input storage class is empty then standard is assumed

-- if input is RRS but RRS is not configured/initialized '-1' parity

for RRS is assumed, the caller is expected to choose the right parity
at that point.

-- if input is STANDARD but STANDARD is not configured/initialized '-1' parity

is returned, the caller is expected to choose the right parity
at that point.

func (*Config) UnmarshalJSON

func (sCfg *Config) UnmarshalJSON(data []byte) error

UnmarshalJSON - Validate SS and RRS parity when unmarshalling JSON.

func (*Config) Update

func (sCfg *Config) Update(newCfg Config)

Update update storage-class with new config

type StorageClass

type StorageClass struct {
	Parity int
}

StorageClass - holds storage class information

func (*StorageClass) MarshalText

func (sc *StorageClass) MarshalText() ([]byte, error)

MarshalText - marshals storage class string.

func (*StorageClass) String

func (sc *StorageClass) String() string

func (*StorageClass) UnmarshalText

func (sc *StorageClass) UnmarshalText(b []byte) error

UnmarshalText unmarshals storage class from its textual form into storageClass structure.