Skip to content

Add StreamInfo command to stream protocol #5412

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom
Closed
acogoluegnes opened this issue Aug 1, 2022 · 0 comments · Fixed by #5427
Closed

Add StreamInfo command to stream protocol #5412

acogoluegnes opened this issue Aug 1, 2022 · 0 comments · Fixed by #5427
Assignees
@acogoluegnes
Labels
enhancement
Milestone
3.11.0

Comments

@acogoluegnes
Copy link
Contributor

Several users ask for a way to get information on a stream, like the first and last available offsets. Requests for other pieces of information, like the number of messages in a stream could come up in the future.

We agreed to add a new StreamInfo command for this, it would return a map for extensibility.

StreamInfoRequest => Key Version CorrelationId Stream
  Key => uint16 // 0x001c
  Version => uint16
  CorrelationId => uint32
  Stream => string

StreamInfoResponse => Key Version CorrelationId ResponseCode Info
  Key => uint16 // 0x801c
  Version => uint16
  CorrelationId => uint32
  ResponseCode => uint16
  Info => [PieceOfInfo]
  PieceOfInfo => Key Value
  Key => string
  Value => string
@acogoluegnes acogoluegnes added this to the 3.11.0 milestone Aug 1, 2022
@acogoluegnes acogoluegnes self-assigned this Aug 1, 2022
acogoluegnes added a commit that referenced this issue Aug 3, 2022
@acogoluegnes
Add StreamInfo command to stream protocol
8687e73 
It returns general information on a stream, the first
and committed offsets for now.

Fixes #5412
@acogoluegnes acogoluegnes mentioned this issue Aug 3, 2022
Merged
acogoluegnes added a commit that referenced this issue Aug 3, 2022
@acogoluegnes
Make process liveness check remote if necessary
e587e9a 
References #5412
acogoluegnes added a commit to rabbitmq/rabbitmq-stream-java-client that referenced this issue Aug 3, 2022
@acogoluegnes
Support StreamInfo command
d331dfb 
References rabbitmq/rabbitmq-server#5412
@acogoluegnes acogoluegnes mentioned this issue Aug 3, 2022
Merged
acogoluegnes added a commit that referenced this issue Aug 3, 2022
@acogoluegnes
Keep stream_* return codes
f223845 
To keep compatibility with the Erlang client's users.

References #5412
acogoluegnes added a commit to rabbitmq/rabbitmq-stream-java-client that referenced this issue Aug 4, 2022
@acogoluegnes
Add Javadoc for stream info command
789bb1d 
References rabbitmq/rabbitmq-server#5412
acogoluegnes added a commit that referenced this issue Aug 8, 2022
@acogoluegnes
Rename StreamInfo to StreamStats
93c33f2 
Other changes: returns a map of int64, use the new osiris:get_stats/1 API.

References #5412
mergify bot pushed a commit that referenced this issue Aug 9, 2022
@acogoluegnes @mergify
Add StreamInfo command to stream protocol
1840afc 
It returns general information on a stream, the first
and committed offsets for now.

Fixes #5412

(cherry picked from commit 8687e73)
mergify bot pushed a commit that referenced this issue Aug 9, 2022
@acogoluegnes @mergify
Make process liveness check remote if necessary
766c7fa 
References #5412

(cherry picked from commit e587e9a)
mergify bot pushed a commit that referenced this issue Aug 9, 2022
@acogoluegnes @mergify
Keep stream_* return codes
390309f 
To keep compatibility with the Erlang client's users.

References #5412

(cherry picked from commit f223845)
mergify bot pushed a commit that referenced this issue Aug 9, 2022
@acogoluegnes @mergify
Rename StreamInfo to StreamStats
d8ec9ef 
Other changes: returns a map of int64, use the new osiris:get_stats/1 API.

References #5412

(cherry picked from commit 93c33f2)
acogoluegnes added a commit to rabbitmq/rabbitmq-stream-java-client that referenced this issue Aug 9, 2022
@acogoluegnes
Rename "StreamInfo" to "StreamStats"
7ed40da 
And use "committed chunk ID" instead of "committed offset".

References rabbitmq/rabbitmq-server#5412
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@acogoluegnes acogoluegnes

Labels
enhancement
Projects
None yet
Milestone
3.11.0
Development

Successfully merging a pull request may close this issue.

Add StreamStats command to stream protocol rabbitmq/rabbitmq-server
1 participant
@acogoluegnes