src/

Package api contains ProtoBuf-generated types for the external gRPC API to Akutan.

Command akutan-api runs an Akutan API server daemon.

Package impl implements the external gRPC and HTTP API servers for Akutan.

Package kgstats fetches and caches runtime statistics about the cluster and dataset.

Package blog contains interfaces to Akutan's data log.

Package kafka implements a Kafka client as a blog.AkutanLog.

Package logspecclient implements a client for the akutan/logspec API.

Package mockblog contains an in-process, in-memory implementation of a Akutan log client and server.

Package config contains the configuration for a Akutan server.

Package discovery defines basic concepts around service discovery and locating endpoints.

Package discoveryfactory constructs service discovery implementations.

Package kubediscovery provides an implementation of the Locator interface backed by Kubernetes service discovery.

Package diskview implements a view service that serves facts from an ordered key-value store.

Command akutan-diskview runs a DiskView daemon.

Package database defines an abstract ordered Key/Value store that can be used as a backing store by the Disk View.

Package keys provides support for building and parsing the DiskView's binary key format that facts are encoded into.

Package rocksdb provides an implementation of the Database interface that is backed by a local RocksDB Key/Value store

Package cache provides for caching facts that were infered during a query and pottentially reusing them for subsequent operations with the same query.

Package infer implements fact inference by traversing transitive predicates.

Package logentry contains all the types generated from the protobuf files.

Package logencoder handles serialization and deserialization of logentry.*Command in to/from bytes.

Package logread deals with mapping from logentry types into rpc types.

Package logwrite contains helper functions to create instances of types in the logentry package.

Package logspec contains ProtoBuf-generated types for Akutan's log.

Package facts defines the well known base set of facts that are needed to bootstrap the graph

Package kgobject contains helper methods to construct common api KGObject instances

Package partitioning provides ways to describe how the set of facts have been partitioned.

Package query provides a high level entry point for executing AkutanQL queries.

Package exec is used to execute a KG query that was built by the query planner.

Package parser implements a parser combinator for the akutan query language.

Package planner is the KG/Akutan-specific query optimizer.

Package plandef defines the output of the query planner.

Package search implements a generic query optimizer algorithm.

Package rpc contains ProtoBuf-generated types for the messages communicated between Akutan servers.

Package space defines abstract notions of points and ranges.

Command bc provides command line access to the akutan GRPC API

Command carousel-client is a low level carousel client tool for helping investigate performance etc.

Command db-scan reads all keys from a Rocks database.

Command dep checks / fetches / update dependencies

Command generate writes out Kubernetes configuration for portions of the Akutan cluster.

Command gen-local writes out files used to run a Akutan cluster locally.

Package gen is used in generating configurations for an entire Akutan cluster.

Command grpcbench is a small benchmark tool for gRPC.

Command log-client is a tool for low-level access to Akutan log servers.

Command plank implements a logspec server by storing entries in local memory only.

Command view-client is command line tool for calling Akutan views.

Package txtimeoutview implements a view service that times out slow transactions and measures the log's latency.

Command akutan-txview runs a TxTimeoutView daemon.

Package logping measures the latency of Akutan's log by appending to it and reading from it.

Package txtimer watches for slow transactions and aborts them.

Package update handles requests to modify the graph.

Package conv helps convert between related types as an update request is processed.

Package bytes aids in manipulating byte slices and writing bytes and strings.

Package clocks provides a mockable way to measure time and set timers.

Package cmp provides common operators on a number of scalar types

Package debuglog configures Logrus.

Package errors aids in handling errors.

Package graphviz generates diagrams from dot input.

Package grpcclientutil has helpers for configuring gRPC clients.

Package grpcserverutil has helpers for configuring gRPC servers

Package metrics aids in defining Prometheus metrics.

Package parallel is a utility package for running parallel/concurrent tasks.

Package perfbenchmarks contains benchmarks for Go language and standard library features.

Package profiling assists in gathering CPU profiles.

Package random helps seed the math/rand pseudo-random number generator.

Package signals aids in POSIX signal handling.

Package stats contains a pretty-printer for statistics about the facts stored on DiskViews.

Package table formats data into a text-based table for human consumption.

Package tracing assists with reporting OpenTracing traces.

Package unicode contains Unicode text functionality for Akutan store.

Package web aids in writing HTTP servers.

Package viewclient provides functionality for querying view servers.

Package fanout is useful for invoking RPCs across a bunch of servers.

Package lookups defines go interfaces that the various LookupXX rpc wrappers expose, this can be useful in decoupling the actual Loopup implementation from its usage, allowing for easier testing

Package mocklookups provides a mock implementation of the various Fact lookup RPCs.

Package mockstore provides various mocks that store facts and can execute lookups against them.

Package viewreg tracks all the known view servers in the cluster.