-
Notifications
You must be signed in to change notification settings - Fork 1.3k
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
add a RPC call to flush buffers and stop workers #1134
Conversation
@@ -82,6 +82,16 @@ def run_rpc_server | |||
end | |||
nil | |||
} | |||
@rpc_server.mount_proc('/api/plugins.flushBuffersAndKillWorkers') { |req, res| |
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.
killWorkers operation is not related with plugins so adding it to plugins
prefix seems not good.
processes is better.
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.
Understood.
9116cdb
to
b46e652
Compare
@repeatedly could you review once again? |
@@ -75,6 +75,16 @@ def run_rpc_server | |||
Process.kill :TERM, $$ | |||
nil | |||
} | |||
@rpc_server.mount_proc('/api/processes.flushBuffersAndKillWorkers') { |req, res| | |||
$log.debug "fluentd RPC got /api/plugins.flushBuffersAndKillWorkers request" |
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.
plugins -> processes
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.
uguh, fixed :P
b46e652
to
8507b3c
Compare
LGTM |
revised version of #1111.