mpather

type Jgroup struct {
	// contains filtered or unexported fields
}

type JgroupOpts struct {
	T cluster.Target

	VisitObj              func(lom *cluster.LOM, buf []byte) error
	VisitCT               func(ct *cluster.CT, buf []byte) error
	Slab                  *memsys.Slab
	Bck                   cmn.Bck
	Prefix                string
	CTs                   []string
	DoLoad                LoadType // if specified, lom.Load(lock type)
	Parallel              int      // num parallel calls
	IncludeCopy           bool     // visit copies (aka replicas)
	SkipGloballyMisplaced bool     // skip globally misplaced
	Throttle              bool     // true: pace itself depending on disk utilization
	// contains filtered or unexported fields
}

type LoadType int

type WorkerGroup struct {
	// contains filtered or unexported fields
}

type WorkerGroupOpts struct {
	Callback  func(lom *cluster.LOM, buf []byte)
	Slab      *memsys.Slab
	QueueSize int
}