io_engine

Documentation

Index

• type GcMapCache
  • func NewGcMapCache(threadNum int, replicaNodeCount int, threadChanSize int, meta *meta.Meta) (*GcMapCache, error)
  • func (gc *GcMapCache) CheckSeg(ctx context.Context, blocks []*types.FileBlockInfo) (updatedBlocks []*types.FileBlockInfo, err error)
  • func (gc *GcMapCache) Run() (err error)
  • func (gc *GcMapCache) Stop()
  • func (gc *GcMapCache) SyncGcMap(ctx context.Context, req *types.GetGcMapReq) (isNeedCheck bool, err error)
• type GcMapTreeMgr
  • func NewGcMapTreeMgr(threadNum int, replicaNodeCount int, threadChanSize int, wg *sync.WaitGroup) (*GcMapTreeMgr, error)
  • func (gt *GcMapTreeMgr) CheckGcMapTree(ctx context.Context, req interface{}, thrKey *types.FileSegment) (updatedBlocks []*types.FileBlockInfo, err error)
  • func (gt *GcMapTreeMgr) DeleteGcMapTree(ctx context.Context, req interface{}, thrKey *types.FileSegment) (err error)
  • func (gt *GcMapTreeMgr) InsertOrUpdateGcMapTree(ctx context.Context, req interface{}, thrKey *types.FileSegment) (err error)
  • func (gt *GcMapTreeMgr) Stop()
• type GcMapTreeTask
• type GcMapTreeThreadPool
• type GcMapTreeWorker
• type Task

Types

type GcMapCache

type GcMapCache struct {
	Meta    *meta.Meta
	TreeMgr *GcMapTreeMgr
	// contains filtered or unexported fields
}

func NewGcMapCache

func NewGcMapCache(threadNum int, replicaNodeCount int, threadChanSize int, meta *meta.Meta) (*GcMapCache, error)

func (*GcMapCache) CheckSeg

func (gc *GcMapCache) CheckSeg(ctx context.Context, blocks []*types.FileBlockInfo) (updatedBlocks []*types.FileBlockInfo, err error)

func (*GcMapCache) Run

func (gc *GcMapCache) Run() (err error)

func (*GcMapCache) Stop

func (gc *GcMapCache) Stop()

func (*GcMapCache) SyncGcMap

func (gc *GcMapCache) SyncGcMap(ctx context.Context, req *types.GetGcMapReq) (isNeedCheck bool, err error)

type GcMapTreeMgr

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

func NewGcMapTreeMgr

func NewGcMapTreeMgr(threadNum int, replicaNodeCount int, threadChanSize int, wg *sync.WaitGroup) (*GcMapTreeMgr, error)

func (*GcMapTreeMgr) CheckGcMapTree

func (gt *GcMapTreeMgr) CheckGcMapTree(ctx context.Context, req interface{}, thrKey *types.FileSegment) (updatedBlocks []*types.FileBlockInfo, err error)

func (*GcMapTreeMgr) DeleteGcMapTree

func (gt *GcMapTreeMgr) DeleteGcMapTree(ctx context.Context, req interface{}, thrKey *types.FileSegment) (err error)

func (*GcMapTreeMgr) InsertOrUpdateGcMapTree

func (gt *GcMapTreeMgr) InsertOrUpdateGcMapTree(ctx context.Context, req interface{}, thrKey *types.FileSegment) (err error)

func (*GcMapTreeMgr) Stop

func (gt *GcMapTreeMgr) Stop()

type GcMapTreeTask

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

type GcMapTreeThreadPool

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

type GcMapTreeWorker

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

type Task

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