qos

type Config struct {
	DiskBandwidthMBPS int64           `json:"disk_bandwidth_MBPS"`
	DiskIOPS          int64           `json:"disk_iops"`
	LevelConfigs      LevelConfig     `json:"flow_conf"`
	DiskViewer        iostat.IOViewer `json:"-"`
	StatGetter        flow.StatGetter `json:"-"`
}

type IOQos struct {
	LevelMgr LevelGetter     // Identify: a level qos controller
	StatMgr  flow.StatGetter // Identify: a io flow
}

type LevelConfig map[string]ParaConfig

type LevelGetter interface {
	GetLevel(priority.Priority) LevelQos
}

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

type LevelQos interface {
	Writer(ctx context.Context, underlying io.Writer) io.Writer
	WriterAt(ctx context.Context, underlying io.WriterAt) io.WriterAt
	Reader(ctx context.Context, underlying io.Reader) io.Reader
	ReaderAt(ctx context.Context, underlying io.ReaderAt) io.ReaderAt
	ChangeLevelQos(level string, conf Config)
}

type ParaConfig struct {
	Iops      int64   `json:"iops"`
	Bandwidth int64   `json:"bandwidth_MBPS"`
	Factor    float64 `json:"factor"`
}

type Qos interface {
	ReaderAt(context.Context, bnapi.IOType, io.ReaderAt) io.ReaderAt
	WriterAt(context.Context, bnapi.IOType, io.WriterAt) io.WriterAt
	Writer(context.Context, bnapi.IOType, io.Writer) io.Writer
	Reader(context.Context, bnapi.IOType, io.Reader) io.Reader
	GetLevelMgr() LevelGetter
}

type Threshold struct {
	sync.RWMutex
	ParaConfig
	DiskBandwidth int64
	DiskIOPS      int64
}