pool

type ArrayPooler interface {
	Pooler
	GetTargets(ctx context.Context) (san.Targets, error)
	CreateDisk(ctx context.Context, name string, size int64, nodenames []string) ([]Disk, error)
	DeleteDisk(ctx context.Context, name, wwid string) ([]Disk, error)
}

type BlkTranslater interface {
	BlkTranslate(name string, size int64, shared bool) ([]string, error)
}

type By func(p1, p2 *StatusItem) bool

type Capabilities []Capability

type Capability string

type Config interface {
	Eval(key.T) (any, error)
	GetInt(key.T) int
	GetString(key.T) string
	GetStringAs(key.T, string) string
	GetStringStrict(key.T) (string, error)
	GetStrings(key.T) []string
	GetBool(k key.T) bool
	GetSize(k key.T) *int64
	HasSectionString(s string) bool
}

type Data[T Dataer] struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type DataElement[T Dataer] struct {
	Name  string
	Node  string
	Value *T
}

type Dataer interface {
	Status
}

type Disk struct {
	// ID is the created disk wwid
	ID string

	// Paths is the subset of requested san path actually setup for this disk
	Paths san.Paths

	// Driver is a driver-specific dataset
	Driver any
}

type Lookup struct {
	Name     string
	Type     string
	Access   volaccess.T
	Size     int64
	Format   bool
	Shared   bool
	Usage    bool
	Volatile bool
	Nodes    []string
	// contains filtered or unexported fields
}

type Pooler interface {
	SetName(string)
	SetDriver(string)
	Name() string
	Type() string
	Head() string
	Mappings() map[string]string
	Capabilities() Capabilities
	Usage(context.Context) (Usage, error)
	SetConfig(Config)
	Config() Config
	Separator() string
}

type Status struct {
	Usage
	Capabilities Capabilities `json:"capabilities"`
	Errors       []string     `json:"errors"`
	Head         string       `json:"head"`
	Type         string       `json:"type"`
	UpdatedAt    time.Time    `json:"updated_at"`
	VolumeCount  int          `json:"volume_count"`
}

type StatusItem struct {
	Status
	Name string `json:"name"`
}

type StatusList []StatusItem

type T struct {
	// contains filtered or unexported fields
}

type Translater interface {
	Translate(name string, size int64, shared bool) ([]string, error)
}

type Usage struct {
	Shared bool `json:"shared"`
	// Free unit is Bytes
	Free int64 `json:"free"`
	// Used unit is Bytes
	Used int64 `json:"used"`
	// Size unit is Bytes
	Size int64 `json:"size"`
}

type VolumeStatus struct {
	Pool     string       `json:"pool"`
	Path     naming.Path  `json:"path"`
	Children naming.Paths `json:"children"`
	IsOrphan bool         `json:"is_orphan"`
	Size     int64        `json:"size"`
}

type VolumeStatusList []VolumeStatus

type Volumer interface {
	FQDN() string
	Config() *xconfig.T
}

type WeightedPools []Pooler