src/

Package cm implements the Cormode-Muthukrishnan algorithm for computing biased quantiles over data streams from "Effective Computation of Biased Quantiles over Data Streams" and is largely based on statsite's implementation in C: https://github.com/statsite/statsite/blob/master/src/cm_quantile.c

Package handler is a generated GoMock package.

Package writer is a generated GoMock package.

Package client is a generated GoMock package.

Package flush is a generated protocol buffer package.

Package hash is a temporary measure used as in between while m3aggregator is upgraded to use native source generated maps now accessible in m3x, these types are missing from m3x when native source generated maps were added.

Package integration contains integration tests for aggregator.

Package runtime is a generated GoMock package.

Package deploy is a generated GoMock package.

Package client is a generated GoMock package.

Package changesetpb is a generated protocol buffer package.

Package changesettest is a generated protocol buffer package.

Package commonpb is a generated protocol buffer package.

Package kvpb is a generated protocol buffer package.

Package kvtest is a generated protocol buffer package.

Package metadatapb is a generated protocol buffer package.

Package placementpb is a generated protocol buffer package.

Package testpb is a generated protocol buffer package.

Package kv is a generated GoMock package.

Package placement is a generated GoMock package.

Package algo implements different types of placement algorithms

Package placementhandler provides debug/admin placement operations via HTTP

Package services is a generated GoMock package.

Package leader provides functionality for etcd-backed leader elections.

Package campaign encapsulates the state of a campaign.

Package election provides a wrapper around a subset of the Election functionality of etcd's concurrency package with error handling for common failure scenarios such as lease expiration.

Package config contains configuration for the aggregator.

Package downsample is a generated GoMock package.

Package ingest is a generated GoMock package.

Package ingestcarbon implements a carbon ingester.

Package model contains model definitions for m3 coordinator.

Package server is a package for starting servers for M3 components.

carbon_load is a tool for load testing carbon ingestion.

Package topics implements topic endpoint interaction.

Package store is a generated GoMock package.

Package client is a generated GoMock package.

Package digest is a generated GoMock package.

Package discovery provides discovery configuration.

Package encoding is a generated GoMock package.

Package annotation is a generated protocol buffer package.

Package index is a generated protocol buffer package.

Package namespace is a generated protocol buffer package.

Package pagetoken is a generated protocol buffer package.

Package snapshot is a generated protocol buffer package.

Package rpc is a generated GoMock package.

Package namespace is a generated GoMock package.

Package kvadmin is a generated GoMock package.

Package tchannelthrift contains code for servicing RPC requests via tchannel.

Package persist is a generated GoMock package.

Package fs is a generated GoMock package.

Package commitlog is a generated GoMock package.

Package retention is a generated GoMock package.

Package runtime is a generated GoMock package.

Package server contains the code to run the dbnode server.

Package storage is a generated GoMock package.

Package block is a generated GoMock package.

Package bootstrap is a generated GoMock package.

Package commitlog implements commit log bootstrapping.

Package fs implements file system bootstrapping.

Package peers implements peers bootstrapping.

Package uninitialized implements uninitialized topology bootstrapping.

Package index is a generated GoMock package.

Package convert contains various conversions.

Package limits contains paths to enforce read query limits.

Package permits is a generated GoMock package.

Package series is a generated GoMock package.

Package test is a package for shared test helpers.

Package topology is a generated GoMock package.

Package writes is a generated GoMock package.

Package xio is a generated GoMock package.

Package aggregator contains integration tests for aggregators.

Package prometheus contains resources for starting a docker-backed Prometheus.

Package repair contains integration tests for repair and replication among dbnodes.

Package resources contains integration test resources for spinning up M3 components.

Package docker contains resources needed to setup docker containers for M3 tests.

Package inprocess contains code for spinning up M3 resources in-process for the sake of integration testing.

Package net contains network-related helpers for integration testing.

Package simple contains code simple integration tests that writes and reads.

Package build is a generated GoMock package.

Package heartbeat is a generated protocol buffer package.

Package m3em is a generated GoMock package.

Package node is a generated GoMock package.

Package exec is a generated GoMock package.

Package fs is a generated GoMock package.

Package doc is a generated GoMock package.

Package fswriter is a generated protocol buffer package.

