ring:using-lib-streaming

ring:using-lib-streaming is a skill for Cursor from LerianStudio/ring. It costs 99 tokens per session (10,552 once invoked), scanned A, original, Apache-2.0.

A guide to lib-streaming, a Go library for publishing business events through systems such as Kafka, SQS, RabbitMQ, or EventBridge.

In plain words
What is it for?
Use it to configure event destinations, publish CloudEvents, send one event to multiple transports, test publishers, and handle publishing errors.
Why use it?
It helps replace separately built event publishers, transport setup, and repeated reliability logic with the library's shared approach.

Skill for Cursor

Written for Cursor: shipped in a Cursor plugin. Also seen: mentions Claude Code.

Part of the ring-dev-team plugin — 35 skills, 24 agents shipped together

Good fit Use it to configure event destinations, publish CloudEvents, send one event to multiple transports, test publishers, and handle publishing errors.

Compare 6 skills from other repositories ↓
Install with agentmods
npx agentmods add skills/lerianstudio/ring/using-lib-streaming
Install

Getting it into your agent

One page per mod, every tool's command on it. A separate URL per tool would split the same page into five that compete with each other.

Any agent
npx skills add LerianStudio/ring --skill using-lib-streaming
Clone the repo
git clone --depth 1 https://github.com/LerianStudio/ring

Made for: Cursor.

Or install ring-dev-team, the plugin that ships this one along with the rest of its 35 skills, 24 agents.

Wrote this? Show the measurements

A badge with what this costs and how it scanned, read live from this page, so it follows the numbers instead of freezing them. Markdown for a README, HTML for a documentation site or a project page.

agentmods badge for ring:using-lib-streaming

