Repository navigation

Major Refactoring: Interceptor Architecture & Iterator-based Responses - #245

Merged

meling merged 167 commits into

masterfrom

meling/client-interceptors-v2

Dec 26, 2025

Merged

Major Refactoring: Interceptor Architecture & Iterator-based Responses#245
meling merged 167 commits into
masterfrom
meling/client-interceptors-v2

Commits on Nov 26, 2025
- refactor: response handling to use Result[T] type for type safety
  meling
  committed
  819d2ee
- feat: add echoSrv and update testSrv to support GetValue
  meling
  committed
  2322fff
- fix: rename Incomplete error to ErrIncomplete for consistency
  meling
  committed
  c615dba
- feat: add client-side interceptor-based quorum call architecture
  meling
  committed
  219a934
- fix: underscore unused parameters and remove unused receiver parameter
  meling
  committed
  d2e0f50
- fix: quorum size calculation and add tests for even node scenarios
  meling
  committed
  c161818
- fix: QuorumSpecInterceptor doc comment
  meling
  committed
  376f0bd
- fix: typos in ErrIncomplete doc comment
  meling
  committed
  e5b480d
- chore: remove extra " typo
  meling
  committed
  0d3c937
Commits on Nov 27, 2025
Commits on Nov 28, 2025
- refactor: second part of the template update
  meling
  committed
  719dd9f
- refactor: replace QuorumCallOption with CallOption
  meling
  committed
  d0ec554
- feat: WithQuorumInterceptors and use variadic opts
  meling
  committed
  b54c2f9
- refactor: replace opts with waitSendDone bool in request struct
  meling
  committed
  a1b9c52
- test: add test for custom return type
  meling
  committed
  839525c
- refactor: update getCallOptions to use variadic CallOption parameters
  meling
  committed
  f96dc53
- refactor: rename WithQuorumInterceptors and WithPerNodeTransform
  meling
  committed
  6c5c113
- refactor: extract interceptor extraction logic into a separate function
  meling
  committed
  491eb6f
- refactor: move register transform logic to call option
  meling
  committed
  a68e89e
- test: add tests for chaining transform functions
  meling
  committed
  0df4b60
- feat: add support for Map to replace PerNodeTransform and more
  meling
  committed
  701383b
- refactor: replace responseFunc with responses in ClientCtx for clarity
  meling
  committed
  c743195
- chore: rename Transform CallOption to MapRequest
  meling
  committed
  a01f534
Commits on Nov 29, 2025
Commits on Nov 30, 2025
- chore: updated correctable call _gorum.pb.go files
  meling
  committed
  c70a5b3
- feat: add newNodeResponse function for type conversion in NodeResponse
  meling
  committed
  268dce4
- fix: skip issue in Correctable call; fix signatures
  meling
  committed
  fbbd6e4
- refactor: benchmark tool to use the new quorum function design
  meling
  committed
  b698f1d
- refactor: updated storage/repl to use new quorum function design
  meling
  committed
  a668b3e
- refactor: replace correctableQF with std quorumFunc and more
  meling
  committed
  6eb7d6a
Commits on Dec 1, 2025
- refactor: redesign quorum call API to use fluent terminal methods
  meling
  committed
  c54406e
- refactor(v2): simplify Responses to single type parameter
  meling
  committed
  3fc4d00
- chore: removed two unused functions in generator code
  meling
  committed
  3643cd2
- refactor: move response handling logic to new file
  meling
  committed
  be2f200
- refactor: replace manual Responses creation with NewResponses function
  meling
  committed
  ad60cd3
- feat: consolidate client context management for all calltypes
  meling
  committed
  0102a22
- feat: add support for builder pattern to construct clientCtx
  meling
  committed
  e28780c
- refactor: rename Raw types to non-Raw
  meling
  committed
  cf9860c
- refactor: rename Raw constructors to their non-Raw counterparts
  meling
  committed
  0b9d116
- chore: regenerated _gorums.pb.go following Raw types rename
  meling
  committed
  ac56392
- refactor: rename getMsgID to nextMsgID and update references for clarity
  meling
  committed
  9c32d34
- chore: updated some documention Raw references no longer valid
  meling
  committed
  562d938
- refactor: make gorumsStream type safe with Gorums_NodeStreamClient
  meling
  committed
  43396ef
Commits on Dec 2, 2025
- test: add tests and benchmarks for stream ready and reconnection
  meling
  committed
  fdfe15b
- feat: add streamReady channel to signal when stream becomes available
  meling
  committed
  0fdf131
- chore: define fixed test duration across ordering tests
  meling
  committed
  6e7794f
