package
0.0.0-20230519005545-30c4c12152ad
Repository: https://github.com/grailbio/bigslice.git
Documentation: pkg.go.dev

# Functions

Bigmachine configures a session using the bigmachine executor configured with the provided system.
Eval simultaneously evaluates a set of task graphs from the provided set of roots.
Eventer configures the session with an Eventer that will be used to log session events (for analytics).
MaxLoad configures the session with the provided max machine load.
NewTaskSubscriber returns a new TaskSubscriber.
Parallelism configures the session with the provided target parallelism.
Start creates and starts a new bigslice session, configuring it according to the provided options.
Status configures the session with a status object to which run statuses are reported.
TracePath configures the path to which a trace event file for the session will be written on shutdown.

# Constants

No description provided by the author
DefaultMaxLoad is the default machine max load.
TaskErr indicates that the task experienced a failure while running.
TaskInit is the initial state of a task.
TaskLost indicates that the task was lost, usually because the machine to which the task was assigned failed.
TaskOk indicates that a task has successfully completed; the task's results are available to dependent tasks.
TaskRunning is the state of a task that's currently being run or discarded.
TaskWaiting indicates that a task has been scheduled for execution (it is runnable) but has not yet been allocated resources by the executor.

# Variables

DoShuffleReaders determines whether reader tasks should be shuffled in order to avoid potential thundering herd issues.
ErrTaskLost indicates that a Task was in TaskLost state.
Local configures a session with the local in-binary executor.
MachineCombiners is a session option that turns on machine-local combine buffers.
ProbationTimeout is the amount of time that a machine will remain in probation without being explicitly marked healthy.

# Structs

No description provided by the author
A Result is the output of a Slice evaluation.
Session represents a Bigslice compute session.
A Task represents a concrete computational task.
A TaskDep describes a single dependency for a task.
A TaskName uniquely names a task by its constituent components.
TaskSubscriber is subscribed to a Task using Subscribe.

# Interfaces

Executor defines an interface used to provide implementations of task runners.
Store is an abstraction that stores partitioned data as produced by a task.

# Type aliases

An Option represents a session configuration parameter value.
TaskState represents the runtime state of a Task.