NewExecutor returns an Executor instance for graph g that invokes the provided list of callbacks inside each execution loop.

NewGraph creates a new Graph instance using the specified configuration.

ErrDestinationIsLocal is returned by Relayer instances to indicate that a message destination is actually owned by the local graph.

ErrInvalidMessageDestination is returned by calls to SendMessage and BroadcastToNeighbors when the destination cannot be resolved to any (local or remote) vertex.

ErrUnknownEdgeSource is returned by AddEdge when the source vertex is not present in the graph.

Edge represents a directed edge in the Graph.

Executor wraps a Graph instance and provides an orchestration layer for executing super-steps until an error occurs or an exit condition is met.

ExecutorCallbacks encapsulates a series of callbacks that are invoked by an Executor instance on a graph.

Graph implements a parallel graph processor based on the concepts described in the Pregel paper.

GraphConfig encapsulates the configuration options for creating graphs.

Vertex represents a vertex in the Graph.

Aggregator is implemented by types that provide concurrent-safe aggregation primitives (e.g.

Relayer is implemented by types that can relay messages to vertices that are managed by a remote graph instance.

ComputeFunc is a function that a graph instance invokes on each vertex when executing a superstep.

ExecutorFactory is a function that creates new Executor instances.

The RelayerFunc type is an adapter to allow the use of ordinary functions as Relayers.