Method RecycleTask

pkg/funclet/task.go:33–60

(stopCh <-chan struct{},  finishCh chan struct{})

)

func (f *Funclet) RecycleTask(stopCh <-chan struct{},  finishCh chan struct{}) {
	ticker := time.NewTicker(30 * time.Second)
	defer ticker.Stop()
	for {
		select {
		case <-stopCh:
			f.logger.Infof("funclet stopped")
			// graceful exit task
			// ...
			list, _ := f.RuntimeClient.ListContainers()
			for _, container := range list {
				ID := container.ID
				f.RuntimeClient.ThawContainer(ID)
			}
			return
		case <-ticker.C:
			taskID := id.GetTaskID()
			taskLogger := f.logger.WithField("task-id", taskID)
			taskLogger.Infof("start recycle task")
			defer taskLogger.Infof("finish recycle task")
			if err := f.tmpRecycleTask(taskLogger); err != nil {
				taskLogger.Errorf("tmp recycle task failed: %s", err)
			}
			// other recycle task
			// ...
		}
	}
}

func (f *Funclet) tmpRecycleTask(tlog *logs.Logger) (err error) {
	tlog.Infof("[tmp recycle task] start task")