Skip to content

adapt vio.Pusher interface to sio serializers#6729

Merged
mccanne merged 4 commits intomainfrom
sio-pusher
Mar 15, 2026
Merged

adapt vio.Pusher interface to sio serializers#6729
mccanne merged 4 commits intomainfrom
sio-pusher

Conversation

@mccanne
Copy link
Collaborator

@mccanne mccanne commented Mar 14, 2026

This commit adds Push methods to all of the sio writers so that they now implement vio.Pusher. This provides an obvious "to do" list for which writers should implement direct vector endcoding (e.g., parquet).

It should also be pretty clear now how to change over the service handler to emit CSUP instead of BSUP.

This now means that the CSUP writer is wired directly to the vam output and vectors are encoded directly for CSPU without a trip through scode.

Also, the query paths for super -c and super db -c are now wrapped with context checks (vio.CopyMuxWithContext). While the underlying read calls should get canceled with ctrl-c, this adds a bit of foolproofing for code paths that miss this so I think it's a good addition for now. But we can take it out if we think it's not necessary; or maybe take it out, after more comprehensive testing?

mccanne added 3 commits March 14, 2026 14:40
This commit adds Push methods to all of the sio writers so that they
now implement vio.Pusher.  This provides an obvious "to do" list for
which writers should implement direct vector endcoding (e.g., parquet).

It should also be pretty clear now how to change over the service
handler to emit CSUP instead of BSUP.

This now means that the CSUP writer is wired directly to the vam output
and vectors are encoded directly for CSPU without a trip through scode.

Also, the query paths for super -c and super db -c are now wrapped
with context checks (vio.CopyMuxWithContext).  While the underlying
read calls should get canceled with ctrl-c, this adds a bit of fullproofing
for code paths that miss this so I think it's a good addition for now.
But we can take it out if we think it's not necessary; or maybe
take it out, after more comprehensive testing?
@@ -1,3 +1,5 @@
skip: this test splits hairs and not important for now... the pusher interface changed this all
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Remove if you don't want to resurrect later.

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This feature is still there. Just need to update the test at some point.

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

...with something less fussy

@mccanne mccanne merged commit d29d653 into main Mar 15, 2026
3 of 4 checks passed
@mccanne mccanne deleted the sio-pusher branch March 15, 2026 20:09
nwt added a commit that referenced this pull request Mar 15, 2026
nwt added a commit that referenced this pull request Mar 16, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants