Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrNoBlobStoreAvailable = errors.New("no blob store available")
)
Functions ¶
This section is empty.
Types ¶
type BlobStoreHeap ¶
type BlobStoreHeap []*BlobStore
func (*BlobStoreHeap) Len ¶
func (b *BlobStoreHeap) Len() int
func (*BlobStoreHeap) Less ¶
func (b *BlobStoreHeap) Less(i, j int) bool
func (*BlobStoreHeap) Pop ¶
func (b *BlobStoreHeap) Pop() any
func (*BlobStoreHeap) Push ¶
func (b *BlobStoreHeap) Push(x any)
func (*BlobStoreHeap) Swap ¶
func (b *BlobStoreHeap) Swap(i, j int)
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
func NewHandler ¶
func NewHandler() *Handler
func (*Handler) AddBlobStore ¶
func (*Handler) UpdateBlobStore ¶
type Req ¶
type Req struct { FaultTolerateLevel goproto.FaultTolerateLevel BlobCount int BlobSize int64 BannedMap [goproto.FaultTolerateLevel_Az]map[string]struct{} RespChannel chan *Resp }
func (*Req) CheckIfBlobStoreBanned ¶
Click to show internal directories.
Click to hide internal directories.