skywalking-banyandb

module
v0.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 24, 2026 License: Apache-2.0

README

BanyanDB

Continuous Integration Go Report Card GitHub release GitHub release date GoDoc

BanyanDB, as an observability database, aims to ingest, analyze and store Metrics, Tracing and Logging data. It's designed to handle observability data generated by observability platform and APM system, like Apache SkyWalking etc.

Introduction

BanyanDB, as an observability database, aims to ingest, analyze and store Metrics, Tracing, and Logging data. It's designed to handle observability data generated by Apache SkyWalking. Before BanyanDB emerges, the Databases that SkyWalking adopted are not ideal for the APM data model, especially for saving tracing and logging data. Consequently, There’s room to improve the performance and resource usage based on the nature of SkyWalking data patterns.

The database research community usually uses RUM Conjecture to describe how a database access data. BanyanDB combines several access methods to build a comprehensive APM database to balance read cost, update cost, and memory overhead.

Contact us

Documentation

Developer tooling

The dump trace-source-catalog subcommand validates the frozen downloaded trace benchmark shard and writes its deterministic core and secondary-index ledgers. It requires --source-path and a new, outside-source --output-path; see the trace pipeline merge performance design for the source contract.

The dump trace-generate-fixture subcommand consumes that catalog and the immutable downloaded shard, verifies the default SkyWalking sampler ratio, and writes the deterministic one-day core and secondary-index fixture through the data-node part receipt path. It requires --source-path, --catalog-path, a new --output-path, and the built sampler --plugin-path.

The trace benchmark receiver can enable per-merge JSONL recording for the primary, boundary-drain, and cooldown phases. Records classify actual sampler execution, preserve merge depth and input lineage, nest secondary-index work under its core merge, and expose reconciled low-cardinality aggregates plus serial-attribution resource deltas.

Contributing

For developers who want to contribute to this project, see the Contribution Guide.

License

Apache 2.0 License.

Directories

Path Synopsis
api
common
Package common defines reusable objects for APIs.
 Package common defines reusable objects for APIs.
data
Package data contains data transmission topics.
 Package data contains data transmission topics.
proto/banyandb
Package apiversion contains the version of the API.
 Package apiversion contains the version of the API.
validate
Package validate provides functions to validate the provided objects.
 Package validate provides functions to validate the provided objects.
Package banyand implements a executable database server.
 Package banyand implements a executable database server.
backup
Package backup provides the backup command-line tool.
 Package backup provides the backup command-line tool.
backup/lifecycle
Package lifecycle provides the lifecycle migration service.
 Package lifecycle provides the lifecycle migration service.
backup/snapshot
Package snapshot provides the snapshot backup and restore functionality.
 Package snapshot provides the snapshot backup and restore functionality.
cmd/backup command
Package main provides main entry for the backup command-line tool.
 Package main provides main entry for the backup command-line tool.
cmd/dump command
Package main provides a command-line tool to dump BanyanDB data.
 Package main provides a command-line tool to dump BanyanDB data.
cmd/lifecycle command
Package main provides main entry for the backup command-line tool.
 Package main provides main entry for the backup command-line tool.
cmd/migration command
Package main is the CLI entry point of the BanyanDB data-migration tool for the measure and stream catalogs.
 Package main is the CLI entry point of the BanyanDB data-migration tool for the measure and stream catalogs.
cmd/restore command
Package main provides main entry for the restore command-line tool.
 Package main provides main entry for the restore command-line tool.
cmd/server command
Package main implements the executable banyandb server named banyand.
 Package main implements the executable banyandb server named banyand.
cmd/trace-merge-benchmark command
Command trace-merge-benchmark runs controlled trace merge performance experiments.
 Command trace-merge-benchmark runs controlled trace merge performance experiments.
dquery
Package dquery implement the distributed query.
 Package dquery implement the distributed query.
internal/benchmark
Package benchmark contains deterministic filesystem helpers shared by the trace merge performance harness.
 Package benchmark contains deterministic filesystem helpers shared by the trace merge performance harness.
internal/benchmark/controller
Package controller provides the external publication boundary for trace merge benchmarks.
 Package controller provides the external publication boundary for trace merge benchmarks.
internal/benchmark/sourcecatalog
Package sourcecatalog validates and catalogs the immutable downloaded trace shard.
 Package sourcecatalog validates and catalogs the immutable downloaded trace shard.
internal/benchmark/tracebaseline
Package tracebaseline runs the constrained one-shard ordinary trace merge benchmark.
 Package tracebaseline runs the constrained one-shard ordinary trace merge benchmark.
