Broadcast returns a StageRunner that passes a copy of each incoming payload to all specified processors and emits their outputs to the next stage.

ChallengeUser requests a challenge from c and prompts the user for an answer using p. If the user's answer matches the challenge then ChallengeUser re

Client returns an http.Client instance that automatically uses the OAuth token obtained from this authentication attempt when performing outgoing http

Close releases any resources allocated by this PageRank calculator instance.

CompleteJob is responsible for persisting the locally computed values after a successful execution of a distributed graph algorithm.

Crawl iterates linkIt and sends each link through the crawler pipeline returning the total count of links that went through the pipeline. Calls to Cra

Flush drops all pending messages from the queue.

DstID returns the vertex ID that corresponds to this edge's target endpoint.

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

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

FixedWorkerPool returns a StageRunner that spins up a pool containing numWorkers to process incoming payloads in parallel and emit their outputs to th

Highlight the configured search terms in the provided sentence by wrapping them in <em> tags.

Links returns an iterator for the set of links whose IDs belong to the [fromID, toID) range and were retrieved before the provided timestamp.

Messages returns an iterator for accessing the queued messages.

Name returns the service name.

NewAggregator returns a new Aggregator instance that queries the providers at providerAddrs and returns back the results.

NewDetector returns a new Detector instance which is initialized with the default list of IPv4/IPv6 CIDR blocks that correspond to private networks ac

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

NewInMemoryGraph creates a new in-memory link graph.

NewLinkGraphServer returns a new server instance that uses the provided graph as its backing store.

NewMasterNode creates a new master node for the PageRank calculator service.

NewMockGraphAPI creates a new mock instance

NewMockIndexAPI creates a new mock instance

NewMockRunner creates a new mock instance

NewMockSerializer creates a new mock instance

NewOAuthFlow returns a Flow instance that can be used to execute a three-legged OAuth flow using the service provider from the specified configuration

NewRetryingDialer returns a new dialer that wraps dialFunc with a retry layer that waits between attempts using an exponential back-off algorithm. Dia

NewTextIndexerServer creates a new server instance that uses the provided indexer as its backing store.

NewWorkerNode creates a new worker node for the PageRank calculator service.

RecvFromMasterChan returns a channel for reading incoming payloads from the master.

RecvMsg mocks base method

RecvMsg mocks base method

Reset the state of the graph by removing any existing vertices or aggregators and resetting the superstep counter.

RoundtripTime uses the ping command to measure the RTT to host.

Run implements service.Service

SendMsg mocks base method

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

Serialize encodes the given value into an any.Any protobuf message.

Serve listens for incoming connections on a random open port until ctx expires. It returns back the address that the server is listening on.

SetDisconnectCallback registers a callback which will be invoked when the remote worker disconnects.

SetExecutorFactory configures the calculator to use the a custom executor factory when AssignColors is invoked.

SetGraph configures the test-suite to run all tests against g.

SetIndexer configures the test-suite to run all tests against idx.

StartJob initializes the underlying bspgraph.Graph instance and invokes the provided ExecutorFactory to create an executor for the graph supersteps.

callService performs an RPC and decodes the response into res.

expBackoff returns the time we need to wait after the i_th attempt. It is calculated using the following formula: min(pow(4ms, attempt) + jitter, max

findByID looks up a document by its link UUID expressed as a string.

newMatchHighlighter returns a matchHighlighter instance that can highlight the specified searchTerms in blocks of text.

newWorkerPool creates a new worker pool instance.

residualOutputAccName returns the name of the accumulator where the residual PageRank scores for the specified superstep are to be written to.

vatInclusivePrice applies a vat rate to a price and returns the result.

AddUndirectedEdge creates an un-directed edge from srcID to dstID.