blobnode

type BadShard struct {
	DiskID proto.DiskID
	Vuid   proto.Vuid
	Bid    proto.BlobID
}

type ChangeChunkStatusArgs struct {
	DiskID proto.DiskID `json:"diskid"`
	Vuid   proto.Vuid   `json:"vuid"`
	Force  bool         `json:"force,omitempty"`
}

type ChunkId [ChunkIdLength]byte

type ChunkInfo struct {
	Id         ChunkId      `json:"id"`
	Vuid       proto.Vuid   `json:"vuid"`
	DiskID     proto.DiskID `json:"diskid"`
	Total      uint64       `json:"total"`  // ChunkSize
	Used       uint64       `json:"used"`   // user data size
	Free       uint64       `json:"free"`   // ChunkSize - Used
	Size       uint64       `json:"size"`   // Chunk File Size (logic size)
	Status     ChunkStatus  `json:"status"` // normal、readOnly
	Compacting bool         `json:"compacting"`
}

type ChunkInspectArgs struct {
	DiskID proto.DiskID `json:"diskid"`
	Vuid   proto.Vuid   `json:"vuid"`
}

type ChunkStatus uint8

type CompactChunkArgs struct {
	DiskID proto.DiskID `json:"diskid"`
	Vuid   proto.Vuid   `json:"vuid"`
}

type Config struct {
	rpc.Config
}

type ConfigReloadArgs struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type CreateChunkArgs struct {
	DiskID    proto.DiskID `json:"diskid"`
	Vuid      proto.Vuid   `json:"vuid"`
	ChunkSize int64        `json:"chunksize,omitempty"`
}

type DeleteShardArgs struct {
	DiskID proto.DiskID `json:"diskid"`
	Vuid   proto.Vuid   `json:"vuid"`
	Bid    proto.BlobID `json:"bid"`
}

type DiskHeartBeatInfo struct {
	DiskID       proto.DiskID `json:"disk_id"`
	Used         int64        `json:"used"`           // disk used space
	Free         int64        `json:"free"`           // remaining free space on the disk
	Size         int64        `json:"size"`           // total physical disk space
	MaxChunkCnt  int64        `json:"max_chunk_cnt"`  // note: maintained by clustermgr
	FreeChunkCnt int64        `json:"free_chunk_cnt"` // note: maintained by clustermgr
	UsedChunkCnt int64        `json:"used_chunk_cnt"` // current number of chunks on the disk
}

type DiskInfo struct {
	ClusterID    proto.ClusterID  `json:"cluster_id"`
	Idc          string           `json:"idc"`
	Rack         string           `json:"rack"`
	Host         string           `json:"host"`
	Path         string           `json:"path"`
	Status       proto.DiskStatus `json:"status"` // normal、broken、repairing、repaired、dropped
	Readonly     bool             `json:"readonly"`
	CreateAt     time.Time        `json:"create_time"`
	LastUpdateAt time.Time        `json:"last_update_time"`
	DiskHeartBeatInfo
}

type DiskProbeArgs struct {
	Path string `json:"path"`
}

type DiskStatArgs struct {
	DiskID proto.DiskID `json:"diskid"`
}

type GetShardArgs struct {
	DiskID proto.DiskID `json:"diskid"`
	Vuid   proto.Vuid   `json:"vuid"`
	Bid    proto.BlobID `json:"bid"`
	Type   IOType       `json:"iotype,omitempty"`
}

type IOType uint64

type InspectRateArgs struct {
	Rate int `json:"rate"`
}

type ListChunkArgs struct {
	DiskID proto.DiskID `json:"diskid"`
}

type ListChunkRet struct {
	ChunkInfos []*ChunkInfo `json:"chunk_infos"`
}

type ListShardsArgs struct {
	DiskID   proto.DiskID `json:"diskid"`
	Vuid     proto.Vuid   `json:"vuid" `
	StartBid proto.BlobID `json:"startbid"`
	Status   ShardStatus  `json:"status" `
	Count    int          `json:"count" `
}

type ListShardsRet struct {
	ShardInfos []*ShardInfo `json:"shard_infos"`
	Next       proto.BlobID `json:"next"`
}

type PutShardArgs struct {
	DiskID proto.DiskID `json:"diskid"`
	Vuid   proto.Vuid   `json:"vuid"`
	Bid    proto.BlobID `json:"bid"`
	Size   int64        `json:"size"`
	Type   IOType       `json:"iotype,omitempty"`
	Body   io.Reader    `json:"-"`
}

type PutShardRet struct {
	Crc uint32 `json:"crc"`
}

type RangeGetShardArgs struct {
	GetShardArgs
	Offset int64 `json:"offset"`
	Size   int64 `json:"size"`
}

type ShardInfo struct {
	Vuid   proto.Vuid   `json:"vuid"`
	Bid    proto.BlobID `json:"bid"`
	Size   int64        `json:"size"`
	Crc    uint32       `json:"crc"`
	Flag   ShardStatus  `json:"flag"` // 1:normal,2:markDelete
	Inline bool         `json:"inline"`
}

type ShardStatus uint8

type StatChunkArgs struct {
	DiskID proto.DiskID `json:"diskid"`
	Vuid   proto.Vuid   `json:"vuid"`
}

type StatShardArgs struct {
	DiskID proto.DiskID `json:"diskid"`
	Vuid   proto.Vuid   `json:"vuid"`
	Bid    proto.BlobID `json:"bid"`
}

type StorageAPI interface {
	String(ctx context.Context, host string) string
	IsOnline(ctx context.Context, host string) bool
	Close(ctx context.Context, host string) error
	Stat(ctx context.Context, host string) (infos []*DiskInfo, err error)
	DiskInfo(ctx context.Context, host string, args *DiskStatArgs) (di *DiskInfo, err error)

	// chunks
	CreateChunk(ctx context.Context, host string, args *CreateChunkArgs) (err error)
	StatChunk(ctx context.Context, host string, args *StatChunkArgs) (ci *ChunkInfo, err error)
	ReleaseChunk(ctx context.Context, host string, args *ChangeChunkStatusArgs) (err error)
	SetChunkReadonly(ctx context.Context, host string, args *ChangeChunkStatusArgs) (err error)
	SetChunkReadwrite(ctx context.Context, host string, args *ChangeChunkStatusArgs) (err error)
	ListChunks(ctx context.Context, host string, args *ListChunkArgs) (cis []*ChunkInfo, err error)

	// shard
	GetShard(ctx context.Context, host string, args *GetShardArgs) (body io.ReadCloser, shardCrc uint32, err error)
	RangeGetShard(ctx context.Context, host string, args *RangeGetShardArgs) (body io.ReadCloser, shardCrc uint32, err error)
	PutShard(ctx context.Context, host string, args *PutShardArgs) (crc uint32, err error)
	StatShard(ctx context.Context, host string, args *StatShardArgs) (si *ShardInfo, err error)
	MarkDeleteShard(ctx context.Context, host string, args *DeleteShardArgs) (err error)
	DeleteShard(ctx context.Context, host string, args *DeleteShardArgs) (err error)
	ListShards(ctx context.Context, host string, args *ListShardsArgs) (sis []*ShardInfo, next proto.BlobID, err error)

	WorkerAPI
}

type WorkerAPI interface {
	RepairShard(ctx context.Context, host string, args *proto.ShardRepairTask) (err error)
	WorkerStats(ctx context.Context, host string) (ret WorkerStats, err error)
}

type WorkerStats struct {
	CancelCount  string `json:"cancel_count"`
	ReclaimCount string `json:"reclaim_count"`
}