Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
47 commits
Select commit Hold shift + click to select a range
938bf8b
Added the stream protos, commands, and API surface.
moedash Sep 14, 2026
4e9314b
Added the stream log store and kept the scavenger off it.
moedash Sep 14, 2026
2ea6176
Added the CHASM stream component with floor-aware retention.
moedash Sep 14, 2026
cd3307e
Added the stream service RPCs and the frontend wiring.
moedash Sep 14, 2026
d014cf3
Let a workflow publish and subscribe to its stream with commands.
moedash Sep 14, 2026
53e99e9
Delivered consumed ranges through Workflow Tasks, routed across hosts.
moedash Sep 14, 2026
27ae8a3
Added the functional tests and the SDK validation server host.
moedash Sep 14, 2026
03a12b1
Formatted the stream proto and the cross-host test.
moedash Sep 16, 2026
083ad12
Regenerated the execution store wrappers.
moedash Sep 16, 2026
9682147
Restored the v1.10 and v0.10 schema manifests.
moedash Sep 16, 2026
197f878
Added the stream_log schema as a new version per database.
moedash Sep 16, 2026
fac8b43
Made the publish cost measurement opt-in.
moedash Sep 16, 2026
8f255ca
Fixed the MySQL stream log read bounds.
moedash Sep 16, 2026
d56c986
Regenerated the stream state proto.
moedash Sep 16, 2026
989b303
Re-pinned api-go to the branch head.
moedash Sep 16, 2026
c9afe90
Regenerated the getproto import map.
moedash Sep 16, 2026
8bb1ad0
Tidied the mixed brain test module.
moedash Sep 16, 2026
04d7060
Fixed the build-tests target for the mixed brain module.
moedash Sep 16, 2026
e33d2d4
Made the otel handler test tolerate empty exemplar slices.
moedash Sep 17, 2026
ed1d612
Cleared the stale test log between local test runs.
moedash Sep 17, 2026
95719ed
Required protobuf payloads from the system Nexus endpoint.
moedash Sep 17, 2026
ed762e1
Re-pinned api-go to the documented stream protos.
moedash Sep 18, 2026
40f54b0
Removed the unused stream log store and its schema.
moedash Sep 18, 2026
bf40768
Routed the command-path subscription through the stream service.
moedash Sep 18, 2026
dee9c68
Failed the workflow task when a stream range cannot be served.
moedash Sep 19, 2026
524dcec
Failed the workflow task on a refused stream command.
moedash Sep 19, 2026
73fccdf
Proved that a failed workflow task publishes nothing.
moedash Sep 19, 2026
18a053d
Regenerated the stream protos after the comment edits.
moedash Sep 19, 2026
ee89886
Treated a stream message with no kind as data.
moedash Sep 19, 2026
cf37d21
Dropped the implicit head pin from the RPC append handlers.
moedash Sep 19, 2026
31ab971
Moved the stream limits to dynamic config and budgeted owned streams.
moedash Sep 19, 2026
774751d
Keyed consumer pins by run and released them when the run closes.
moedash Sep 19, 2026
d3602ee
Made retention and deletion respect an active consumer.
moedash Sep 19, 2026
98320c4
Stopped a filtered stream read from skipping unexamined offsets.
moedash Sep 19, 2026
b6c8b0c
Validated stream ids, names, offsets and page sizes on the frontend.
moedash Sep 19, 2026
fb3567d
Wrapped long lines, tagged every handler and rewrote stale comments.
moedash Sep 19, 2026
edfba28
Cleared the linter findings in the stream code.
moedash Sep 19, 2026
bedc962
Carried the record vocabulary and producer identity through the server.
moedash Sep 21, 2026
3f3f269
Created the owned stream when a workflow subscribes to it by name.
moedash Sep 21, 2026
cf095d2
Applied the repo formatter to the stream service proto and race test.
moedash Sep 21, 2026
ed16b23
Imported the api stream package as streampb wherever both stream pack…
moedash Sep 21, 2026
032c382
Guarded the stream test env's cancel list against concurrent producers.
moedash Sep 21, 2026
c0b383d
Declared authorization scope, quotas and redirection for the stream s…
moedash Sep 21, 2026
16af6ea
Carried the recorded stream ranges on non-sticky query tasks.
moedash Sep 21, 2026
3f66c5b
Shortened the stream metadata table.
moedash Sep 21, 2026
125e9d3
Carried stream subscriptions through a workflow reset.
moedash Sep 21, 2026
19b4452
Characterized a stream under namespace failover in both replication m…
moedash Sep 21, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 5 additions & 1 deletion Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -522,14 +522,18 @@ workflowcheck: $(WORKFLOWCHECK)
check: lint shell-check

##### Tests #####
# verify-test-log reads the whole file, so a log left behind by an earlier run
# would be judged as if it belonged to this one.
clean-test-output:
@printf $(COLOR) "Delete test output..."
@rm -rf $(TEST_OUTPUT_ROOT)
@rm -f test.log
@go clean -testcache

build-tests:
@printf $(COLOR) "Build tests..."
@CGO_ENABLED=$(CGO_ENABLED) go test $(TEST_TAG_FLAG) -exec="true" -count=0 $(TEST_DIRS)
@CGO_ENABLED=$(CGO_ENABLED) go test $(TEST_TAG_FLAG) -exec="true" -count=0 $(filter-out $(MIXED_BRAIN_TEST_ROOT)%,$(TEST_DIRS))
@cd $(MIXED_BRAIN_TEST_ROOT) && CGO_ENABLED=1 go test $(TEST_TAG_FLAG) -exec="true" -count=0 ./...

unit-test: clean-test-output
@printf $(COLOR) "Run unit tests..."
Expand Down
74 changes: 74 additions & 0 deletions api/historyservice/v1/request_response.go-helpers.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2,708 changes: 1,422 additions & 1,286 deletions api/historyservice/v1/request_response.pb.go

Large diffs are not rendered by default.

625 changes: 315 additions & 310 deletions api/historyservice/v1/service.pb.go

Large diffs are not rendered by default.

43 changes: 43 additions & 0 deletions api/historyservice/v1/service_grpc.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

35 changes: 35 additions & 0 deletions api/historyservicemock/v1/service_grpc.pb.mock.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading
Loading