proxy.golang.org : github.com/streamdal/streamdal/sdks/go
Package streamdal is a library that allows running of Client data pipelines against data This package is designed to be included in golang message bus libraries. The only public method is Process() which is used to run pipelines against data. Use of this package requires a running instance of a streamdal server©. The server can be downloaded at https://github.com/streamdal/streamdal/tree/main/apps/server The following environment variables must be set: - STREAMDAL_URL: The address of the Client server - STREAMDAL_TOKEN: The token to use when connecting to the Client server - STREAMDAL_SERVICE_NAME: The name of the service to identify it in the streamdal console Optional parameters: - STREAMDAL_DRY_RUN: If true, rule hits will only be logged, no failure modes will be ran
Registry
-
Source
- Documentation
- JSON
purl: pkg:golang/github.com/streamdal/streamdal/sdks/go
Keywords:
astrojs
, data-contracts
, deno
, docker
, event-driven
, go
, javascript
, message-queues
, nodejs
, observability
, python
, reactjs
, rust
, streaming-data
, tail-f
, wasi
, wasm
License: Apache-2.0
Latest release: 10 months ago
First release: about 1 year ago
Namespace: github.com/streamdal/streamdal/sdks
Stars: 485 on GitHub
Forks: 8 on GitHub
See more repository details: repos.ecosyste.ms
Last synced: 29 days ago
github.com/streamdal/shopify-sarama v1.42.2-streamdal1
Package sarama is a pure Go client library for dealing with Apache Kafka (versions 0.8 and later)...2 versions - Latest release: about 1 year ago - 0 stars on GitHub
github.com/streamdal/ibm-sarama v1.42.2-streamdal1
Package sarama is a pure Go client library for dealing with Apache Kafka (versions 0.8 and later)...1 version - Latest release: about 1 year ago - 0 stars on GitHub
github.com/streamdal/segmentio-kafka-go v0.4.47-streamdal
Kafka library in Go (instrumented with Streamdal)2 versions - Latest release: about 1 year ago - 0 stars on GitHub
Check this option to include packages that no longer depend on this package in their latest version but previously did.