-
Notifications
You must be signed in to change notification settings - Fork 97
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.
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
UI Peer Page - Stats and Slots #576
Conversation
Amogh-Bharadwaj
commented
Oct 26, 2023
flow/cmd/peer_data.go
Outdated
"google.golang.org/protobuf/proto" | ||
) | ||
|
||
func (h *FlowRequestHandler) GetPoolForPGPeer(ctx context.Context, peerName string) (*pgxpool.Pool, error) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
can this be a private method?
protos/route.proto
Outdated
message StatInfo { | ||
int64 pid = 1; | ||
string query = 2; | ||
float duration = 3; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
wait_event, wait_event_type, query_start are extremely useful as well.
} | ||
|
||
message SlotInfo { | ||
string slot_name = 1; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
is there any additional data about when the slot was created?
protos/route.proto
Outdated
@@ -94,6 +94,31 @@ message CDCSyncStatus { | |||
google.protobuf.Timestamp end_time = 5; | |||
} | |||
|
|||
message PeerDataRequest { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lets call this PostgresPeerActivityInfoRequest
return ( | ||
<TableRow key={slotName}> | ||
<TableCell> | ||
{flowName.length >= 1 ? ( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
refactor to its own component function const SlotMirrorInfo = .. { slotName, flowName?}
or something along those lines.
}); | ||
return peerSlots.slotData; | ||
}; | ||
const getStatData = async () => { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
sprinkle some new lines to make this more readable.
f9251f0
to
33bd6b9
Compare
33bd6b9
to
bc66f2b
Compare