mirror of
https://github.com/elastic/logstash.git
synced 2025-04-23 22:27:21 -04:00
parent
5a4d4bc3ba
commit
1eef8c9be7
2 changed files with 12 additions and 0 deletions
|
@ -33,6 +33,10 @@ module LogStash
|
|||
)
|
||||
end
|
||||
|
||||
def pipeline
|
||||
service.get_shallow(:stats, :pipelines)
|
||||
end
|
||||
|
||||
def memory
|
||||
memory = service.get_shallow(:jvm, :memory)
|
||||
{
|
||||
|
|
|
@ -50,6 +50,10 @@ module LogStash
|
|||
respond_with :mem => mem_payload
|
||||
end
|
||||
|
||||
get "/pipeline" do
|
||||
respond_with :pipeline => pipeline_payload
|
||||
end
|
||||
|
||||
private
|
||||
|
||||
def events_payload
|
||||
|
@ -67,6 +71,10 @@ module LogStash
|
|||
def mem_payload
|
||||
@stats.memory
|
||||
end
|
||||
|
||||
def pipeline_payload
|
||||
@stats.pipeline
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue