allocator

type BidMgr interface {
	Alloc(ctx context.Context, count uint64) (bidRange []BidRange, err error)
}

type BidRange struct {
	StartBid proto.BlobID
	EndBid   proto.BlobID
}

type BlobConfig struct {
	BidAllocNums uint64 `json:"bid_alloc_nums"`
}

type VolConfig struct {
	ClusterID             proto.ClusterID `json:"cluster_id"`
	Idc                   string          `json:"idc"`
	Host                  string          `json:"host"`
	RetainIntervalS       int64           `json:"retain_interval_s"`
	DefaultAllocVolsNum   int             `json:"default_alloc_vols_num"`
	InitVolumeNum         int             `json:"init_volume_num"`
	TotalThresholdRatio   float64         `json:"total_threshold_ratio"`
	MetricReportIntervalS int             `json:"metric_report_interval_s"`
	RetainVolumeBatchNum  int             `json:"retain_volume_batch_num"`
	RetainBatchIntervalS  int64           `json:"retain_batch_interval_s"`
	VolumeReserveSize     int             `json:"-"`
}

type VolumeMgr interface {
	// Alloc the required volumes to access module
	Alloc(ctx context.Context, args *proxy.AllocVolsArgs) (allocVols []proxy.AllocRet, err error)
	// List the volumes in the allocator
	List(ctx context.Context, codeMode codemode.CodeMode) (vids []proto.Vid, volumes []clustermgr.AllocVolumeInfo, err error)
	// Discard just used for proxy volume management, remove invalid volumes
	Discard(ctx context.Context, args *proxy.DiscardVolsArgs) error
	Close()
}