fs_console

Documentation

Index

• type ConsoleDeleteFsTask
  • func NewConsoleDeleteFsTask(ctx context.Context, groupId, topic string, store *storage.YigFsStorage, ...) (task *ConsoleDeleteFsTask)
  • func (df *ConsoleDeleteFsTask) Run() (err error)
  • func (df *ConsoleDeleteFsTask) ScanGcFs()
  • func (df *ConsoleDeleteFsTask) Stop()

Types

type ConsoleDeleteFsTask

type ConsoleDeleteFsTask struct {
	GroupId string
	Topic   string
	Store   *storage.YigFsStorage
	// contains filtered or unexported fields
}

func NewConsoleDeleteFsTask

func NewConsoleDeleteFsTask(ctx context.Context, groupId, topic string, store *storage.YigFsStorage, fileChanSize, fileThreadNum, fsChanSize, fsThreadNum int,
	msgBus helper.MsgBusConfig, leadeMgr *tools.LeaderMgr, wg *sync.WaitGroup) (task *ConsoleDeleteFsTask)

func (*ConsoleDeleteFsTask) Run

func (df *ConsoleDeleteFsTask) Run() (err error)

func (*ConsoleDeleteFsTask) ScanGcFs

func (df *ConsoleDeleteFsTask) ScanGcFs()

func (*ConsoleDeleteFsTask) Stop

func (df *ConsoleDeleteFsTask) Stop()