Package querypb is a generated protocol buffer package.

Package index is a generated GoMock package.

Package segment is a generated GoMock package.

Package fst is a generated GoMock package.

Package mem is a generated GoMock package.

Package persist is a generated GoMock package.

Package postings is a generated GoMock package.

Package search is a generated GoMock package.

Package proptest contains a collection of generative tests to validate query behaviour in a variety of situations.

Package protobuf is a generated GoMock package.

Package aggregationpb is a generated protocol buffer package.

Package metricpb is a generated protocol buffer package.

Package pipelinepb is a generated protocol buffer package.

Package policypb is a generated protocol buffer package.

Package rulepb is a generated protocol buffer package.

Package transformationpb is a generated protocol buffer package.

Package integration contains integration tests.

Package matcher is a generated GoMock package.

Package namespace provides namespace functionality for the matcher.

Package id is a generated GoMock package.

Package m3 describes m3 metric id information.

Package rules is a generated GoMock package.

Package consumer is a generated GoMock package.

mockgen rules for generating mocks for unexported interfaces (file mode).

Package msgpb is a generated protocol buffer package.

Package topicpb is a generated protocol buffer package.

Package producer is a generated GoMock package.

Package writer is a generated GoMock package.

Package proto is a generated GoMock package.

Package topic is a generated GoMock package.

Package database contains API endpoints for managing the database.

Package prom provides custom handlers that support the prometheus query endpoints.

Package native handles the prometheus api endpoints using m3.

Package httpd contains http routers.

Package middleware contains HTTP middleware functions.

Package options configures query http handlers.

Package route stores common HTTP route handling code

package validators contains validation logics for the api.

Package block is a generated GoMock package.

Package executor is a generated GoMock package.

Package transform is a generated GoMock package.

Package temporal is a generated GoMock package.

Package admin is a generated protocol buffer package.

Package prompb is a generated protocol buffer package.

Package rpcpb is a generated protocol buffer package.

Package storage is a generated GoMock package.

Package m3ql is a generated GoMock package.

Package promqlengine contains utilities for PromQL engine.

Package source identifies the source of query requests.

Package storage is a generated GoMock package.

Package m3 is a generated GoMock package.

Package promremote implements storage interface backed by Prometheus remote write capable endpoints.

Package promremotetest provides test utilities.

Package compare provides comparison functions for testing.

Package ts is a generated GoMock package.

Package json contains logic for writing JSON.

Package checked is a generated GoMock package.

Package clock implements facilities for working with wall clock time.

Package config provides utilities for loading configuration files.

Package configflag provides a utility for registering config related command line options with the stdlib flag package.

Package hostid provides a configuration struct for resolving a host ID from YAML.

Package debug contains debug helpers for M3 components.

Package extdebug contains helpers for more detailed debug information

Package debugtest contains test helper methods

Package errors provides utilities for working with different types errors.

Package generated is a dummy package to make sure mockgen dependencies are pulled in correctly in vendor mode.

Package m3_test is a generated protocol buffer package.

Package hash provides implementation of hash functions.

Package jump implements the jump consistent hash algorithm as described in "A Fast, Minimal Memory, Consistent Hash Algorithm"[1].

Package http adds extension to the stdlib http package.

Package ident is a generated GoMock package.

Package instrument implements functions to make instrumenting code, including metrics and logging, easier.

Package json allows for easy duck typing of JSON, i.e.

Package net implements functions for running network servers.

Package cors handles cross-origin HTTP requests (CORS).

Package opentelemetry provides Open Telemetry configuration.

Package panicmon provides a method of spawning processes and monitoring its behavior via generic pluggable handlers.

Package pool is a generated GoMock package.

Package process provides functions for inspecting processes.

Package resource describes require for object lifecycle management.

Package retry provides utilities for retrying functions.

Package serialize is a generated GoMock package.

Package server implements a network server.

Package sync implements synchronization facililites such as worker pools.

Package tcp implements a tcp listener.

Package test contains utility methods for testing.

Package testmarshal provides some assertions around marshalling/unmarshalling (serialization/deserialization) behavior for types.

Package time implement facilities for working with time.

Package unsafe contains operations that step around the type safety of Go programs.

Package watch provides utilities for watching resources for changes.