internal/benchmark/tracefixture
Package tracefixture builds the deterministic hybrid trace merge benchmark fixture.
 Package tracefixture builds the deterministic hybrid trace merge benchmark fixture.
internal/dump
Package dump holds the shared decoding helpers reused by the measure, stream and trace part parsers under banyand/dump.
 Package dump holds the shared decoding helpers reused by the measure, stream and trace part parsers under banyand/dump.
internal/dump/measure
Package measure decodes the on-disk byte format of a measure part into rows.
 Package measure decodes the on-disk byte format of a measure part into rows.
internal/dump/stream
Package stream decodes the on-disk byte format of a stream part into rows.
 Package stream decodes the on-disk byte format of a stream part into rows.
internal/dump/trace
Package trace decodes the on-disk byte format of a trace part into rows.
 Package trace decodes the on-disk byte format of a trace part into rows.
internal/encoding
Package encoding provides tag value encoding functionality with optimal compression for different data types including int64, float64, and other types using dictionary encoding with fallback to plain encoding with zstd compression.
 Package encoding provides tag value encoding functionality with optimal compression for different data types including int64, float64, and other types using dictionary encoding with fallback to plain encoding with zstd compression.
internal/migration
Package migration orchestrates measure / stream data migration: it loads the YAML copy plan, classifies each group's catalog through the offline schema reader (with a backup-layout fallback), builds the per-group union sidx shared by both catalogs, and drives the per-(entry, group) executors implemented by banyand/measure and banyand/stream.
 Package migration orchestrates measure / stream data migration: it loads the YAML copy plan, classifies each group's catalog through the offline schema reader (with a backup-layout fallback), builds the per-group union sidx shared by both catalogs, and drives the per-(entry, group) executors implemented by banyand/measure and banyand/stream.
internal/sidx
Package sidx provides block structure and operations for organizing elements within parts for efficient storage and retrieval based on user-provided int64 keys.
 Package sidx provides block structure and operations for organizing elements within parts for efficient storage and retrieval based on user-provided int64 keys.
internal/snapshot
Package snapshot provides generic transaction coordination for snapshot-based systems.
 Package snapshot provides generic transaction coordination for snapshot-based systems.
internal/storage
Package storage implements a time-series-based storage engine.
 Package storage implements a time-series-based storage engine.
internal/test
Package test provides mock implementations for testing.
 Package test provides mock implementations for testing.
internal/wqueue
Package wqueue provides a write queue implementation for managing data shards.
 Package wqueue provides a write queue implementation for managing data shards.
liaison/grpc
Package grpc implements the gRPC services defined by APIs.
 Package grpc implements the gRPC services defined by APIs.
liaison/grpc/route
Package route defines interfaces and types for providing route table information.
 Package route defines interfaces and types for providing route table information.
liaison/http
Package http implements the gRPC gateway.
 Package http implements the gRPC gateway.
liaison/pkg/auth
Package auth provides configuration management and validation logic for authentication.
 Package auth provides configuration management and validation logic for authentication.
measure
Package measure implements a time-series-based storage which is consists of a sequence of data points.
 Package measure implements a time-series-based storage which is consists of a sequence of data points.
metadata
Package metadata implements the metadata storage system.
 Package metadata implements the metadata storage system.
metadata/discovery/common
Package common provides shared functionality for node discovery implementations.
 Package common provides shared functionality for node discovery implementations.
metadata/discovery/dns
Package dns implements DNS-based node discovery for distributed metadata management.
 Package dns implements DNS-based node discovery for distributed metadata management.
metadata/discovery/file
Package file implements file-based node discovery for distributed metadata management.
 Package file implements file-based node discovery for distributed metadata management.
metadata/discovery/none
Package none implements a no-op node discovery for standalone mode.
 Package none implements a no-op node discovery for standalone mode.
metadata/schema
Package schema implements CRUD schema.
 Package schema implements CRUD schema.
metadata/schema/property
Package property implements a property-based schema registry client.
 Package property implements a property-based schema registry client.
metadata/schema/reader
Package reader provides offline read access to the property-based schema catalog (the `_schema` bluge index written by the property schema server).
 Package reader provides offline read access to the property-based schema catalog (the `_schema` bluge index written by the property schema server).
metadata/schema/schemaserver
Package schemaserver implements a standalone gRPC server for schema property management.
 Package schemaserver implements a standalone gRPC server for schema property management.
metadata/service
Package service implements the metadata server wrapper.
 Package service implements the metadata server wrapper.
