-
Notifications
You must be signed in to change notification settings - Fork 1.1k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(exp/metricsserver): Expose metrics over libp2p streams
Allows users to run a Prometheus+Grafana setup remotely and gather metrics securely over libp2p.
- Loading branch information
Showing
5 changed files
with
934 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,66 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "log" | ||
| "net/http/httputil" | ||
| "net/url" | ||
| "os" | ||
| "os/signal" | ||
| "strings" | ||
|
|
||
| "github.com/libp2p/go-libp2p" | ||
| libp2phttp "github.com/libp2p/go-libp2p/p2p/http" | ||
| "github.com/multiformats/go-multiaddr" | ||
| ) | ||
|
|
||
| func main() { | ||
| proxyTarget := os.Getenv("PROXY_TARGET") | ||
| if proxyTarget == "" { | ||
| log.Fatal("PROXY_TARGET must be set") | ||
| } | ||
|
|
||
| h, err := libp2p.New(libp2p.ListenAddrStrings( | ||
| "/ip4/0.0.0.0/tcp/0", | ||
| "/ip4/0.0.0.0/tcp/0", | ||
| )) | ||
| if err != nil { | ||
| log.Fatal(err) | ||
| } | ||
| defer h.Close() | ||
|
|
||
| const multiaddrPrefix = "multiaddr:" | ||
| if !strings.HasPrefix(proxyTarget, multiaddrPrefix) { | ||
| log.Fatalf("PROXY_TARGET must start with %q", multiaddrPrefix) | ||
| } | ||
|
|
||
| targetUrl, _ := url.Parse(proxyTarget) | ||
|
|
||
| httpHost := libp2phttp.Host{ | ||
| StreamHost: h, | ||
| InsecureAllowHTTP: true, | ||
| ListenAddrs: []multiaddr.Multiaddr{multiaddr.StringCast("/ip4/0.0.0.0/tcp/5005/http")}, | ||
| } | ||
|
|
||
| // reverse proxy | ||
| proxy := &httputil.ReverseProxy{ | ||
| Rewrite: func(r *httputil.ProxyRequest) { | ||
| copiedURL := *targetUrl | ||
| r.Out.URL = &copiedURL | ||
| }, | ||
| Transport: &httpHost, | ||
| } | ||
|
|
||
| httpHost.SetHTTPHandlerAtPath("/http-reverse-proxy/0.0.1", "/", proxy) | ||
| go httpHost.Serve() | ||
|
|
||
| log.Println("Listening on:") | ||
| for _, a := range httpHost.Addrs() { | ||
| log.Println(a.Encapsulate(multiaddr.StringCast("/p2p/" + h.ID().String()))) | ||
| } | ||
|
|
||
| // Wait for interrupt signal to stop | ||
| intSig := make(chan os.Signal, 1) | ||
| signal.Notify(intSig, os.Interrupt) | ||
| <-intSig | ||
| log.Println("Interrupt signal received, closing host") | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,114 @@ | ||
| module github.com/libp2p/go-libp2p/exp | ||
|
|
||
| go 1.22.1 | ||
|
|
||
| require ( | ||
| github.com/ipfs/go-log/v2 v2.5.1 | ||
| github.com/libp2p/go-libp2p v0.37.0 | ||
| github.com/prometheus/client_golang v1.20.5 | ||
| go.uber.org/fx v1.23.0 | ||
| ) | ||
|
|
||
| require ( | ||
| github.com/benbjohnson/clock v1.3.5 // indirect | ||
| github.com/beorn7/perks v1.0.1 // indirect | ||
| github.com/cespare/xxhash/v2 v2.3.0 // indirect | ||
| github.com/containerd/cgroups v1.1.0 // indirect | ||
| github.com/coreos/go-systemd/v22 v22.5.0 // indirect | ||
| github.com/davecgh/go-spew v1.1.1 // indirect | ||
| github.com/davidlazar/go-crypto v0.0.0-20200604182044-b73af7476f6c // indirect | ||
| github.com/decred/dcrd/dcrec/secp256k1/v4 v4.3.0 // indirect | ||
| github.com/docker/go-units v0.5.0 // indirect | ||
| github.com/elastic/gosigar v0.14.3 // indirect | ||
| github.com/flynn/noise v1.1.0 // indirect | ||
| github.com/francoispqt/gojay v1.2.13 // indirect | ||
| github.com/go-task/slim-sprig/v3 v3.0.0 // indirect | ||
| github.com/godbus/dbus/v5 v5.1.0 // indirect | ||
| github.com/gogo/protobuf v1.3.2 // indirect | ||
| github.com/google/gopacket v1.1.19 // indirect | ||
| github.com/google/pprof v0.0.0-20241017200806-017d972448fc // indirect | ||
| github.com/google/uuid v1.6.0 // indirect | ||
| github.com/gorilla/websocket v1.5.3 // indirect | ||
| github.com/hashicorp/golang-lru/v2 v2.0.7 // indirect | ||
| github.com/huin/goupnp v1.3.0 // indirect | ||
| github.com/ipfs/go-cid v0.4.1 // indirect | ||
| github.com/jackpal/go-nat-pmp v1.0.2 // indirect | ||
| github.com/jbenet/go-temp-err-catcher v0.1.0 // indirect | ||
| github.com/klauspost/compress v1.17.11 // indirect | ||
| github.com/klauspost/cpuid/v2 v2.2.8 // indirect | ||
| github.com/koron/go-ssdp v0.0.4 // indirect | ||
| github.com/libp2p/go-buffer-pool v0.1.0 // indirect | ||
| github.com/libp2p/go-flow-metrics v0.2.0 // indirect | ||
| github.com/libp2p/go-libp2p-asn-util v0.4.1 // indirect | ||
| github.com/libp2p/go-msgio v0.3.0 // indirect | ||
| github.com/libp2p/go-nat v0.2.0 // indirect | ||
| github.com/libp2p/go-netroute v0.2.1 // indirect | ||
| github.com/libp2p/go-reuseport v0.4.0 // indirect | ||
| github.com/libp2p/go-yamux/v4 v4.0.1 // indirect | ||
| github.com/marten-seemann/tcp v0.0.0-20210406111302-dfbc87cc63fd // indirect | ||
| github.com/mattn/go-isatty v0.0.20 // indirect | ||
| github.com/miekg/dns v1.1.62 // indirect | ||
| github.com/mikioh/tcpinfo v0.0.0-20190314235526-30a79bb1804b // indirect | ||
| github.com/mikioh/tcpopt v0.0.0-20190314235656-172688c1accc // indirect | ||
| github.com/minio/sha256-simd v1.0.1 // indirect | ||
| github.com/mr-tron/base58 v1.2.0 // indirect | ||
| github.com/multiformats/go-base32 v0.1.0 // indirect | ||
| github.com/multiformats/go-base36 v0.2.0 // indirect | ||
| github.com/multiformats/go-multiaddr v0.13.0 // indirect | ||
| github.com/multiformats/go-multiaddr-dns v0.4.0 // indirect | ||
| github.com/multiformats/go-multiaddr-fmt v0.1.0 // indirect | ||
| github.com/multiformats/go-multibase v0.2.0 // indirect | ||
| github.com/multiformats/go-multicodec v0.9.0 // indirect | ||
| github.com/multiformats/go-multihash v0.2.3 // indirect | ||
| github.com/multiformats/go-multistream v0.6.0 // indirect | ||
| github.com/multiformats/go-varint v0.0.7 // indirect | ||
| github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect | ||
| github.com/onsi/ginkgo/v2 v2.20.2 // indirect | ||
| github.com/opencontainers/runtime-spec v1.2.0 // indirect | ||
| github.com/pbnjay/memory v0.0.0-20210728143218-7b4eea64cf58 // indirect | ||
| github.com/pion/datachannel v1.5.9 // indirect | ||
| github.com/pion/dtls/v2 v2.2.12 // indirect | ||
| github.com/pion/ice/v2 v2.3.36 // indirect | ||
| github.com/pion/interceptor v0.1.37 // indirect | ||
| github.com/pion/logging v0.2.2 // indirect | ||
| github.com/pion/mdns v0.0.12 // indirect | ||
| github.com/pion/randutil v0.1.0 // indirect | ||
| github.com/pion/rtcp v1.2.14 // indirect | ||
| github.com/pion/rtp v1.8.9 // indirect | ||
| github.com/pion/sctp v1.8.33 // indirect | ||
| github.com/pion/sdp/v3 v3.0.9 // indirect | ||
| github.com/pion/srtp/v2 v2.0.20 // indirect | ||
| github.com/pion/stun v0.6.1 // indirect | ||
| github.com/pion/transport/v2 v2.2.10 // indirect | ||
| github.com/pion/turn/v2 v2.1.6 // indirect | ||
| github.com/pion/webrtc/v3 v3.3.4 // indirect | ||
| github.com/pkg/errors v0.9.1 // indirect | ||
| github.com/pmezard/go-difflib v1.0.0 // indirect | ||
| github.com/prometheus/client_model v0.6.1 // indirect | ||
| github.com/prometheus/common v0.60.0 // indirect | ||
| github.com/prometheus/procfs v0.15.1 // indirect | ||
| github.com/quic-go/qpack v0.5.1 // indirect | ||
| github.com/quic-go/quic-go v0.48.1 // indirect | ||
| github.com/quic-go/webtransport-go v0.8.1-0.20241018022711-4ac2c9250e66 // indirect | ||
| github.com/raulk/go-watchdog v1.3.0 // indirect | ||
| github.com/spaolacci/murmur3 v1.1.0 // indirect | ||
| github.com/stretchr/testify v1.9.0 // indirect | ||
| github.com/wlynxg/anet v0.0.5 // indirect | ||
| go.uber.org/dig v1.18.0 // indirect | ||
| go.uber.org/mock v0.5.0 // indirect | ||
| go.uber.org/multierr v1.11.0 // indirect | ||
| go.uber.org/zap v1.27.0 // indirect | ||
| golang.org/x/crypto v0.28.0 // indirect | ||
| golang.org/x/exp v0.0.0-20241009180824-f66d83c29e7c // indirect | ||
| golang.org/x/mod v0.21.0 // indirect | ||
| golang.org/x/net v0.30.0 // indirect | ||
| golang.org/x/sync v0.8.0 // indirect | ||
| golang.org/x/sys v0.26.0 // indirect | ||
| golang.org/x/text v0.19.0 // indirect | ||
| golang.org/x/tools v0.26.0 // indirect | ||
| google.golang.org/protobuf v1.35.1 // indirect | ||
| gopkg.in/yaml.v3 v3.0.1 // indirect | ||
| lukechampine.com/blake3 v1.3.0 // indirect | ||
| ) | ||
|
|
||
| replace github.com/libp2p/go-libp2p => ../ |
Oops, something went wrong.