Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RefreshAndRemove ¶ added in v4.1.0
Types ¶
type OnCompletionFunc ¶
type SrcPathToRemove ¶
type SrcPathToRemove string
type TaskGroupCoordinator ¶
type TaskGroupCoordinator struct {
// contains filtered or unexported fields
}
var TransferCoordinator *TaskGroupCoordinator = NewTaskGroupCoordinator("RefreshAndRemove", RefreshAndRemove)
func NewTaskGroupCoordinator ¶
func NewTaskGroupCoordinator(name string, f OnCompletionFunc) *TaskGroupCoordinator
func (*TaskGroupCoordinator) AddTask ¶
func (tgc *TaskGroupCoordinator) AddTask(groupID string, payload any)
payload可为nil
func (*TaskGroupCoordinator) AppendPayload ¶
func (tgc *TaskGroupCoordinator) AppendPayload(groupID string, payload any)
func (*TaskGroupCoordinator) Done ¶
func (tgc *TaskGroupCoordinator) Done(groupID string, success bool)
Source Files
Click to show internal directories.
Click to hide internal directories.