jschoubben da31bcb11e A module hears what it consumes: its consumer is raised with the bus, and it pulls it ...

Every module moved onto the bus by the rollout was issued on the old one, so none had a consumer
waiting; and the grant named a push delivery a runtime's client never binds, while the pull it
does make — asking about its consumer, asking it for messages — was refused. The consumers a
module's declarations imply are now raised whenever the bus is, and the grant is the pull.

2026-09-28 04:29:32 +02:00

..

testdata

A module hears what it consumes: its consumer is raised with the bus, and it pulls it

2026-09-28 04:29:32 +02:00

agreement_catalogue_test.go

Merge main: the trunk renamed the seats and made them data

2026-09-27 18:50:18 +02:00

agreement.go

Event names are checked now, per manifest and across the catalogue

2026-09-27 14:43:16 +02:00

broker_test.go

One bus: the AMQP transport is gone from the controller

2026-09-28 03:36:16 +02:00

broker.go

An address is read from the node's settings where it is used, never recorded with a port

2026-09-23 23:49:31 +02:00

derived_test.go

A node's declaration consumer, which only the mesh can make

2026-09-27 01:24:46 +02:00

derived.go

A module may watch a role's events, and the catch-up turns out to be unnecessary

2026-09-27 17:22:30 +02:00

genesis_template_test.go

Genesis can raise a mesh on the new bus, and the carried user list is checked against the composer

2026-09-27 16:39:19 +02:00

jetstream_test.go

Derive a seat's stream and a module's consumer, and wire JetStream

2026-09-26 22:28:42 +02:00

jetstream.go

The build machine takes work on the bus its credential names, and the work queue has a taker

2026-09-28 01:59:20 +02:00

nats_golden_test.go

The enrolment user is per token, and it has an inbox

2026-09-27 01:31:34 +02:00

nats_test.go

A module hears what it consumes: its consumer is raised with the bus, and it pulls it

2026-09-28 04:29:32 +02:00

nats.go

A module hears what it consumes: its consumer is raised with the bus, and it pulls it

2026-09-28 04:29:32 +02:00

onnats_test.go

One bus: the AMQP transport is gone from the controller

2026-09-28 03:36:16 +02:00

onnats.go

One bus: the AMQP transport is gone from the controller

2026-09-28 03:36:16 +02:00

raise_live_test.go

A module may watch a role's events, and the catch-up turns out to be unnecessary

2026-09-27 17:22:30 +02:00

raise.go

The bus's objects are raised on every start, and one switch says which bus

2026-09-27 02:59:05 +02:00

readiness_test.go

The move ends with the old broker going, not staying

2026-09-27 23:04:59 +02:00

readiness.go

The move ends with the old broker going, not staying

2026-09-27 23:04:59 +02:00

streams_test.go

The mesh's own roles carry a protocol, and the build branch retires

2026-09-27 15:34:44 +02:00

streams.go

The controller follows the subject it decodes

2026-09-28 03:13:57 +02:00

users_test.go

The bus account has JetStream, and the control plane's client has its own inbox

2026-09-28 01:40:10 +02:00

users.go

A module may watch a role's events, and the catch-up turns out to be unnecessary

2026-09-27 17:22:30 +02:00