ring:using-lib-streaming

ring:using-lib-streaming is a skill for Claude Code, Codex 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 Claude CodeCodex

Written for no agent in particular: nothing here depends on one. Also seen: mentions Claude Code.

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.

agentmods
npx agentmods add skills/lerianstudio/ring/using-lib-streaming
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: Claude Code, Codex.

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.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.svg" alt="Measured on agentmods" 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. Scan, not verified.
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 $0.00049 $0.05276
Sonnet 5 $0.00020 $0.02110
Haiku 4.5 $0.00010 $0.01055

Measured 3d ago against content hash a5a745c3b3c8, method: parsed. Prices are Anthropic first-party input rates as of 2026-09-06, 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 3d 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-outboxOutboxWriter, 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-observabilitylog.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. 3d 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 (211 stars, last pushed 17d ago), licensed Apache-2.0. It adds 99 tokens to every session and 10,552 once invoked, about $0.0005 per session on Opus 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.