mpather

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

type JgroupOpts struct {
	Parent      cos.Stopper // optional: stop walk when parent xaction aborts
	VisitObj    func(lom *core.LOM, buf []byte) error
	VisitCT     func(ct *core.CT, buf []byte) error
	Slab        *memsys.Slab
	Bck         cmn.Bck
	Buckets     cmn.Bcks
	Prefix      string
	CTs         []string
	DoLoad      LoadType // if specified, lom.Load(lock type)
	IncludeCopy bool     // visit copies (aka replicas)
	PerBucket   bool     // num joggers = (num mountpaths) x (num buckets)
	RW          bool     // true when performs data IO
	// contains filtered or unexported fields
}

type LoadType int

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

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