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