- feat: add stress tests for ordering tests using iter.Seq
  meling
  committed
  a995db3
- fix: reduce iteration count for Unresponsive test
  meling
  committed
  ab4af0b
- refactor: consolidate test setup and teardown with robust test helpers
  meling
  committed
  47ee0b9
- refactor: consolidate test helpers: SetupConfiguration, SetupNode
  meling
  committed
  d686056
- fix: TestServers to work in benchmarks
  meling
  committed
  24fe5d7
- refactor: use SetupConfiguration in correctable_test.go
  meling
  committed
  9b98405
- chore: remove unused NewTestConfigContext
  meling
  committed
  133fd23
- refactor: simplify test setup by consolidating server initialization
  meling
  committed
  b7e46cd
- refactor: removed unused NewTestConfig and SetupNodes
  meling
  committed
  23773b7
- refactor: clarify need for setupWithNodeMap for consistent node IDs
  meling
  committed
  419ba3f
- feat: add TestContext for consistency and clarity
  meling
  committed
  5e4af41
- chore: replace context.WithTimeout with TestContext for improved clarity
  meling
  committed
  a45ff71
- refactor: streamline setup in tests for improved readability
  meling
  committed
  9d86335
- feat: add testing options for improved server management and teardown
  meling
  committed
  4f2dc5c
- feat: enhance test setup with TestOption for flexible config mgnt
  meling
  committed
  2a4e572
Commits on Dec 3, 2025
- feat: add Manager method to Configuration and add TestOption type
  meling
  committed
  c00567f
- chore: simplify TestServerCallback using SetupNode
  meling
  committed
  51eb487
- chore: minor comments and if err contraction
  meling
  committed
  431e288
- refactor: replace newNodeWithServer with SetupNode
  meling
  committed
  12e1eee
- refactor: rename WithTeardown to WithPreConnect and update related tests
  meling
  committed
  215644e
- refactor: add WithStopFunc option and remove newNodeWithStoppableServer
  meling
  committed
  3ec9f8d
- refactor: move preConnect option to testOptions
  meling
  committed
  53477a7
- refactor: remove TestSetup function and update doc for TestServers
  meling
  committed
  69904fb
- refactor: rename NewTestNode with testNodeWithoutServer
  meling
  committed
  2ba5319
- refactor: rename SetupNode, SetupConfiguration to Test*
  meling
  committed
  a6db001
- refactor: remove gorums.async option and use helper funcs instead
  meling
  committed
  e22f411
- refactor: replace QuorumCallWithInterceptor with QuorumCall*
  meling
  committed
  3eb681e
Commits on Dec 4, 2025
- refactor: correctable functionality and remove deprecated options
  meling
  committed
  1e03735
- refactor: unexport the Update method for Correctable[Resp]
  meling
  committed
  2a49e00
Commits on Dec 5, 2025
- chore: reorganization of repsonse handling methods
  meling
  committed
  ff2926f
- fix: BenchmarkGetCallOptions()
  meling
  committed
  de215df
- refactor: reorganized tests and various fixes
  meling
  committed
  5f43659
Commits on Dec 6, 2025
- chore: clean up various tests and remove old cruft
  meling
  committed
  a3b46a3
- refactor: return error from Unicast and Multicast methods (part 1)
  meling
  committed
  20cde1c
- refactor: return error from Unicast and Multicast methods (part 2)
  meling
  committed
  37e7319
- refactor: rename call option WithNoSendWaiting() to IgnoreErrors()
  meling
  committed
  1e9b991
- fix: doc comments and add forwarding funcs to generated code
  meling
  committed
  addcb2d
- chore: regenerated _gorums.pb.go with forwarding funcs
  meling
  committed
  aced390
- chore: rename WithGrpcDialOptions to WithDialOptions
  meling
  committed
  75e7aff
- feat: add NewConfig helper to create configurations without Manager
  meling
  committed
  2723909
- chore: regenerate _gorums.pb.go files
  meling
  committed
  757a3ea
- fix: stream benchmark slowness
  meling
  committed
  c5862fe
- fix: revised the AGENTS.md file
  meling
  committed
  c15f39b
Commits on Dec 9, 2025
Commits on Dec 10, 2025
- refactor: partially decouple node and channel
  meling
  committed
  8b8c81d
- refactor: replace WithNoConnect with InsecureDialOptions in tests
  meling
  committed
  c233e3d
- refactor: remove legacy NewNode functions
  meling
  committed
  d533a26
- chore: updated generated code to remove NewNode
  meling
  committed
  0e68457
- chore: update nextMsgID to use msgIDGen for message ID generation
  meling
  committed
  361f10e
Commits on Dec 11, 2025
- refactor: reduce coupling between channel and node
  meling
  committed
  a536134
Commits on Dec 14, 2025
- refactor: remove logger from channel and node
  meling
  committed
  7ef675e
- fix: error handling for multicast and unicast operations
  meling
  committed
  317a678
- refactor: stop function with variadic args to stop individual srvs
  meling
  committed
  4e5a208
- refactor: QuorumCallError to remove replies field and support Unwarp
  meling
  committed
  2fd0640
- test: add TestPartialFailures for multicast and quorumcall
  meling
  committed
  b3c1a22
- feat: add WithoutErrors to Configuration for excluding failed nodes
  meling
  committed
  1fe9928
- refactor: simplify update logic in Correctable and Threshold methods
  meling
  committed
  828b02f
- chore: switch to new protobuf vscode plugin; update settings
  meling
  committed
  31047ea
- chore: remove unnecessary variable declaration for nodes in mgr_test.go
  meling
  committed
  570b7d1
- fix: rename missing WaitForLevel to Correctable
  meling
  committed
  df47d55
- feat: implement ParseInteger function for generic integer parsing
  meling
  committed
  2621f82
- fix: refactor serverState start method to run synchronously
  meling
  committed
  6d9ce38
- fix: remove unused outPrefix field and hasAllMethodOption function
  meling
  committed
  ee2ca07
- fix: rename new param to newNodes in WithNewNodes function
  meling
  committed
  77c9112
- fix: remove receiver var for test methods where not needed
  meling
  committed
  a732911
- fix: remove duplicate import
  meling
  committed
  96d95e1
- fix: remove unused parameters in function signatures across test files
  meling
  committed
  44a8a49
- fix: add skipcq comments to suppress linting warnings in test files
  meling
  committed
  2a6942e
- fix: rename send function to sendReq
  meling
  committed
  46b5b4c
- fix: rename internal quorumCall to invokeQuorumCall
  meling
  committed
  8fe944a
- fix: simplify var declaration for CorrectableResponse in test
  meling
  committed
  15c9ff2
Commits on Dec 15, 2025
- doc: update user guide and options guide for Gorums; add migration guide
  meling
  committed
  a9b1912
- refactor: context handling for node and configuration
  meling
  committed
  729ecbf
Commits on Dec 17, 2025
- test: add custom aggregation pattern tests for Responses
  meling
  committed
  f5c011e
- doc: add recommended patterns for custom quorum functions
  meling
  committed
  e44cf37
- doc: clarify API behavior and streaming support in method options
  meling
  committed
  cbc1304
- refactor: make interceptor design more flexible with next argument
  meling
  committed
  85b82bf
- doc: improve user guide
  meling
  committed
  0a9575f
Commits on Dec 20, 2025
Commits on Dec 21, 2025
- doc: add storage.proto for the gorumsexample service used in the tutorial
  meling
  committed
  f849770
- chore: update examples/Makefile with docs for debug flags
  meling
  committed
  08fbeef
- chore: keep only one .gitignore
  meling
  committed
  883425e
- chore: replace clang-format with buf format via protobuf-vsc extension
  meling
  committed
  bb57284
- chore: update examples/storage.proto resolve lint issues
  meling
  committed
  c8f1be4
- chore: update benchmark proto resolve lint issues
  meling
  committed
  11df72f
- refactor: remove MemoryStatList from benchmark
  meling
  committed
  02cdac4
- refactor: rename MessageID to message_seq_no in ordering.proto
  meling
  committed
  2306fac
Commits on Dec 25, 2025
- feat: add gorums.System and proper io.Closer support
  meling
  committed
  4e99c28
Commits on Dec 26, 2025
- fix(channel): eliminate race condition in ensureStream
  meling
  committed
  59cde08
- refactor(channel): move ensureStream closer to related newNodeStream
  meling
  committed
  de30aa2
- feat: add benchmark validation and measurement targets in Makefile
  meling
  committed
  a67cb52
- refactor(sync): replace RWMutex with Mutex
  meling
  committed
  11e293e
- refactor(channel): improve ensureStream doc and helper func rename
  meling
  committed
  4183fb7

Commits

Commits on Nov 26, 2025

Commits on Nov 27, 2025

Commits on Nov 28, 2025

Commits on Nov 29, 2025

Commits on Nov 30, 2025

Commits on Dec 1, 2025

Commits on Dec 2, 2025

Commits on Dec 3, 2025

Commits on Dec 4, 2025

Commits on Dec 5, 2025

Commits on Dec 6, 2025

Commits on Dec 9, 2025

Commits on Dec 10, 2025

Commits on Dec 11, 2025

Commits on Dec 14, 2025