EXPECT returns an object that allows the caller to indicate expected use

FIFO returns a StageRunner that processes incoming payloads in a first-in first-out fashion. Each input is passed to the specified processor and its o

HandleSendRecv asynchronously handles both the send and receiving ends of a remotely connected worker. Calls to HandleSendRecv block until the

Links streams the set of links in the specified ID range.

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

NewMockLinkGraphClient creates a new mock instance

Output returns a channel for writing the output payloads for a stage.

Scores invokes the provided visitor function for each vertex in the graph.

newRemoteMasterStream creates a stream abstraction for interacting with a master.

newWorkerStepBarrier creates a new barrier instance for a worker node that communicates with a master barrier instance over the provided channels.

Close cleans up any allocated graph resources.

DependencyType returns the type of a particular dependency.

FindLink looks up a link by its ID.

Get the current aggregator value.

Input returns a channel for reading the input payloads for a stage.

MarkAsProcessed is invoked by the pipeline when the Payload either reaches the pipeline sink or it gets discarded by one of the pipeline stages.

NewRange creates a new range [start, end) and splits it into the provided number of partitions.

NewService creates a new PageRank calculator service instance with the specified config.

PartitionExtents returns the [start, end) range for the requested partition.

PartitionExtents returns the [start, end) range for the requested partition.

PartitionForID returns the partition index that the provided ID belongs to.

PendingMessages returns true if the queue contains any messages.

RecvMsg mocks base method

ReserveWorkers blocks until either the context gets cancelled or at least minWorkers are available in the pool. In the latter case, the workers are re

SendMsg mocks base method

SendToMasterChan returns a channel for sending worker payloads to the master.

TotalCount returns the approximate number of search results.

maybeEmitError attempts to queue err to a buffered error channel. If the channel is full, the error is dropped.

AbortJob is responsible for cleaning up the underlying graph after an unsuccessful execution of a distributed graph algorithm.

Authenticate starts a new three-legged OAuth flow. It returns back a URL that the client must to visit to authorize access. Once the user has complete

CloseSend mocks base method

EXPECT returns an object that allows the caller to indicate expected use

EXPECT returns an object that allows the caller to indicate expected use

EXPECT returns an object that allows the caller to indicate expected use

Enqueue inserts a message to the end of the queue.

Freeze marks the vertex as inactive. Inactive vertices will not be processed in the following supersteps unless they receive a message in which case t

Header mocks base method

JobStream establishes a bi-directional connection between a worker and a master. The master eventually broadcasts a new job to the connected workers a

ListDependencies returns the list of direct dependency IDs for a particular project ID or an error if a non-project ID argument is provided.

MustGetTracer obtains and returns a new Jaeger tracer or panics if any error occurs.

NewCalculator returns a new Calculator instance using the provided config options.

NewCockroachDbGraph returns a CockroachDbGraph instance that connects to the cockroachdb instance specified by dsn.

NewDetectorFromCIDRs returns a new Detector instance which is initialized with the specified list of privateNetworkCIDRs.

NewElasticSearchIndexer creates a text indexer that uses an in-memory bleve instance for indexing documents.

NewFullRange creates a new range that uses the full UUID value space and splits it into the provided number of partitions.

NewFullRange creates a new range that uses the full UUID value space and splits it into the provided number of partitions.

NewMockGraphAPI creates a new mock instance

NewMockIndexAPI creates a new mock instance

NewMockJobQueue_JobStreamServer creates a new mock instance

NewMockTextIndexerClient creates a new mock instance

NewService creates a new front-end service instance with the specified config.

NewService creates a new crawler service instance with the specified config.

PriceForItem calculates the VAT-inclusive retail price of itemUUID with the currently applicable VAT rates.

RecvFromWorkerChan returns a channel for reading incoming payloads from the worker.

RegisterRelayer configures a Relayer that the graph will invoke when attempting to deliver a message to a vertex that is not known locally but could p

RemoveStaleEdges removes any edge that originates from the specified link ID and was updated before the specified timestamp.

Run executes all Service instances in the group using the provided context. Calls to Run block until all services have completed executing either beca

RunSteps executes at most numStep supersteps unless the context expires, an error occurs or one of the Pre/PostStepKeepRunning callbacks specified at

SendMsg mocks base method

Unserialize decodes the given any.Any protobuf value.

WithPinnedCertVerification returns a TLS dialer function which checks that the remote server provides a certificate whose SHA256 fingerprint matches t

resolveURL expands target into an absolute URL using the following rules: - targets starting with '//' are treated as absolute URLs that inherit the p

sendToWorker attempts to send a message to a remote worker. It blocks until either the message is enqueued for sending or the job context expires.

AddEdge creates a directed edge from srcID to dstID with the specified cost. An error will be returned if a negative cost value is specified.

AddEdge inserts a directed edge from src to dst. If both src and dst refer to the same vertex then this is a no-op.

AddPreColoredVertex inserts a new vertex with a pre-assigned color.

AddUser appends user to the room user list.

AddVertex inserts a new vertex with the specified ID into the graph.

AddVertex inserts a new vertex to the graph with the given id.

Aggregators returns a map of all currently registered aggregators where the key is the aggregator's name.

AssignColors executes the Jones/Plassmann algorithm on the graph and invokes the user-defined visitor function for each vertex in the graph.