observability
Package observability provides metrics, profiling, and etc.
 Package observability provides metrics, profiling, and etc.
observability/services
Package services is the service provider of observability real works.
 Package services is the service provider of observability real works.
property
Package property provides the property service interface.
 Package property provides the property service interface.
property/db
Package db introduce the property storage database.
 Package db introduce the property storage database.
property/gossip
Package gossip implements the gossip protocol for BanyanDB property repair.
 Package gossip implements the gossip protocol for BanyanDB property repair.
protector
Package protector provides a set of protectors that stop the query services when the resource usage exceeds the limit.
 Package protector provides a set of protectors that stop the query services when the resource usage exceeds the limit.
query
Package query implement the query module for liaison and other modules to retrieve data.
 Package query implement the query module for liaison and other modules to retrieve data.
queue
Package queue implements the data transmission queue.
 Package queue implements the data transmission queue.
queue/pub
Package pub implements the queue client.
 Package pub implements the queue client.
queue/sub
Package sub implements the queue server.
 Package sub implements the queue server.
queue/test
stream
Package stream implements a time-series-based storage which is consists of a sequence of element.
 Package stream implements a time-series-based storage which is consists of a sequence of element.
trace
Package trace implements a trace-based storage which consists of trace data.
 Package trace implements a trace-based storage which consists of trace data.
bydbctl
cmd/cli command
Package main provides main entry for the command-line toolkit, i.e.
 Package main provides main entry for the command-line toolkit, i.e.
internal/cmd
Package cmd is an internal package defining cli commands for bydbctl.
 Package cmd is an internal package defining cli commands for bydbctl.
internal/tui/agent
Package agent defines provider-neutral contracts for coding agent integration.
 Package agent defines provider-neutral contracts for coding agent integration.
internal/tui/agent/claude
Package claude provides a fail-closed Claude CLI gateway for bydbctl.
 Package claude provides a fail-closed Claude CLI gateway for bydbctl.
internal/tui/agent/codex
Package codex provides a fail-closed Codex app-server gateway for bydbctl.
 Package codex provides a fail-closed Codex app-server gateway for bydbctl.
internal/tui/agent/fake
Package fake provides a deterministic agent implementation for TUI tests and demos.
 Package fake provides a deterministic agent implementation for TUI tests and demos.
internal/tui/agent/prompt
Package prompt builds BYDBQL generation prompts for agent adapters.
 Package prompt builds BYDBQL generation prompts for agent adapters.
internal/tui/app
Package app implements the Bubble Tea user interface for bydbctl agent.
 Package app implements the Bubble Tea user interface for bydbctl agent.
internal/tui/applog
Package applog writes detailed bydbctl agent TUI diagnostics to a session log file.
 Package applog writes detailed bydbctl agent TUI diagnostics to a session log file.
internal/tui/bridge
Package bridge provides the private, bydbctl-owned tool set exposed to agents.
 Package bridge provides the private, bydbctl-owned tool set exposed to agents.
internal/tui/bydbql
Package bydbql validates BYDBQL candidates for the bydbctl agent TUI workflow.
 Package bydbql validates BYDBQL candidates for the bydbctl agent TUI workflow.
internal/tui/catalog
Package catalog provides deterministic BanyanDB resource ranking and matching.
 Package catalog provides deterministic BanyanDB resource ranking and matching.
internal/tui/execution
Package execution owns the shared validation and execution lifecycle for BYDBQL candidates.
 Package execution owns the shared validation and execution lifecycle for BYDBQL candidates.
internal/tui/planner
Package planner validates structured query plans and deterministically renders BYDBQL.
 Package planner validates structured query plans and deterministically renders BYDBQL.
internal/tui/session
Package session defines the durable state shared by the bydbctl agent TUI workflow and agent adapters.
 Package session defines the durable state shared by the bydbctl agent TUI workflow and agent adapters.
internal/tui/tools
Package tools defines the bydbctl-owned tool boundary used by the TUI workflow.
 Package tools defines the bydbctl-owned tool boundary used by the TUI workflow.
internal/tui/tuirun
Package tuirun launches the agent TUI's background goroutines under panic recovery.
 Package tuirun launches the agent TUI's background goroutines under panic recovery.
internal/tui/tuitext
Package tuitext holds the string helpers shared across the agent TUI packages.
 Package tuitext holds the string helpers shared across the agent TUI packages.
internal/tui/workflow
Package workflow owns the deterministic BYDBQL assistant state machine.
 Package workflow owns the deterministic BYDBQL assistant state machine.
pkg/file
Package file provides utils to handle files.
 Package file provides utils to handle files.
cmd
m4-seed command
Command m4-seed seeds a live BanyanDB cluster with demo data for the Canopy M4 query console review.
 Command m4-seed seeds a live BanyanDB cluster with demo data for the Canopy M4 query console review.
soak-driver command
Package main implements the soak-driver CLI for the G5d soak harness.
 Package main implements the soak-driver CLI for the G5d soak harness.
fodc
agent/cmd/agent command
Package main provides main entry for the FODC agent.
 Package main provides main entry for the FODC agent.
agent/internal/cluster
Package cluster provides cluster state collection functionality for FODC agent.
 Package cluster provides cluster state collection functionality for FODC agent.
agent/internal/cmd
Package cmd is an internal package defining cli commands for fodc.
 Package cmd is an internal package defining cli commands for fodc.
agent/internal/crashcollector
Package crashcollector provides components to collect crash artifacts from multiple sources, deduplicate them, and expose them for analysis.
 Package crashcollector provides components to collect crash artifacts from multiple sources, deduplicate them, and expose them for analysis.
agent/internal/exporter
Package exporter implements Prometheus metrics exporter for FlightRecorder Datasources.
 Package exporter implements Prometheus metrics exporter for FlightRecorder Datasources.
agent/internal/flightrecorder
Package flightrecorder implements a flight recorder for metrics data.
 Package flightrecorder implements a flight recorder for metrics data.
agent/internal/ktm
Package ktm is a module that monitors I/O operations in the kernel.
 Package ktm is a module that monitors I/O operations in the kernel.
agent/internal/ktm/iomonitor
Package iomonitor implements I/O monitoring using eBPF.
 Package iomonitor implements I/O monitoring using eBPF.
agent/internal/ktm/iomonitor/ebpf
Package ebpf provides eBPF program loading and management functionality.
 Package ebpf provides eBPF program loading and management functionality.
agent/internal/lifecycle
Package lifecycle provides lifecycle data collection functionality for FODC agent.
 Package lifecycle provides lifecycle data collection functionality for FODC agent.
agent/internal/metrics
Package metrics implements parsing of Prometheus text format metrics.
 Package metrics implements parsing of Prometheus text format metrics.
agent/internal/pressureprofiler
Package pressureprofiler captures heap and goroutine pprof profiles from the monitored BanyanDB container when its RSS approaches the cgroup memory limit, stores them on a shared volume, and exposes them to the FODC proxy.
 Package pressureprofiler captures heap and goroutine pprof profiles from the monitored BanyanDB container when its RSS approaches the cgroup memory limit, stores them on a shared volume, and exposes them to the FODC proxy.
agent/internal/proxy
Package proxy provides a client for communicating with the FODC Proxy.
 Package proxy provides a client for communicating with the FODC Proxy.
agent/internal/server
Package server provides HTTP server functionality for exposing Prometheus metrics.
 Package server provides HTTP server functionality for exposing Prometheus metrics.
agent/internal/watchdog
Package watchdog implements a watchdog for metrics data.
 Package watchdog implements a watchdog for metrics data.
agent/testhelper
Package testhelper provides test helpers for FODC agent components.
 Package testhelper provides test helpers for FODC agent components.
internal/consistency
Package consistency derives and fingerprints schema state so the registry, node-cache and runtime views can be compared with identical semantics.
 Package consistency derives and fingerprints schema state so the registry, node-cache and runtime views can be compared with identical semantics.
internal/pprofcapture
Package pprofcapture defines the canonical set of pprof profiles the FODC agent captures under memory pressure.
 Package pprofcapture defines the canonical set of pprof profiles the FODC agent captures under memory pressure.
internal/timeouts
Package timeouts holds timeout constants shared between the FODC agent and proxy.
 Package timeouts holds timeout constants shared between the FODC agent and proxy.
proxy/cmd/proxy command
Package main is the main package for the FODC Proxy.
 Package main is the main package for the FODC Proxy.
proxy/internal/api
Package api provides functionality for the API server.
 Package api provides functionality for the API server.
proxy/internal/cluster
Package cluster provides cluster state management for FODC proxy.
 Package cluster provides cluster state management for FODC proxy.
proxy/internal/diagnostics
Package diagnostics provides functionality for aggregating crash/panic diagnostic data from all agents.
 Package diagnostics provides functionality for aggregating crash/panic diagnostic data from all agents.
proxy/internal/grpc
Package grpc provides functionality for the gRPC server.
 Package grpc provides functionality for the gRPC server.
proxy/internal/lifecycle
Package lifecycle provides lifecycle state management for FODC proxy.
 Package lifecycle provides lifecycle state management for FODC proxy.
proxy/internal/metrics
Package metrics provides functionality for aggregating and enriching metrics from all agents.
 Package metrics provides functionality for aggregating and enriching metrics from all agents.
proxy/internal/pressure
Package pressure aggregates memory-pressure pprof profile metadata from all agents.
 Package pressure aggregates memory-pressure pprof profile metadata from all agents.
proxy/internal/registry
Package registry provides functionality for managing and tracking FODC agents.
 Package registry provides functionality for managing and tracking FODC agents.
mcp
tools/bydbql-parse command
pkg
accesslog
Package accesslog provides access log for banyandb.
 Package accesslog provides access log for banyandb.
auth
Package auth contains authentication helper functions.
 Package auth contains authentication helper functions.
bus
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.
bydbql
Package bydbql provides BanyanDB Query Language (BydbQL) parsing and translation capabilities.
 Package bydbql provides BanyanDB Query Language (BydbQL) parsing and translation capabilities.
bytes
Package bytes provides utilities for operating bytes.
 Package bytes provides utilities for operating bytes.
cgroups
Package cgroups provides a way to get the number of CPUs.
 Package cgroups provides a way to get the number of CPUs.
cmdsetup
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.
config
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.
convert
Package convert implements conversions to and from data.
 Package convert implements conversions to and from data.
dump
Package dump provides utilities for dumping BanyanDB data.
 Package dump provides utilities for dumping BanyanDB data.
encoding
Package encoding implements encoding/decoding data points.
 Package encoding implements encoding/decoding data points.
encoding/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).
filter
Package filter defines and implements data structures and interfaces for skipping index.
 Package filter defines and implements data structures and interfaces for skipping index.
flow
Package flow implements a streaming calculation framework.
 Package flow implements a streaming calculation framework.
flow/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.
flow/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.
fs
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.
fs/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.
fs/remote/aws
Package aws provides an AWS S3 file system implementation.
 Package aws provides an AWS S3 file system implementation.
fs/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.
fs/remote/checksum
Package checksum provides functions for computing checksums algorithms and verifying.
 Package checksum provides functions for computing checksums algorithms and verifying.
fs/remote/config
Package config provides the configuration for the file system.
 Package config provides the configuration for the file system.
fs/remote/gcp
Package gcp provides the GCS file system.
 Package gcp provides the GCS file system.
fs/remote/local
Package local provides a local file system implementation.
 Package local provides a local file system implementation.
grpchelper
Package grpchelper implements helpers to access gRPC services.
 Package grpchelper implements helpers to access gRPC services.
healthcheck
Package healthcheck provides a health check client.
 Package healthcheck provides a health check client.
host
Package host provides information about the host.
 Package host provides information about the host.
idgen
Package idgen provides a lock-free snowflake ID generator for stream writes.
 Package idgen provides a lock-free snowflake ID generator for stream writes.
index
Package index implements the index system for searching data.
 Package index implements the index system for searching data.
index/analyzer
Package analyzer provides analyzers for indexing and searching.
 Package analyzer provides analyzers for indexing and searching.
index/inverted
Package inverted implements an inverted index repository.
 Package inverted implements an inverted index repository.
index/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.
index/posting/roaring
Package roaring implements the posting list by a roaring bitmap.
 Package roaring implements the posting list by a roaring bitmap.
index/testcases
Package testcases implements common helpers for testing inverted and lsm indices.
 Package testcases implements common helpers for testing inverted and lsm indices.
initerror
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.
iter
Package iter implement a generic Iterator.
 Package iter implement a generic Iterator.
iter/sort
Package sort provides a generic iterator that merges multiple sorted iterators.
 Package sort provides a generic iterator that merges multiple sorted iterators.
logger
Package logger implements a logging system with a module tag.
 Package logger implements a logging system with a module tag.
meter
Package meter provides a simple meter system for metrics.
 Package meter provides a simple meter system for metrics.
meter/native
Package native provides a simple meter system for metrics.
 Package native provides a simple meter system for metrics.
meter/prom
Package prom provides a prometheus implementation for the meter system.
 Package prom provides a prometheus implementation for the meter system.
node
Package node provides node selector for liaison.
 Package node provides node selector for liaison.
panicdiag
Package panicdiag provides panic recovery helpers and crash artifact writing.
 Package panicdiag provides panic recovery helpers and crash artifact writing.
panicdiag/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.
partition
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.
path
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.
pb/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).
pipeline/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.
pipeline/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.
pool
Package pool provides a pool for reusing objects.
 Package pool provides a pool for reusing objects.
query
Package query provides the query common interfaces and utilities.
 Package query provides the query common interfaces and utilities.
query/aggregation
Package aggregation implements aggregation functions to statistic a range of values.
 Package aggregation implements aggregation functions to statistic a range of values.
query/executor
Package executor defines the specifications accessing underlying data repositories.
 Package executor defines the specifications accessing underlying data repositories.
query/logical
Package logical implements the executable operations.
 Package logical implements the executable operations.
query/logical/measure
Package measure implements execution operations for querying measure data.
 Package measure implements execution operations for querying measure data.
query/logical/stream
Package stream implements execution operations for querying stream data.
 Package stream implements execution operations for querying stream data.
query/logical/trace
Package trace implements execution operations for querying trace data.
 Package trace implements execution operations for querying trace data.
query/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.
query/tracelabels
Package tracelabels defines stable query trace tag keys.
 Package tracelabels defines stable query trace tag keys.
query/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.
query/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.
query/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).
query/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.
query/vectorized/measure/plan
Package plan is the vectorized measure-query plan tree (G8).
 Package plan is the vectorized measure-query plan tree (G8).
query/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.
query/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.
query/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).
run
Package run implements a lifecycle framework to control modules.
 Package run implements a lifecycle framework to control modules.
schema
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.
schema/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.
signal
Package signal implements a handler to listen to system signals.
 Package signal implements a handler to listen to system signals.
test
Package test implements helpers for testing.
 Package test implements helpers for testing.
test/flags
Package flags implements injected flags to run tests.
 Package flags implements injected flags to run tests.
test/flow
Package flow implements mockers for testing flow.
 Package flow implements mockers for testing flow.
test/gmatcher
Package gmatcher provides custom Gomega matchers.
 Package gmatcher provides custom Gomega matchers.
test/helpers
Package helpers implements several helpers for testing.
 Package helpers implements several helpers for testing.
test/measure
Package measure implements helpers to load schemas for testing.
 Package measure implements helpers to load schemas for testing.
test/property
Package property implements helpers to load schemas for testing.
 Package property implements helpers to load schemas for testing.
test/query
Package query provides functions for analyzing and collecting metrics.
 Package query provides functions for analyzing and collecting metrics.
test/replicated/measure
Package replicatedmeasure implements helpers to load replicated schemas for testing.
 Package replicatedmeasure implements helpers to load replicated schemas for testing.
test/replicated/stream
Package replicatedstream implements helpers to load replicated schemas for testing.
 Package replicatedstream implements helpers to load replicated schemas for testing.
test/replicated/trace
Package trace implements helpers to load replicated schemas for testing.
 Package trace implements helpers to load replicated schemas for testing.
test/setup
Package setup implements a real env in which to run tests.
 Package setup implements a real env in which to run tests.
test/stream
Package stream implements helpers to load schemas for testing.
 Package stream implements helpers to load schemas for testing.
test/trace
Package trace implements helpers to load schemas for testing.
 Package trace implements helpers to load schemas for testing.
timestamp
Package timestamp implements several component related to time.
 Package timestamp implements several component related to time.
tls
Package tls provides common TLS utilities for HTTP and gRPC servers.
 Package tls provides common TLS utilities for HTTP and gRPC servers.
version
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.
watcher
Package watcher provides a watcher to watch the epoch.
 Package watcher provides a watcher to watch the epoch.
plugins
skywalking/internal/tracesampler
Package tracesampler is the shared post-trace sampler engine behind the first-party sw-trace-sampler and zipkin-trace-sampler plugins.
 Package tracesampler is the shared post-trace sampler engine behind the first-party sw-trace-sampler and zipkin-trace-sampler plugins.
skywalking/sw-trace-sampler command
Command sw-trace-sampler is the first-party post-trace sampler for the SkyWalking-native segment schema (group sw_trace, BanyanDB trace "segment").
 Command sw-trace-sampler is the first-party post-trace sampler for the SkyWalking-native segment schema (group sw_trace, BanyanDB trace "segment").
skywalking/zipkin-trace-sampler command
Command zipkin-trace-sampler is the first-party post-trace sampler for the Zipkin schema (group sw_zipkinTrace, BanyanDB trace "zipkin_span").
 Command zipkin-trace-sampler is the first-party post-trace sampler for the Zipkin schema (group sw_zipkinTrace, BanyanDB trace "zipkin_span").
scripts
lint/rawgo command
Command rawgo enforces the project's "no raw goroutines outside the recovery wrappers" rule.
 Command rawgo enforces the project's "no raw goroutines outside the recovery wrappers" rule.
lint/rawgo-baseline command
Command rawgo-baseline rewrites the raw-go baseline from the current tree.
 Command rawgo-baseline rewrites the raw-go baseline from the current tree.
test
cases
Package cases provides some tools to access test data.
 Package cases provides some tools to access test data.
cases/backup
Package backup_test provides the test cases for the backup command-line tool.
 Package backup_test provides the test cases for the backup command-line tool.
cases/lifecycle
Package lifecycle_test is the test cases for the lifecycle package.
 Package lifecycle_test is the test cases for the lifecycle package.
cases/measure
Package measure_test contains integration test cases of the measure.
 Package measure_test contains integration test cases of the measure.
cases/measure/cmd/generate command
Package main implements the capture subcommand for the test-case generator.
 Package main implements the capture subcommand for the test-case generator.
cases/measure/data
Package data contains integration test cases of the measure.
 Package data contains integration test cases of the measure.
cases/property
Package property includes test cases for property queries.
 Package property includes test cases for property queries.
cases/property/data
Package data includes utilities for property test data management and verification.
 Package data includes utilities for property test data management and verification.
cases/schema
Package schema contains shared test cases for schema-related functionality.
 Package schema contains shared test cases for schema-related functionality.
cases/stream
Package stream_test contains integration test cases of the stream.
 Package stream_test contains integration test cases of the stream.
