43 lines
906 B
Go
43 lines
906 B
Go
|
// Copyright (C) 2018 Storj Labs, Inc.
|
||
|
|
// See LICENSE for copying information.
|
||
|
|
|
||
|
|
package datarepair
|
||
|
|
|
||
|
|
import "storj.io/storj/pkg/pb"
|
||
|
|
|
||
|
|
//Queue implements the RepairQueue interface
|
||
|
|
type Queue struct {
|
||
|
|
//redis db of repair segments
|
||
|
|
//offline nodes?
|
||
|
|
}
|
||
|
|
|
||
|
|
//NewQueue creates a new data repair queue
|
||
|
|
func NewQueue() {
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
//Add adds a repair segment to the queue
|
||
|
|
func (q Queue) Add(qi *pb.InjuredSegment) error {
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
//AddAll adds a slice of repair segements to the queue
|
||
|
|
func (q Queue) AddAll(qis []*pb.InjuredSegment) error {
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
//Remove removes a repair segment from the queue
|
||
|
|
func (q Queue) Remove(qi *pb.InjuredSegment) error {
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
//GetNext returns the next repair segement from the queue
|
||
|
|
func (q Queue) GetNext() pb.InjuredSegment {
|
||
|
|
return pb.InjuredSegment{}
|
||
|
|
}
|
||
|
|
|
||
|
|
//GetSize returns the number of repair segements are in the queue
|
||
|
|
func (q Queue) GetSize() int {
|
||
|
|
return 0
|
||
|
|
}
|