README.md
[![agentmods](https://agentmods.dev/badge/skills/lerianstudio/ring/using-lib-streaming/github.svg)](https://agentmods.dev/skills/lerianstudio/ring/using-lib-streaming)
Your own site
<a href="https://agentmods.dev/skills/lerianstudio/ring/using-lib-streaming"><img src="https://agentmods.dev/badge/skills/lerianstudio/ring/using-lib-streaming/github.svg" alt="Measured on agentmods" height="20"></a>

Or the 80×15 button, for a site that already has a row of RSS and ATOM ones. Only the verdict fits; the numbers stay here.

agentmods 80×15 button for ring:using-lib-streaming

Your own site · 80×15
<a href="https://agentmods.dev/skills/lerianstudio/ring/using-lib-streaming"><img src="https://agentmods.dev/badge/skills/lerianstudio/ring/using-lib-streaming.svg" alt="Reviewed on agentmods" width="80" height="20"></a>
Per session 99 Skills are progressive disclosure: only the name and description are preloaded; the body loads when the skill is used.
When invoked 10,552 The whole file, excluding the scripts and references it only reads on demand.
Security scan A 0 findings. A grade says what 26 rules found in the file — not that it is safe. Third-party audits
  • NVIDIA SkillSpector warn 7 Sept 2026
SkillSpector: 1 finding, up to medium

These are SkillSpector’s own severities. On a checked sample its high-severity flags on skills were ~96% false positives — a documented command, a public API, a “never do X” rule — so we show them as a caution to read, not a verdict. Why →

  • medium Data Exfiltration · line 82
    Data is being sent to an external URL. This could be legitimate telemetry or data exfiltration. Manual review is recommended.
    Fix: Verify the destination URL is trusted and necessary. Remove or replace with documented APIs. Ensure no secrets, tokens, or PII are transmitted.
How audits are shown
Origin original No closer match found in the catalogue.
Token cost

What it costs to keep this loaded

Counted locally with the o200k_base tokenizer, which is exact for GPT models; Claude uses its own tokenizer and its counts differ. Treat this as one consistent yardstick across the catalogue rather than a bill. Prices are per million input tokens.

ModelPer sessionOnce invoked
Fable 5.1 $0.00099 $0.10552
Opus 5.5 $0.00040 $0.04221
Sonnet 5.5 $0.00020 $0.02110
Haiku 4.5 $0.00010 $0.01055

Measured 1mo ago against content hash a5a745c3b3c8, method: parsed. Prices are Anthropic first-party input rates as of 2026-10-07, from the pricing page.

Security

Grade A, and why

ring:using-lib-streaming scanned grade A with 0 findings against 26 rules in 11 categories — prompt injection, anti-refusal, data exfiltration, privilege escalation, supply chain, agent snooping, system-prompt leakage, SSRF and excessive agency — measured 1mo ago.

A static scan of the body, not an audit. Every finding is printed with the line that produced it so you can judge whether it matters here. A mod is markdown that instructs an agent; that is exactly why what it instructs is worth reading.

Nothing flagged

None of the 26 patterns this scan looks for appear in this file: no shell pipes, no recursive deletes, no credential paths, no hidden text, no instruction-override or anti-refusal phrasing, no agent-config snooping. That is not a guarantee, it is the absence of the things that are checkable.

dev-team/skills/using-lib-streaming/SKILL.md · 750 lines

How it starts

The opening of the file, as written. The whole thing — 750 lines — stays where its author put it; the contents beside it link to each section on GitHub.

ring:using-lib-streaming

When to use

Sweep mode:

  • "Sweep this service for lib-streaming adoption opportunities"
  • "Find every DIY Kafka / SQS / RabbitMQ publisher that should use lib-streaming"
  • "Audit our event publishing layer against lib-streaming"
  • "We have raw franz-go / sarama / watermill — what should move to lib-streaming?"
  • "Identify ad-hoc manifest or per-service circuit breakers around event publishing"

Reference mode:

  • Need to understand what lib-streaming provides at the public facade
  • Looking for the right Builder setter, Destination helper, or sentinel
  • Setting up a new service that emits CloudEvents-framed domain events
  • Wiring multi-transport fan-out (Kafka primary + SQS shadow, etc.)
  • Writing unit tests that depend on streamingtest.MockEmitter
  • Need the canonical CloudEvents binary-mode Kafka header bytes for an interop layer
  • Need to map a runtime *EmitError / *MultiEmitError to an operator response

Skip when

  • Working on non-Go services (lib-streaming is Go-only)
  • Working on frontend code
  • Service is consumer-only with no outbound business event surface — there is nothing for lib-streaming to instrument
  • Service publishes only internal command queue messages — those stay on github.com/LerianStudio/lib-commons/v5/commons/rabbitmq; lib-streaming is for past-tense business events to external subscribers
  • ring:instrumenting-streaming-events — end-to-end 13-gate orchestration that implements lib-streaming in a target service. Use that after ring:mapping-streaming-events has produced a validated docs/streaming/instrumentation-map.json. This skill is the adoption/reference counterpart — it does not own the implementation cycle.
  • ring:mapping-streaming-events — PM-side identification of eventable points; produces the catalog and instrumentation map this skill's REFERENCE MODE consumes.
  • ring:using-lib-commons — lib-streaming depends on lib-commons for circuit breaker, outbox repository, App lifecycle, runtime panic instrumentation, and assertions. The CB / outbox / runtime / assert API surface lives there.
  • ring:using-outbox — OutboxWriter, TransactionalOutboxWriter, WithOutboxTx, and route-aware envelope replay live in the outbox skill. This skill points at the boundary but does NOT duplicate the writer / dispatcher API.
  • ring:using-lib-observability — log.Logger, metrics.MetricsFactory, and trace.Tracer are owned there. Builder setters consume those types; this skill links rather than re-documents.

Read the full file on GitHub · 750 lines

Changes

What this file has done since we first saw it

Hashed on every crawl. A supply-chain change to an agent config is a question of when, not whether, so the history is kept rather than the latest state alone.

  1. 1mo ago First seen · 750 lines · 99 tokens per session scan A a5a745c3b3c8

Subscribe to this mod's changes

ring:using-lib-streaming is a skill published in the GitHub repository LerianStudio/ring (218 stars, last pushed today), licensed Apache-2.0. It adds 99 tokens to every session and 10,552 once invoked, about $0.0004 per session on Opus 5.5. A static security scan graded it A with 0 findings. No closer match exists in the catalogue, so it is treated as the original; first seen 2026-09-03.

Related

Other skills, from other repositories

api-audit

API and endpoint integrity audit across 10 dimensions (D1-D10) plus optional contract stability (D11) and optional OWASP API Security Top 10 (D12: BOLA/BOPLA/BFLA, mass assignment, JWT alg-confusion, GraphQL introspection). Covers validation, payloads, pagination, errors, caching, HTTP semantics, waterfalls, rate…

greglas75/zuvo · 135 tokens

performance-audit

Full-stack performance health check across 12 dimensions. Rendering, bundles, assets, API/network, algorithms, memory, database, caching, Web Vitals, backend runtime, concurrency, and framework-specific pathologies. Evidence-based Impact Models with confidence tiers and a prioritized optimization roadmap. Switches…

greglas75/zuvo · 90 tokens

docs

Write and update technical documentation from actual codebase analysis. Generates README, API reference, runbook, onboarding guide, or changelog. Supports update mode that patches stale sections without rewriting from scratch. Modes: readme [path], api [path], runbook [topic], onboarding, update [file], changelog…

greglas75/zuvo · 68 tokens

leads

B2B lead discovery and enrichment skill. Finds company addresses, employee emails, and phone numbers filtered by industry, geography, role, and company size. 100% free-tier: orchestrates Claude Code's native WebSearch and WebFetch plus free OSINT subprocesses (theHarvester, crt.sh, whois, GitHub API, OSM Overpass, DNS…

greglas75/zuvo · 178 tokens

laravel-audit-dsa

Run a read-only, orchestrated audit of a Laravel codebase for data structures, state representation, algorithms, and ownership. Use when asked for a DSA audit, subsystem inventory, or Aaron-style bounded agent audit.

MrPunyapal/laravel-auditor · 51 tokens

argot-suggest-rules

Turn a convention argot has already discovered into a scripted custom rule. Runs argot conventions, surfaces the repo's mined placement conventions (where a kind of code lives — "validation in schema files", "DB access only in migrations", "business logic in the service layer, not views") and internal-API vocabulary…

get-tmonier/argot · 173 tokens