Directories
¶
| Path | Synopsis |
|---|---|
|
Package broadcast defines transport-neutral contracts for cross-process messages.
|
Package broadcast defines transport-neutral contracts for cross-process messages. |
|
broadcasttest
Package broadcasttest tests code that publishes or listens to broadcasts.
|
Package broadcasttest tests code that publishes or listens to broadcasts. |
|
memorybroadcast
Package memorybroadcast provides an asynchronous, in-process broadcast driver for local development.
|
Package memorybroadcast provides an asynchronous, in-process broadcast driver for local development. |
|
Package cache provides a vendor-neutral cache contract and typed facade.
|
Package cache provides a vendor-neutral cache contract and typed facade. |
|
cachetest
Package cachetest provides a conformance suite for cache.Driver implementations, modeled on testing/slogtest and testing/fstest.
|
Package cachetest provides a conformance suite for cache.Driver implementations, modeled on testing/slogtest and testing/fstest. |
|
internal/lease
Package lease owns cache-lock polling and serialized holder state.
|
Package lease owns cache-lock polling and serialized holder state. |
|
memorycache
Package memorycache provides an in-memory cache.Driver for tests, local development, and single-process applications.
|
Package memorycache provides an in-memory cache.Driver for tests, local development, and single-process applications. |
|
memorycache/internal/storage
Package storage owns atomic cache values, counters, expiry and sweeping.
|
Package storage owns atomic cache values, counters, expiry and sweeping. |
|
Package crypto defines the authenticated-encryption contract and an Encrypter facade for typed values.
|
Package crypto defines the authenticated-encryption contract and an Encrypter facade for typed values. |
|
cryptotest
Package cryptotest provides Run, a conformance suite that every crypto.Driver implementation must pass.
|
Package cryptotest provides Run, a conformance suite that every crypto.Driver implementation must pass. |
|
Package database defines the SQL database contract and a typed facade that runs published SQL queries into typed rows, with pinned sessions, transactions, and telemetry.
|
Package database defines the SQL database contract and a typed facade that runs published SQL queries into typed rows, with pinned sessions, transactions, and telemetry. |
|
databasetest
Package databasetest provides a conformance suite for database.Driver implementations.
|
Package databasetest provides a conformance suite for database.Driver implementations. |
|
databasetest/internal/suite
Package suite implements database driver checks and their private fixtures.
|
Package suite implements database driver checks and their private fixtures. |
|
migrate
Package migrate applies ordered schema migrations to a database.Database and records them in a bookkeeping table.
|
Package migrate applies ordered schema migrations to a database.Database and records them in a bookkeeping table. |
|
Package feature provides a vendor-neutral, read-only feature flag contract and a typed facade.
|
Package feature provides a vendor-neutral, read-only feature flag contract and a typed facade. |
|
featuretest
Package featuretest provides a conformance suite for feature.Driver implementations, modeled on testing/slogtest and testing/fstest.
|
Package featuretest provides a conformance suite for feature.Driver implementations, modeled on testing/slogtest and testing/fstest. |
|
memoryfeature
Package memoryfeature provides an in-memory feature.Driver for tests, local development, and single-process applications.
|
Package memoryfeature provides an in-memory feature.Driver for tests, local development, and single-process applications. |
|
Package hash defines the password-hashing contract and a Hasher facade that hashes and checks values and reports hashes that need rehashing.
|
Package hash defines the password-hashing contract and a Hasher facade that hashes and checks values and reports hashes that need rehashing. |
|
hashtest
Package hashtest provides Run, a conformance suite that every hash.Driver implementation must pass.
|
Package hashtest provides Run, a conformance suite that every hash.Driver implementation must pass. |
|
internal
|
|
|
messaging
Package messaging holds the telemetry shared by the queue and broadcast facades: producer and consumer spans, trace propagation through message metadata, and the messaging.* metrics of the OpenTelemetry semantic conventions.
|
Package messaging holds the telemetry shared by the queue and broadcast facades: producer and consumer spans, trace propagation through message metadata, and the messaging.* metrics of the OpenTelemetry semantic conventions. |
|
Package llm provides a vendor-neutral contract for large language models and a facade for turns, streaming, and embeddings.
|
Package llm provides a vendor-neutral contract for large language models and a facade for turns, streaming, and embeddings. |
|
internal/engine
Package engine owns agent turn sequencing and bounded tool execution.
|
Package engine owns agent turn sequencing and bounded tool execution. |
|
internal/genai
Package genai holds the telemetry of the llm facades: one span per model call, embeddings request, agent run or tool call, the gen_ai.client.operation.duration histogram and the gen_ai.client.token.usage histogram, all named by arkoren.dev/core/internal/semconv after the OpenTelemetry generative AI conventions.
|
Package genai holds the telemetry of the llm facades: one span per model call, embeddings request, agent run or tool call, the gen_ai.client.operation.duration histogram and the gen_ai.client.token.usage histogram, all named by arkoren.dev/core/internal/semconv after the OpenTelemetry generative AI conventions. |
|
llmtest
Package llmtest provides test support for llm.Driver implementations and for code that talks to a model.
|
Package llmtest provides test support for llm.Driver implementations and for code that talks to a model. |
|
Package mail provides portable transactional email submission and MIME encoding.
|
Package mail provides portable transactional email submission and MIME encoding. |
|
internal/mime
Package mime renders validated mail projections without importing the mail facade.
|
Package mime renders validated mail projections without importing the mail facade. |
|
mailtest
Package mailtest provides test support for mail.Driver implementations and for code that sends mail.
|
Package mailtest provides test support for mail.Driver implementations and for code that sends mail. |
|
slogmail
Package slogmail provides a development mail.Driver that logs each message to a log/slog.Logger instead of sending it.
|
Package slogmail provides a development mail.Driver that logs each message to a log/slog.Logger instead of sending it. |
|
Package payment defines provider-neutral checkout, payment, refund, and subscription operations.
|
Package payment defines provider-neutral checkout, payment, refund, and subscription operations. |
|
memorypayment
Package memorypayment simulates outbound payment operations in process.
|
Package memorypayment simulates outbound payment operations in process. |
|
paymenttest
Package paymenttest provides a scripted outbound fake and driver conformance tests.
|
Package paymenttest provides a scripted outbound fake and driver conformance tests. |
|
paymenttest/internal/suite
Package suite implements deterministic payment driver conformance checks.
|
Package suite implements deterministic payment driver conformance checks. |
|
Package push provides portable outbound push submission, not delivery.
|
Package push provides portable outbound push submission, not delivery. |
|
pushtest
Package pushtest provides an outbound push fake and Driver conformance suite.
|
Package pushtest provides an outbound push fake and Driver conformance suite. |
|
Package queue provides transport-neutral asynchronous queue dispatch and execution.
|
Package queue provides transport-neutral asynchronous queue dispatch and execution. |
|
internal/execution
Package execution owns queue attempt execution and settlement policy.
|
Package execution owns queue attempt execution and settlement policy. |
|
internal/measurement
Package measurement supplies allocation measurements and race-mode metadata for tests.
|
Package measurement supplies allocation measurements and race-mode metadata for tests. |
|
memoryqueue
Package memoryqueue provides a non-durable, in-process queue driver for local development.
|
Package memoryqueue provides a non-durable, in-process queue driver for local development. |
|
memoryqueue/internal/broker
Package broker owns memory queue admission, delivery and delayed retries.
|
Package broker owns memory queue admission, delivery and delayed retries. |
|
queuetest
Package queuetest tests code that dispatches or consumes jobs.
|
Package queuetest tests code that dispatches or consumes jobs. |
|
Package schedule runs functions on a calendar and defers one-off typed tasks.
|
Package schedule runs functions on a calendar and defers one-off typed tasks. |
|
internal/calendar
Package calendar compiles bounded cron calendars and resolves wall times.
|
Package calendar compiles bounded cron calendars and resolves wall times. |
|
memoryschedule
Package memoryschedule provides an in-process schedule.Driver for local development and single-replica deployments.
|
Package memoryschedule provides an in-process schedule.Driver for local development and single-replica deployments. |
|
scheduletest
Package scheduletest helps test code that defers jobs and checks drivers of the schedule package.
|
Package scheduletest helps test code that defers jobs and checks drivers of the schedule package. |
|
Package search provides a vendor-neutral full-text search contract and a typed facade.
|
Package search provides a vendor-neutral full-text search contract and a typed facade. |
|
internal/lexicon
Package lexicon parses query syntax and supplies language-neutral words.
|
Package lexicon parses query syntax and supplies language-neutral words. |
|
internal/scalar
Package scalar normalizes supported search operands and field lists.
|
Package scalar normalizes supported search operands and field lists. |
|
memorysearch
Package memorysearch provides an in-memory search.Driver for tests, local development, and single-process applications.
|
Package memorysearch provides an in-memory search.Driver for tests, local development, and single-process applications. |
|
memorysearch/internal/engine
Package engine owns memory search storage, matching, relevance and ordering.
|
Package engine owns memory search storage, matching, relevance and ordering. |
|
searchtest
Package searchtest provides a conformance suite for search.Driver implementations, modeled on testing/slogtest and testing/fstest.
|
Package searchtest provides a conformance suite for search.Driver implementations, modeled on testing/slogtest and testing/fstest. |
|
Package secret provides versioned secret contracts, typed retrieval, and observed mutations.
|
Package secret provides versioned secret contracts, typed retrieval, and observed mutations. |
|
memorysecret
Package memorysecret provides an in-memory versioned secret.Driver for tests and local development.
|
Package memorysecret provides an in-memory versioned secret.Driver for tests and local development. |
|
secrettest
Package secrettest provides a conformance suite for secret.Driver implementations, modeled on testing/slogtest and testing/fstest.
|
Package secrettest provides a conformance suite for secret.Driver implementations, modeled on testing/slogtest and testing/fstest. |
|
Package storage defines portable streaming object storage contracts.
|
Package storage defines portable streaming object storage contracts. |
|
internal/transfer
Package transfer handles HTTP presentation and upload sniffing for storage.
|
Package transfer handles HTTP presentation and upload sniffing for storage. |
|
memorystorage
Package memorystorage provides a concurrent in-memory storage driver.
|
Package memorystorage provides a concurrent in-memory storage driver. |
|
storagetest
Package storagetest provides a conformance suite for storage.Driver implementations, modeled on testing/slogtest and testing/fstest.
|
Package storagetest provides a conformance suite for storage.Driver implementations, modeled on testing/slogtest and testing/fstest. |
|
Package telemetry provides a vendor-neutral observability contract: traces, metrics, and logs, for Arkoren packages and for application code.
|
Package telemetry provides a vendor-neutral observability contract: traces, metrics, and logs, for Arkoren packages and for application code. |
|
internal/httptrack
Package httptrack implements HTTP observation policy without telemetry state.
|
Package httptrack implements HTTP observation policy without telemetry state. |
|
internal/lazy
Package lazy caches the latest value built for a comparable owner.
|
Package lazy caches the latest value built for a comparable owner. |
|
memorytelemetry
Package memorytelemetry provides an in-process telemetry.TraceDriver, telemetry.MetricDriver, and telemetry.LogDriver for tests, local development, and applications that want trace IDs in logs and responses without a backend.
|
Package memorytelemetry provides an in-process telemetry.TraceDriver, telemetry.MetricDriver, and telemetry.LogDriver for tests, local development, and applications that want trace IDs in logs and responses without a backend. |
|
memorytelemetry/internal/aggregate
Package aggregate retains bounded, ordered metric label tuples.
|
Package aggregate retains bounded, ordered metric label tuples. |
|
memorytelemetry/internal/capture
Package capture copies and normalizes telemetry snapshots before storage.
|
Package capture copies and normalizes telemetry snapshots before storage. |
|
memorytelemetry/internal/tracegroup
Package tracegroup organizes retained span snapshots without storage or DTOs.
|
Package tracegroup organizes retained span snapshots without storage or DTOs. |
|
telemetrytest
Package telemetrytest tests code that emits telemetry and drivers that implement it.
|
Package telemetrytest tests code that emits telemetry and drivers that implement it. |
|
telemetrytest/internal/conformance
Package conformance exercises telemetry driver protocols and readback.
|
Package conformance exercises telemetry driver protocols and readback. |
|
Package workflow defines durable, typed workflows built from retried steps, signals, and sleeps, run by a swappable engine driver.
|
Package workflow defines durable, typed workflows built from retried steps, signals, and sleeps, run by a swappable engine driver. |
|
internal/envelope
Package envelope owns workflow payload framing and failure wire records.
|
Package envelope owns workflow payload framing and failure wire records. |
|
internal/execution
Package execution protects registered workflow and step invocations.
|
Package execution protects registered workflow and step invocations. |
|
memoryworkflow
Package memoryworkflow provides an in-process workflow.Driver for local development and single-replica deployments.
|
Package memoryworkflow provides an in-process workflow.Driver for local development and single-replica deployments. |
|
memoryworkflow/internal/engine
Package engine owns in-process workflow runs, worker lifetime, and retention.
|
Package engine owns in-process workflow runs, worker lifetime, and retention. |
|
workflowtest
Package workflowtest helps test code that starts workflows and checks drivers of the workflow package.
|
Package workflowtest helps test code that starts workflows and checks drivers of the workflow package. |
Click to show internal directories.
Click to hide internal directories.