Created
February 2, 2024 23:29
-
-
Save beatak/6229c14844407e206f3042959d449c70 to your computer and use it in GitHub Desktop.
snipers from pgcat (e1e4929d)
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
match query_parts[0].to_ascii_uppercase().as_str() { | |
"BAN" => { | |
trace!("BAN"); | |
ban(stream, query_parts).await | |
} | |
"UNBAN" => { | |
trace!("UNBAN"); | |
unban(stream, query_parts).await | |
} | |
"RELOAD" => { | |
trace!("RELOAD"); | |
reload(stream, client_server_map).await | |
} | |
"SET" => { | |
trace!("SET"); | |
ignore_set(stream).await | |
} | |
"PAUSE" => { | |
trace!("PAUSE"); | |
pause(stream, query_parts).await | |
} | |
"RESUME" => { | |
trace!("RESUME"); | |
resume(stream, query_parts).await | |
} | |
"SHUTDOWN" => { | |
trace!("SHUTDOWN"); | |
shutdown(stream).await | |
} | |
"SHOW" => match query_parts[1].to_ascii_uppercase().as_str() { | |
"HELP" => { | |
trace!("SHOW HELP"); | |
show_help(stream).await | |
} | |
"BANS" => { | |
trace!("SHOW BANS"); | |
show_bans(stream).await | |
} | |
"CONFIG" => { | |
trace!("SHOW CONFIG"); | |
show_config(stream).await | |
} | |
"DATABASES" => { | |
trace!("SHOW DATABASES"); | |
show_databases(stream).await | |
} | |
"LISTS" => { | |
trace!("SHOW LISTS"); | |
show_lists(stream).await | |
} | |
"POOLS" => { | |
trace!("SHOW POOLS"); | |
show_pools(stream).await | |
} | |
"CLIENTS" => { | |
trace!("SHOW CLIENTS"); | |
show_clients(stream).await | |
} | |
"SERVERS" => { | |
trace!("SHOW SERVERS"); | |
show_servers(stream).await | |
} | |
"STATS" => { | |
trace!("SHOW STATS"); | |
show_stats(stream).await | |
} | |
"VERSION" => { | |
trace!("SHOW VERSION"); | |
show_version(stream).await | |
} | |
"USERS" => { | |
trace!("SHOW USERS"); | |
show_users(stream).await | |
} | |
_ => error_response(stream, "Unsupported SHOW query against the admin database").await, | |
}, | |
_ => error_response(stream, "Unsupported query against the admin database").await, | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment