This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a change to branch bydb-parameter
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
from 3d60e0235 fix ci
add 1a2696b8a feat(trace): bounded meter + logger telemetry for the
sampler plugin SDK (#1206)
add a26e49ffd Merge branch 'main' into bydb-parameter
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
Makefile | 18 +-
banyand/trace/metadata.go | 115 +++-
banyand/trace/pipeline_loader.go | 46 +-
banyand/trace/pipeline_loader_test.go | 22 +-
banyand/trace/pipeline_metrics.go | 44 +-
banyand/trace/pipeline_metrics_test.go | 102 ++-
banyand/trace/pipeline_registry.go | 47 +-
banyand/trace/pipeline_watch_test.go | 18 +-
banyand/trace/plugin_telemetry.go | 712 ++++++++++++++++++++
banyand/trace/plugin_telemetry_integration_test.go | 550 +++++++++++++++
banyand/trace/plugin_telemetry_realso_test.go | 746 +++++++++++++++++++++
banyand/trace/plugin_telemetry_test.go | 378 +++++++++++
docs/design/post-trace-pipeline.md | 58 ++
pkg/encoding/array.go | 80 +--
pkg/encoding/{array.go => vararray/vararray.go} | 9 +-
pkg/pb/v1/value.go | 27 +-
.../pb/v1/valuetype/valuetype.go | 23 +-
pkg/pipeline/sdk/decode.go | 28 +-
pkg/pipeline/sdk/importgraph_test.go | 87 +++
pkg/pipeline/sdk/sdk.go | 21 +-
pkg/pipeline/sdk/telemetry.go | 104 +++
test/plugins/_faultysampler/main.go | 159 +++++
test/plugins/_latencystatussampler/main.go | 6 +-
test/plugins/_telemetrysampler/main.go | 128 ++++
test/plugins/telemetry_smoke_test.go | 171 +++++
26 files changed, 3506 insertions(+), 194 deletions(-)
create mode 100644 banyand/trace/plugin_telemetry.go
create mode 100644 banyand/trace/plugin_telemetry_integration_test.go
create mode 100644 banyand/trace/plugin_telemetry_realso_test.go
create mode 100644 banyand/trace/plugin_telemetry_test.go
copy pkg/encoding/{array.go => vararray/vararray.go} (86%)
copy banyand/trace/constants.go => pkg/pb/v1/valuetype/valuetype.go (52%)
create mode 100644 pkg/pipeline/sdk/importgraph_test.go
create mode 100644 pkg/pipeline/sdk/telemetry.go
create mode 100644 test/plugins/_faultysampler/main.go
create mode 100644 test/plugins/_telemetrysampler/main.go
create mode 100644 test/plugins/telemetry_smoke_test.go
