README
¶
queuekit
import "github.com/kitsunium/sdk/framework/internal/kit/queuekit"
Package queuekit is what framework/kit/queue plugs into kit: the brokers kit's consumers' queues run on — the SDK's queue in memory, in the data directory and over SQL, a mailer's outbox on a database sealed in front of the SQL one —, the consumer that delivers them, and the migration of a queue's table (ADR 0179 §1, step 4). kit's core imports none of the SDK's queue: it reaches it through plug, and a product that declares no topic, no subscription, no watch, no queued command and no outbox on a database links none of it.
Package queuekit — the compile-time proof that the brokers are kit's.
Index
func BrokerOf
func BrokerOf(b plug.Broker) (queue.Broker, bool)
BrokerOf is the SDK's broker behind b, a queue this package opened: what a mailer's spool keeps its outbox in on a database (ADR 0179 step 6) — the sealed outbox, behind a test's wrapper when it set one —; false for a queue it did not open.
func Enable
func Enable()
Enable plugs the queues' brokers, their consumer and the migration of a queue's table into kit.
Generated from docs/api by tools/genindex.
Documentation
¶
Overview ¶
Package queuekit is what framework/kit/queue plugs into kit: the brokers kit's consumers' queues run on — the SDK's queue in memory, in the data directory and over SQL, a mailer's outbox on a database sealed in front of the SQL one —, the consumer that delivers them, and the migration of a queue's table (ADR 0179 §1, step 4). kit's core imports none of the SDK's queue: it reaches it through plug, and a product that declares no topic, no subscription, no watch, no queued command and no outbox on a database links none of it.
Package queuekit — the compile-time proof that the brokers are kit's.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
This section is empty.
Source Files