please upgrade the proto package The type of this step.

ProcessorFunc is an adapter to allow the use of plain functions as Processor instances. If f is a function with the appropriate signature, ProcessorFu

restEndpointCaller is a convenience type for perfoming GET requests to REST endpoints.

QueryType describes the types of queries supported by the indexer implementations.

please upgrade the proto package

The RelayerFunc type is an adapter to allow the use of ordinary functions as Relayers. If f is a function with the appropriate signature, RelayerFunc(

API is implemented by clients of the project metadata micro-service.

Aggregator is implemented by types that provide concurrent-safe aggregation primitives (e.g. counters, min/max, topN).

Aggregator collects and returns price quotes from a set of downstream providers.

Assigner implements the greedy Jones/Plassmann algorithm for coloring graphs.

Calculator implements a shortest path calculator from a single vertex to all other vertices in a connected graph.

Calculator executes the iterative version of the PageRank algorithm on a graph until the desired level of convergence is reached.

Challenger is implemented by objects that can generate CAPTCHA image challenges.

CockroachDBGraph implements a graph that persists its links and edges to a cockroachdb instance.

Collector provides helper methods for building the dependency graph of projects.

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

Config encapsulates the configuration options for creating a new Crawler.

Config encapsulates the settings for configuring the front-end service.

Config encapsulates the settings for configuring the PageRank calculator service.

Config encapsulates the settings for configuring the web-crawler service.

Config encapsulates the required parameters for creating a new PageRank calculator instance.

Crawler implements a web-page crawling pipeline consisting of the following stages: - Given a URL, retrieve the web-page contents from the remote ser

DepType describes a dependency type.

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

Detector is implemented by types that can assign a clustered application instance to a particular partition.

Detector checks whether a host name resolves to a private network address.

Device is implemented by objects that can perform vector operations on slices containing single-precision floating point numbers.

Device describes a GPU computing node.

DialFunc describes any function that can be invoked to dial a remote host.

Document describes a web-oage whose content has been indexed by Links 'R' Us.

Document represents an indexed document.

Edge describes a graph edge that originates from Src and terminates at Dst.

Edge describes an edge in the linkgraph.

Edge represents a directed edge in the Graph.

EdgeIterator is implemented by objects that can iterate the graph edges.

ElasticSearchIndexer is an Indexer implementation that uses an elastic search instance to catalogue and search documents.

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

ExecutorCallbacks encapsulates a series of callbacks that are invoked by an Executor instance on a graph. All callbacks are optional and will be ignor

ExecutorFactory is a function that creates new Executor instances.

Fixed is a dummy PartitionDetector implementation that always returns back the same partition details.

Float64Accumulator implements a concurrent-safe accumulator for float64 values.

Flow implements the three-legged OAuth authentication flow.

FromSRVRecords detects the number of partitions by performing an SRV query and counting the number of results.

Gateway simulates an API gateway that would handle requests from a front-end.

Graph is implemented by objects that can upsert links and edges into a link graph instance.

Graph is implemented by objects that can mutate or query a link graph.

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

GraphAPI defines as set of API methods for fetching the links and edges from the link graph.

GraphAPI defines as set of API methods for adding links to the link graph.

go:generate mockgen -package mocks -destination mocks/mocks.go github.com/PacktPublishing/Hands-On-Software-Engineering-with-Golang/Chapter10/linksrus

go:generate mockgen -package mocks -destination mocks/mocks.go github.com/PacktPublishing/Hands-On-Software-Engineering-with-Golang/Chapter10/linksrus

GraphConfig encapsulates the configuration options for creating graphs.

Group is a list of Service instances that can execute in parallel.

InMemoryBleveIndexer is an Indexer implementation that uses an in-memory bleve instance to catalogue and search documents.

InMemoryGraph implements an in-memory link graph that can be concurrently accessed by multiple clients.

IncomingScoreMessage is used for distributing PageRank scores to neighbors.

IndexAPI defines a set of API methods for updating PageRank scores for indexed documents.

IndexAPI defines a set of API methods for searching crawled documents.

IndexAPI defines a set of API methods for updating PageRank scores for indexed documents.

IndexAPI defines a set of API methods for indexing crawled documents.

Indexer is implemented by objects that can index the contents of web-pages retrieved by the crawler pipeline.

Indexer is implemented by objects that can index and search documents discovered by the Links 'R' Us crawler.

IntAccumulator implements a concurrent-safe accumulator for int values.

Iterator is implemented by graph objects that can be iterated.

Iterator is implemented by objects that can paginate search results.

Iterator provides an API for iterating a list of messages.

JobDetails describes a job assigned by a master node to a worker.

JobQueueClient is the client API for JobQueue service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.

JobQueueServer is the server API for JobQueue service.