Directories
¶
| Path | Synopsis |
|---|---|
|
Package accesslog provides access log for banyandb.
|
Package accesslog provides access log for banyandb. |
|
Package auth contains authentication helper functions.
|
Package auth contains authentication helper functions. |
|
Package bus implements a message bus which is a common data model and a messaging infrastructure to allow different modules to communicate locally or remotely.
|
Package bus implements a message bus which is a common data model and a messaging infrastructure to allow different modules to communicate locally or remotely. |
|
Package bydbql provides BanyanDB Query Language (BydbQL) parsing and translation capabilities.
|
Package bydbql provides BanyanDB Query Language (BydbQL) parsing and translation capabilities. |
|
Package bytes provides utilities for operating bytes.
|
Package bytes provides utilities for operating bytes. |
|
Package cgroups provides a way to get the number of CPUs.
|
Package cgroups provides a way to get the number of CPUs. |
|
Package cmdsetup implements a real env in which to run tests.
|
Package cmdsetup implements a real env in which to run tests. |
|
compress
|
|
|
zstd
Package zstd provides ZSTD compression and decompression.
|
Package zstd provides ZSTD compression and decompression. |
|
Package config implements a configuration system which could load configuration from flags and env vars.
|
Package config implements a configuration system which could load configuration from flags and env vars. |
|
Package convert implements conversions to and from data.
|
Package convert implements conversions to and from data. |
|
Package dump provides utilities for dumping BanyanDB data.
|
Package dump provides utilities for dumping BanyanDB data. |
|
Package encoding implements encoding/decoding data points.
|
Package encoding implements encoding/decoding data points. |
|
vararray
Package vararray holds the escaped, delimiter-separated variable-length array codec (MarshalVarArray / UnmarshalVarArray and the delimiter/escape bytes).
|
Package vararray holds the escaped, delimiter-separated variable-length array codec (MarshalVarArray / UnmarshalVarArray and the delimiter/escape bytes). |
|
Package filter defines and implements data structures and interfaces for skipping index.
|
Package filter defines and implements data structures and interfaces for skipping index. |
|
Package flow implements a streaming calculation framework.
|
Package flow implements a streaming calculation framework. |
|
streaming
Package streaming implement the flow framework to provide the sliding window, top-n aggregation, and etc.
|
Package streaming implement the flow framework to provide the sliding window, top-n aggregation, and etc. |
|
streaming/sources
Package sources implements data sources to sink data into the flow framework.
|
Package sources implements data sources to sink data into the flow framework. |
|
Package fs (file system) is an independent component to operate file and directory.
|
Package fs (file system) is an independent component to operate file and directory. |
|
remote
Package remote provides an interface for interacting with various remote file systems such as S3, GCS, and distributed file systems for backup/restore operations.
|
Package remote provides an interface for interacting with various remote file systems such as S3, GCS, and distributed file systems for backup/restore operations. |
|
remote/aws
Package aws provides an AWS S3 file system implementation.
|
Package aws provides an AWS S3 file system implementation. |
|
remote/azure
Package azure provides an Azure Blob Storage implementation of the remote.FS interface.
|
Package azure provides an Azure Blob Storage implementation of the remote.FS interface. |
|
remote/checksum
Package checksum provides functions for computing checksums algorithms and verifying.
|
Package checksum provides functions for computing checksums algorithms and verifying. |
|
remote/config
Package config provides the configuration for the file system.
|
Package config provides the configuration for the file system. |
|
remote/gcp
Package gcp provides the GCS file system.
|
Package gcp provides the GCS file system. |
|
remote/local
Package local provides a local file system implementation.
|
Package local provides a local file system implementation. |
|
Package grpchelper implements helpers to access gRPC services.
|
Package grpchelper implements helpers to access gRPC services. |
|
Package healthcheck provides a health check client.
|
Package healthcheck provides a health check client. |
|
Package host provides information about the host.
|
Package host provides information about the host. |
|
Package idgen provides a lock-free snowflake ID generator for stream writes.
|
Package idgen provides a lock-free snowflake ID generator for stream writes. |
|
Package index implements the index system for searching data.
|
Package index implements the index system for searching data. |
|
analyzer
Package analyzer provides analyzers for indexing and searching.
|
Package analyzer provides analyzers for indexing and searching. |
|
inverted
Package inverted implements an inverted index repository.
|
Package inverted implements an inverted index repository. |
|
posting
Package posting implements a posting list contains a list of document ids.
|
Package posting implements a posting list contains a list of document ids. |
|
posting/roaring
Package roaring implements the posting list by a roaring bitmap.
|
Package roaring implements the posting list by a roaring bitmap. |
|
testcases
Package testcases implements common helpers for testing inverted and lsm indices.
|
Package testcases implements common helpers for testing inverted and lsm indices. |
|
Package initerror exposes a Permanent error contract for initialization failures that must not be retried.
|
Package initerror exposes a Permanent error contract for initialization failures that must not be retried. |
|
Package iter implement a generic Iterator.
|
Package iter implement a generic Iterator. |
|
sort
Package sort provides a generic iterator that merges multiple sorted iterators.
|
Package sort provides a generic iterator that merges multiple sorted iterators. |
|
Package logger implements a logging system with a module tag.
|
Package logger implements a logging system with a module tag. |
|
Package meter provides a simple meter system for metrics.
|
Package meter provides a simple meter system for metrics. |
|
native
Package native provides a simple meter system for metrics.
|
Package native provides a simple meter system for metrics. |
|
prom
Package prom provides a prometheus implementation for the meter system.
|
Package prom provides a prometheus implementation for the meter system. |
|
Package node provides node selector for liaison.
|
Package node provides node selector for liaison. |
|
Package panicdiag provides panic recovery helpers and crash artifact writing.
|
Package panicdiag provides panic recovery helpers and crash artifact writing. |
|
lintrawgo
Package lintrawgo provides a go/analysis Analyzer that fails the build when production code launches a goroutine via a raw `go` statement instead of run.Go, run.GoOrDie, or run.GoWithSignal.
|
Package lintrawgo provides a go/analysis Analyzer that fails the build when production code launches a goroutine via a raw `go` statement instead of run.Go, run.GoOrDie, or run.GoWithSignal. |
|
Package partition implements a location system to find a shard or index rule.
|
Package partition implements a location system to find a shard or index rule. |
|
Package path provides utilities to resolve relative paths to absolute paths.
|
Package path provides utilities to resolve relative paths to absolute paths. |
|
pb
|
|
|
v1
Package v1 implements helpers to access data defined by API v1.
|
Package v1 implements helpers to access data defined by API v1. |
|
v1/valuetype
Package valuetype holds the ValueType byte enum used to tag encoded tag and field values.
|
Package valuetype holds the ValueType byte enum used to tag encoded tag and field values. |
|
pipeline
|
|
|
sdk
Package sdk defines the contract between the BanyanDB post-trace pipeline engine and user-supplied native Go plugins (each a .so loaded in-process via the standard Go plugin package).
|
Package sdk defines the contract between the BanyanDB post-trace pipeline engine and user-supplied native Go plugins (each a .so loaded in-process via the standard Go plugin package). |
|
sdk/_example/segment-tail-sampler
command
Command segment-tail-sampler is the reference post-trace sampler plugin from docs/design/post-trace-pipeline.md §6.1.
|
Command segment-tail-sampler is the reference post-trace sampler plugin from docs/design/post-trace-pipeline.md §6.1. |
|
sdk/sdktest
Package sdktest is an offline test kit for pkg/pipeline/sdk sampler plugins: a fixture builder, a differential projection-guard runner, a chain harness, and a real-.so loader — all without a database or a cluster.
|
Package sdktest is an offline test kit for pkg/pipeline/sdk sampler plugins: a fixture builder, a differential projection-guard runner, a chain harness, and a real-.so loader — all without a database or a cluster. |
|
Package pool provides a pool for reusing objects.
|
Package pool provides a pool for reusing objects. |
|
Package query provides the query common interfaces and utilities.
|
Package query provides the query common interfaces and utilities. |
|
aggregation
Package aggregation implements aggregation functions to statistic a range of values.
|
Package aggregation implements aggregation functions to statistic a range of values. |
|
executor
Package executor defines the specifications accessing underlying data repositories.
|
Package executor defines the specifications accessing underlying data repositories. |
|
logical
Package logical implements the executable operations.
|
Package logical implements the executable operations. |
|
logical/measure
Package measure implements execution operations for querying measure data.
|
Package measure implements execution operations for querying measure data. |
|
logical/stream
Package stream implements execution operations for querying stream data.
|
Package stream implements execution operations for querying stream data. |
|
logical/trace
Package trace implements execution operations for querying trace data.
|
Package trace implements execution operations for querying trace data. |
|
model
Package model defines the structures and interfaces for query options and results.
|
Package model defines the structures and interfaces for query options and results. |
|
tracelabels
Package tracelabels defines stable query trace tag keys.
|
Package tracelabels defines stable query trace tag keys. |
|
vectorized
Package vectorized provides RecordBatch-based columnar execution primitives: schema, columns, operator interfaces, pipeline composition, and memory tracking.
|
Package vectorized provides RecordBatch-based columnar execution primitives: schema, columns, operator interfaces, pipeline composition, and memory tracking. |
|
vectorized/frame
Package frame defines the shared, engine-agnostic non-proto columnar binary frame carried as the SendResponse.body for a vec-native query topic.
|
Package frame defines the shared, engine-agnostic non-proto columnar binary frame carried as the SendResponse.body for a vec-native query topic. |
|
vectorized/measure
Package measure implements measure-specific vectorized operators (scan, cursor, extract, limit, group-by, aggregation, top, output serialization).
|
Package measure implements measure-specific vectorized operators (scan, cursor, extract, limit, group-by, aggregation, top, output serialization). |
|
vectorized/measure/frame
Package frame binds the shared vec columnar frame codec (pkg/query/vectorized/frame) to the measure engine.
|
Package frame binds the shared vec columnar frame codec (pkg/query/vectorized/frame) to the measure engine. |
|
vectorized/measure/plan
Package plan is the vectorized measure-query plan tree (G8).
|
Package plan is the vectorized measure-query plan tree (G8). |
|
vectorized/stream
Package stream implements stream-specific vectorized query operators: the pull pipeline that scans elements into columnar batches and merges them in index or timestamp order at egress.
|
Package stream implements stream-specific vectorized query operators: the pull pipeline that scans elements into columnar batches and merges them in index or timestamp order at egress. |
|
vectorized/stream/frame
Package frame binds the shared vec columnar frame codec (pkg/query/vectorized/frame) to the stream engine.
|
Package frame binds the shared vec columnar frame codec (pkg/query/vectorized/frame) to the stream engine. |
|
vectorized/trace
Package trace implements trace-specific vectorized query operators: the two-phase pull pipeline that resolves trace IDs (Phase 1) and materializes spans grouped per trace (Phase 2).
|
Package trace implements trace-specific vectorized query operators: the two-phase pull pipeline that resolves trace IDs (Phase 1) and materializes spans grouped per trace (Phase 2). |
|
Package run implements a lifecycle framework to control modules.
|
Package run implements a lifecycle framework to control modules. |
|
Package schema implements a framework to sync schema info from the metadata repository.
|
Package schema implements a framework to sync schema info from the metadata repository. |
|
registry
Package registry holds the per-node aggregator that routes barrier and node-status RPC lookups to the same per-service schema-repo caches the query executor consults.
|
Package registry holds the per-node aggregator that routes barrier and node-status RPC lookups to the same per-service schema-repo caches the query executor consults. |
|
Package signal implements a handler to listen to system signals.
|
Package signal implements a handler to listen to system signals. |
|
Package test implements helpers for testing.
|
Package test implements helpers for testing. |
|
flags
Package flags implements injected flags to run tests.
|
Package flags implements injected flags to run tests. |
|
flow
Package flow implements mockers for testing flow.
|
Package flow implements mockers for testing flow. |
|
gmatcher
Package gmatcher provides custom Gomega matchers.
|
Package gmatcher provides custom Gomega matchers. |
|
helpers
Package helpers implements several helpers for testing.
|
Package helpers implements several helpers for testing. |
|
measure
Package measure implements helpers to load schemas for testing.
|
Package measure implements helpers to load schemas for testing. |
|
property
Package property implements helpers to load schemas for testing.
|
Package property implements helpers to load schemas for testing. |
|
query
Package query provides functions for analyzing and collecting metrics.
|
Package query provides functions for analyzing and collecting metrics. |
|
replicated/measure
Package replicatedmeasure implements helpers to load replicated schemas for testing.
|
Package replicatedmeasure implements helpers to load replicated schemas for testing. |
|
replicated/stream
Package replicatedstream implements helpers to load replicated schemas for testing.
|
Package replicatedstream implements helpers to load replicated schemas for testing. |
|
replicated/trace
Package trace implements helpers to load replicated schemas for testing.
|
Package trace implements helpers to load replicated schemas for testing. |
|
setup
Package setup implements a real env in which to run tests.
|
Package setup implements a real env in which to run tests. |
|
stream
Package stream implements helpers to load schemas for testing.
|
Package stream implements helpers to load schemas for testing. |
|
trace
Package trace implements helpers to load schemas for testing.
|
Package trace implements helpers to load schemas for testing. |
|
Package timestamp implements several component related to time.
|
Package timestamp implements several component related to time. |
|
Package tls provides common TLS utilities for HTTP and gRPC servers.
|
Package tls provides common TLS utilities for HTTP and gRPC servers. |
|
Package version can be used to implement embedding versioning details from git branches and tags into the binary importing this package.
|
Package version can be used to implement embedding versioning details from git branches and tags into the binary importing this package. |
|
Package watcher provides a watcher to watch the epoch.
|
Package watcher provides a watcher to watch the epoch. |
Click to show internal directories.
Click to hide internal directories.