task

type Client interface {
	CreateTask(ctx context.Context, req *taskspb.CreateTaskRequest, opts ...gax.CallOption) (*taskspb.Task, error)
	Close() error
}

type Payload struct {
	Url    string `json:"url"`    // the youtube url to use for download
	Artist string `json:"artist"` // the artist
	Album  string `json:"album"`  // the album
	Track  string `json:"track"`  // the music track
}

type Provider interface {
	NewClient() (Client, error)
}

type Task struct {
	JobKey string `json:"job_key"`
	Payload
}

type TaskClient interface {

	// CreateTask creates a new task from the given payload.
	// It returns the created task.
	CreateTask(tPayload Task) (*taskspb.Task, error)

	// Close closes the client
	Close() error
}

type TaskClientOptions struct {
	// QueuePath locates where to push new tasks.
	QueuePath string

	// Target is the host that needs to be called by the task.
	Target string

	// Provider for the client
	Provider Provider
}