cases/stream/cmd/generate command
Package main generates stream query integration-test cases (input/*.ql, input/*.yaml, want/*.yaml).
 Package main generates stream query integration-test cases (input/*.ql, input/*.yaml, want/*.yaml).
cases/stream/data
Package data contains integration test cases of the stream.
 Package data contains integration test cases of the stream.
cases/topn
Package topn_test contains integration test cases of the TopN.
 Package topn_test contains integration test cases of the TopN.
cases/topn/data
Package data contains integration test cases of the topN.
 Package data contains integration test cases of the topN.
cases/trace
Package trace_test contains integration test cases of the trace.
 Package trace_test contains integration test cases of the trace.
cases/trace/cmd/generate command
Package main generates trace query integration-test cases (input/*.ql and input/*.yml).
 Package main generates trace query integration-test cases (input/*.ql and input/*.yml).
cases/trace/data
Package data is used to test the trace service.
 Package data is used to test the trace service.
cases/tracepipeline
Package tracepipeline_test contains integration test cases for the trace pipeline filter.
 Package tracepipeline_test contains integration test cases for the trace pipeline filter.
cases/tracepipeline/data
Package data is used to test the trace pipeline service.
 Package data is used to test the trace pipeline service.
integration/distributed
Package distributed is a distributed integration test suite.
 Package distributed is a distributed integration test suite.
integration/distributed/backup
Package backup and recovery tests for different storage types in distributed mode.
 Package backup and recovery tests for different storage types in distributed mode.
integration/distributed/cluster_state
Package clusterstate provides shared test setup for distributed cluster state integration tests.
 Package clusterstate provides shared test setup for distributed cluster state integration tests.
integration/distributed/deletion
Package deletion provides shared test setup for distributed group deletion integration tests.
 Package deletion provides shared test setup for distributed group deletion integration tests.
integration/distributed/inspection
Package inspection provides shared test setup for the inspect functionality in distributed mode.
 Package inspection provides shared test setup for the inspect functionality in distributed mode.
integration/distributed/lifecycle
Package lifecycle provides shared test setup for distributed lifecycle integration tests.
 Package lifecycle provides shared test setup for distributed lifecycle integration tests.
integration/distributed/multi_segments
Package multisegments provides shared test setup for distributed multi-segment integration tests.
 Package multisegments provides shared test setup for distributed multi-segment integration tests.
integration/distributed/pipeline
Package pipeline_test provides an out-of-process distributed integration test for the trace in-merge filter via the .so sampler plugin on two external data nodes with one external liaison.
 Package pipeline_test provides an out-of-process distributed integration test for the trace in-merge filter via the .so sampler plugin on two external data nodes with one external liaison.
integration/distributed/query
Package query contains integration tests for distributed query.
 Package query contains integration tests for distributed query.
integration/distributed/querybench
Package querybench is the docker-gated distributed-query benchmark harness that drives row vs vec mode comparisons across scenarios and cardinalities.
 Package querybench is the docker-gated distributed-query benchmark harness that drives row vs vec mode comparisons across scenarios and cardinalities.
integration/distributed/schema
Package schema contains integration tests for distributed schema deletion.
 Package schema contains integration tests for distributed schema deletion.
integration/distributed/sync_retry
Package integration_sync_retry_test provides test utilities for sync retry integration tests.
 Package integration_sync_retry_test provides test utilities for sync retry integration tests.
integration/dockertesthelper
Package dockertesthelper provides utilities and constants for managing Docker containers.
 Package dockertesthelper provides utilities and constants for managing Docker containers.
integration/replication/benchmark
integration/standalone
Package standalone is a standalone integration test suite.
 Package standalone is a standalone integration test suite.
integration/standalone/backup
Package backup Conduct backup and recovery tests for different storage types in standalone mode.
 Package backup Conduct backup and recovery tests for different storage types in standalone mode.
integration/standalone/cold_query
Package coldquery provides shared test setup for cold data query integration tests.
 Package coldquery provides shared test setup for cold data query integration tests.
integration/standalone/deletion
Package deletion contains integration tests for standalone group deletion.
 Package deletion contains integration tests for standalone group deletion.
integration/standalone/inspection
Package inspection provides integration tests for the inspect functionality in standalone mode.
 Package inspection provides integration tests for the inspect functionality in standalone mode.
integration/standalone/multi_segments
Package multisegments provides shared test setup for multi-segment integration tests.
 Package multisegments provides shared test setup for multi-segment integration tests.
integration/standalone/observability
Package observability provides shared setup and helpers for standalone observability integration tests.
 Package observability provides shared setup and helpers for standalone observability integration tests.
integration/standalone/other
Package other provides shared test setup for miscellaneous standalone integration tests.
 Package other provides shared test setup for miscellaneous standalone integration tests.
integration/standalone/pipeline
Package pipeline_test provides an out-of-process integration test for the trace in-merge filter via the .so sampler plugin.
 Package pipeline_test provides an out-of-process integration test for the trace in-merge filter via the .so sampler plugin.
integration/standalone/query
Package query provides shared test setup for query integration tests.
 Package query provides shared test setup for query integration tests.
integration/standalone/schema
Package schema contains integration tests for standalone schema deletion.
 Package schema contains integration tests for standalone schema deletion.
plugin-sidecar/register command
Command register creates the trace group + schema and attaches a trace pipeline (a single latency-status sampler) so a standalone data node reconciles it and calls plugin.Open on the carrier-mounted .so.
 Command register creates the trace group + schema and attaches a trace pipeline (a single latency-status sampler) so a standalone data node reconciles it and calls plugin.Open on the carrier-mounted .so.
plugins/_alwayskeepsampler command
Command alwayskeepsampler is the metadata-only native plugin used to measure the minimum trace-pipeline framework cost.
 Command alwayskeepsampler is the metadata-only native plugin used to measure the minimum trace-pipeline framework cost.
plugins/_deterministicdropsampler command
Command deterministicdropsampler is the metadata-only native plugin used to measure trace deletion and secondary-index pruning independently of application logic.
 Command deterministicdropsampler is the metadata-only native plugin used to measure trace deletion and secondary-index pruning independently of application logic.
plugins/_faultysampler command
Command faultysampler is an adversarial reference post-trace sampler plugin that verifies the engine's host-side bounds hold under hostile plugin behaviour.
 Command faultysampler is an adversarial reference post-trace sampler plugin that verifies the engine's host-side bounds hold under hostile plugin behaviour.
plugins/_latencystatussampler command
Command latencystatussampler is a post-trace sampler plugin that drops a trace when its duration (in milliseconds, read from the "duration" tag) is below a configured threshold AND its "status" tag equals a configured success value.
 Command latencystatussampler is a post-trace sampler plugin that drops a trace when its duration (in milliseconds, read from the "duration" tag) is below a configured threshold AND its "status" tag equals a configured success value.
plugins/_telemetrysampler command
Command telemetrysampler is a reference post-trace sampler plugin that demonstrates well-behaved use of the sdk.HostAware telemetry façade.
 Command telemetrysampler is a reference post-trace sampler plugin that demonstrates well-behaved use of the sdk.HostAware telemetry façade.
property_repair
Package propertyrepair package provides utilities for property repair performance testing in BanyanDB.
 Package propertyrepair package provides utilities for property repair performance testing in BanyanDB.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.