delete_info

Documentation

Index

• func GetAndSendDeleteSeg(ctx context.Context, fsId string, needDeletedSegs []*types.GcDeleteSeg, ...) (err error)
• func SendDeletedMessage(ctx context.Context, deletedSegs []*types.GcDeleteSeg, ...) (err error)
• type DeleteBlocksTask
  • func NewDeleteBlocksTask(ctx context.Context, group, topic string, chanSize int, ...) (task *DeleteBlocksTask)
  • func (dbt *DeleteBlocksTask) Run() (err error)
  • func (dbt *DeleteBlocksTask) ScanGcFiles()
  • func (dbt *DeleteBlocksTask) Stop()
• type DeleteFile_SegmentTask
  • func NewDeleteFile_SegmentTask(ctx context.Context, group, topic string, store *storage.YigFsStorage, ...) (task *DeleteFile_SegmentTask, err error)
  • func (dst *DeleteFile_SegmentTask) Run() (err error)
  • func (dst *DeleteFile_SegmentTask) Stop()
• type UpdateSegTask
  • func NewUpdateSegTask(ctx context.Context, group, topic string, scheduler *concurrency.TaskScheduler, ...) *UpdateSegTask
  • func (ust *UpdateSegTask) Run() (err error)
  • func (ust *UpdateSegTask) Stop()

Functions

func GetAndSendDeleteSeg

func GetAndSendDeleteSeg(ctx context.Context, fsId string, needDeletedSegs []*types.GcDeleteSeg, store *storage.YigFsStorage, msgBus helper.MsgBusConfig) (err error)

func SendDeletedMessage

func SendDeletedMessage(ctx context.Context, deletedSegs []*types.GcDeleteSeg, msgBus helper.MsgBusConfig) (err error)

Types

type DeleteBlocksTask

type DeleteBlocksTask struct {
	GroupId string
	Topic   string
	Cache   *io_engine.GcMapCache
	Store   *storage.YigFsStorage
	// contains filtered or unexported fields
}

func NewDeleteBlocksTask

func NewDeleteBlocksTask(ctx context.Context, group, topic string, chanSize int, store *storage.YigFsStorage, threadNum int, msgBus helper.MsgBusConfig, leadeMgr *tools.LeaderMgr, wg *sync.WaitGroup) (task *DeleteBlocksTask)

func (*DeleteBlocksTask) Run

func (dbt *DeleteBlocksTask) Run() (err error)

func (*DeleteBlocksTask) ScanGcFiles

func (dbt *DeleteBlocksTask) ScanGcFiles()

func (*DeleteBlocksTask) Stop

func (dbt *DeleteBlocksTask) Stop()

type DeleteFile_SegmentTask

type DeleteFile_SegmentTask struct {
	GroupId string
	Topic   string
	Store   *storage.YigFsStorage

	Scheduler *concurrency.TaskScheduler
	// contains filtered or unexported fields
}

func NewDeleteFile_SegmentTask

func NewDeleteFile_SegmentTask(ctx context.Context, group, topic string, store *storage.YigFsStorage, scheduler *concurrency.TaskScheduler, msgBus helper.MsgBusConfig) (task *DeleteFile_SegmentTask, err error)

func (*DeleteFile_SegmentTask) Run

func (dst *DeleteFile_SegmentTask) Run() (err error)

func (*DeleteFile_SegmentTask) Stop

func (dst *DeleteFile_SegmentTask) Stop()

type UpdateSegTask

type UpdateSegTask struct {
	GroupId string
	Topic   string

	Scheduler *concurrency.TaskScheduler
	// contains filtered or unexported fields
}

func NewUpdateSegTask

func NewUpdateSegTask(ctx context.Context, group, topic string, scheduler *concurrency.TaskScheduler, msgBus helper.MsgBusConfig) *UpdateSegTask

func (*UpdateSegTask) Run

func (ust *UpdateSegTask) Run() (err error)

func (*UpdateSegTask) Stop

func (ust *UpdateSegTask) Stop()