qos

type IOTag string

type IOTagConfig struct {
	Tag         string
	Weight      *float64
	LimitOps    *float64
	ReservedOps *float64
	Prohibited  bool
}

type Limiter interface {
	ReadRequest(context.Context) (ReleaseFunc, error)
	WriteRequest(context.Context) (ReleaseFunc, error)
	SetParentID(string)
	SetMetrics(Metrics)
	Close()
}

type LimiterConfig struct {
	Read  OpConfig
	Write OpConfig
}

type Metrics interface {
	SetOperationTagCounters(shardID, operation, tag string, pending, inProgress, completed, resourceExhausted uint64)
	Close(shardID string)
}

type OpConfig struct {
	MaxWaitingOps int64
	MaxRunningOps int64
	IdleTimeout   time.Duration
	Tags          []IOTagConfig
}

type ReleaseFunc scheduling.ReleaseFunc