job

package
Version: v0.0.0-...-0102553 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 17, 2021 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Details

type Details struct {
	// JobID returns a unique ID for this job.
	JobID string

	// CreatedAt returns the creation time for this job.
	CreatedAt time.Time

	// The [start, end) values of the UUID range allocated for this job.
	PartitionFromID uuid.UUID
	PartitionToID   uuid.UUID
}

Details encapsulates the information about a job executed by a master or a worker node.

type Runner

type Runner interface {
	// StartJob initializes the underlying bspgraph.Graph instance and
	// invokes the provided ExecutorFactory to create an executor for the
	// graph supersteps.
	StartJob(Details, bspgraph.ExecutorFactory) (*bspgraph.Executor, error)

	// CompleteJob is responsible for persisting the locally computed
	// values after a successful execution of a distributed graph algorithm.
	CompleteJob(Details) error

	// AbortJob is responsible for cleaning up the underlying graph after
	// an unsuccessful execution of a distributed graph algorithm.
	AbortJob(Details)
}

Runner is implemented by types that can execute distributed bspgraph jobs.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL