tasks

type Client interface {
	GetConnectorTasks(name string) ([]connect.Task, *http.Response, error)
	GetConnectorTaskStatus(name string, taskID int) (*connect.TaskState, *http.Response, error)
	RestartConnectorTask(name string, taskID int) (*http.Response, error)
}

type ClientFn func(string) (Client, error)

type GenericOptions struct {
	// Function for creating API client
	CreateClient ClientFn

	ClusterURL    string
	ConnectorName string
}

type GetOptions struct {
	*GenericOptions

	TaskID int
	Output string
}

type ListOptions struct {
	// Use pointer here to make reference to the 'tasks' options.
	// Otherwise, the local copy of the config will be created an no
	// value from the flags will be set. It is caused by the global
	// scope nature of viper and multiple overrides of cluster flag
	// from the other commands.
	*GenericOptions

	Output string
}

type OutputType string

type RestartOptions struct {
	*GenericOptions

	TaskID int
}

type StatusOptions struct {
	*GenericOptions

	TaskID int
	Output string
}

type TaskListOutputFn func([]connect.Task) ([]byte, error)

type TaskStateOutputFn func(*connect.TaskState) ([]byte, error)