task

package

v0.0.0-...-d500d3c Latest Latest Go to latest Published: Jan 17, 2019 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

View Source

var ErrFailedPermission = errors.New("unauthorized")

func NewValidator(ts platform.TaskService, bs platform.BucketService) platform.TaskService

func PlatformAdapter(s backend.Store, r backend.LogReader, rc RunController) platform.TaskService

PlatformAdapter wraps a task.Store into the platform.TaskService interface.

type RunController interface {
	CancelRun(ctx context.Context, taskID, runID platform.ID) error
}

Path	Synopsis
backend
bolt Package bolt provides an bolt-backed store implementation.	Package bolt provides an bolt-backed store implementation.
coordinator
executor Package executor contains implementations of backend.Executor that depend on the query service.	Package executor contains implementations of backend.Executor that depend on the query service.
storetest
mock Package mock contains mock implementations of different task interfaces.	Package mock contains mock implementations of different task interfaces.
options Package options provides ways to extract the task-related options from a Flux script.	Package options provides ways to extract the task-related options from a Flux script.
servicetest Package servicetest provides tests to ensure that implementations of platform/task/backend.Store and platform/task/backend.LogReader meet the requirements of platform.TaskService.	Package servicetest provides tests to ensure that implementations of platform/task/backend.Store and platform/task/backend.LogReader meet the requirements of platform.TaskService.