tasks

Documentation

Index

• type BaseTask
• type TaskInterface
  • func NewDownloadTask(service services.ResourceService) TaskInterface
  • func NewTestTask() TaskInterface

Types

type BaseTask

type BaseTask struct {
	Name string
	// contains filtered or unexported fields
}

type TaskInterface

type TaskInterface interface {
	SendSync(args []tasks.Arg) ([]reflect.Value, *models.Error)
	SendAsync(args []tasks.Arg) (*result.AsyncResult, *models.Error)
	Register() *models.Error
	Test()
	GetName() string
	SetServer(server *machinery.Server)
	// contains filtered or unexported methods
}

func NewDownloadTask

func NewDownloadTask(service services.ResourceService) TaskInterface

func NewTestTask

func NewTestTask() TaskInterface