tasks

type FileStore struct {
	// contains filtered or unexported fields
}

type Server struct {
	v1alpha1.UnimplementedTasksServiceServer
	// contains filtered or unexported fields
}

type StoredData struct {

	// the tasks
	Tasks map[string]*v1alpha1.Task

	// Group to worker is a mapping from groups to workers; empty means its unassigned.
	// It is the inverse of WorkerIdToGroupNonce
	GroupToWorker map[string]string

	// Mapping from a worker id to the group nonce
	WorkerIdToGroupNonce map[string]string

	// Should we make this a list of only incomplete tasks?
	GroupToTaskNames map[string][]string
	// contains filtered or unexported fields
}

type TaskInterface interface {
	Create(ctx context.Context, task *v1alpha1.Task) (*v1alpha1.Task, error)
	Get(ctx context.Context, name string) (*v1alpha1.Task, error)
	// Update departs from K8s convention because we need to provide the ID of the worker issuing the update
	// request. In principle that should be sent via a sidechannel (e.g. as part of Authn)  so it wouldn't
	// be in the body of the request.
	Update(ctx context.Context, task *v1alpha1.Task, worker string) (*v1alpha1.Task, error)
	Delete(ctx context.Context, name string) error
	List(ctx context.Context, workerId string, includeDone bool) ([]*v1alpha1.Task, error)
	Status(ctx context.Context, req *v1alpha1.StatusRequest) (*v1alpha1.StatusResponse, error)
}