michaelklishin / rabbit-hole Goto Github PK

View Code? Open in Web Editor NEW

404.0 404.0 112.0 1011 KB

RabbitMQ HTTP API client in Go

License: BSD 2-Clause "Simplified" License

Makefile 0.55% Shell 1.30% Go 97.55% Batchfile 0.60%

go golang monitoring rabbitmq

rabbit-hole's People

Contributors

Stargazers

Watchers

Forkers

kavu akeem tongjieyi yongma wj24021040 relops signalvine okmeter wheelcomplex maryvilledev dcorbacho ewilde woxihuanjia alex-slynko loafoe semanticallynull andeya totherme sokenhe momcilovic digideskio jippi jiancheung barryz akutta e-nikolov jakauppila mweibel stongo jeandeaual ahjdzx histal1 blogoslov fossabot j-kaplan leoluz jordanbcooper pmoneda paulolimarb opsrampdeveloper janberktold rvelaz markgunnels karlmutch blamarvt alexrudd chrismatteson codelingobot friendlydan daanikus ferozjilla thavlik racaharya wangdrew lorock fenollp thudry smartrecruiters jaroslaw-bochniak yongbig kgrieco beetahnator masterxavierfox justabaka niclic markfisher jereques flaticols ansd aaronlyc coderanger pathcl adestis-bm serviceware michalkurzeja daktari sxueck chunyilyu hmrbarros thomasvnn mrluje hjweddie sauci kbabiakg2a zerpet mkuratczyk needsaholiday deefdragon aitorpazos shubhang93 hetianxia yuihukoou andygrunwald sure-l wangguanxiaoer pazderak mirahimage ikpehlivan stateofdenial mqhenning

rabbit-hole's Issues

Support GET api/exchanges/{vhost}

Support GET /api/bindings/{vhost}/{queue}/{exchange}

Support GET /api/connections/{name}

Convenience method for fetching statistics DB node

This is easily accessible via GET /api/overview but it's a bit difficult to discover.

Support PUT /api/policies/{vhost}/{name}

Support GET /api/policies/{vhost}

Support GET /api/queues/{vhost}/{name}

Support PUT /api/exchanges/{vhost}/{name}

Support POST /api/bindings/{vhost}/{queue}/{exchange}

Support GET /api/exchanges/{vhost}/{name}

Support DELETE /api/queues/{vhost}/{name}

Support PUT /api/queues/{vhost}/{name}

Support GET /api/policies/{vhost}/{name}

Support GET /api/exchanges/{vhost}/{name}/{bindings}

Support PUT /api/vhosts/{name}

Support DELETE /api/exchanges/{vhost}/{name}

Support PUT /api/permissions/{vhost}/{user}

Support GET /api/bindings/{vhost}/{queue}/{exchange}/{props}

Support GET /api/bindings/{vhost}

Add Client#protocol_ports

See ruby-amqp/rabbitmq_http_api_client@e2f9be5

Broken Overview() method for rabbitmq management 3.5.1

/api/overview response:

{"management_version":"3.5.1","rates_mode":"basic","exchange_types":[{"name":"topic","description":"AMQP topic exchange, as per the AMQP specification","enabled":true},{"name":"fanout","description":"AMQP fanout exchange, as per the AMQP specification","enabled":true},{"name":"direct","description":"AMQP direct exchange, as per the AMQP specification","enabled":true},{"name":"headers","description":"AMQP headers exchange, as per the AMQP specification","enabled":true}],"rabbitmq_version":"3.5.1","cluster_name":"rabbit@localhost","erlang_version":"17","erlang_full_version":"Erlang/OTP 17 [erts-6.1] [source] [64-bit] [smp:4:4] [async-threads:30] [hipe] [kernel-poll:true]","message_stats":{},"queue_totals":{"messages":0,"messages_details":{"rate":0.0},"messages_ready":0,"messages_ready_details":{"rate":0.0},"messages_unacknowledged":0,"messages_unacknowledged_details":{"rate":0.0}},"object_totals":{"consumers":0,"queues":1,"exchanges":8,"connections":0,"channels":0},"statistics_db_event_queue":0,"node":"rabbit@localhost","statistics_db_node":"rabbit@localhost","listeners":[{"node":"rabbit@localhost","protocol":"amqp","ip_address":"127.0.0.1","port":5672},{"node":"rabbit@localhost","protocol":"clustering","ip_address":"::","port":25672},{"node":"rabbit@localhost","protocol":"mqtt","ip_address":"::","port":1883},{"node":"rabbit@localhost","protocol":"stomp","ip_address":"::","port":61613}],"contexts":[{"node":"rabbit@localhost","description":"RabbitMQ Management","path":"/","port":"15672"}]}

in contexts item:

{"node":"rabbit@localhost","description":"RabbitMQ Management","path":"/","port":"15672"}

field "port" is of type string instead of expected int.

Support GET /api/channels/{channel}

Add Client#enabledProtocols

See ruby-amqp/rabbitmq_http_api_client@5018ac4

Support GET /api/queues/{vhost}/{name}/{bindings}

client.go is not re-using keep-alive connections

According to go docs (https://golang.org/src/net/http/response.go?s=1408:1586#L19), unless response.Body is read to completion AND closed, default http.client’s transport will not reuse keep-alive connections.

Support DELETE /api/policies/{vhost}/{name}

Support GET /api/queues/{vhost}

Support DELETE /api/bindings/{vhost}/{queue}/{exchange}/{props}

Support PUT /api/users/{name}

Support GET /api/permissions/{vhost}/{user}

Support DELETE /api/users/{name}

Expose consumer utilization

I'd like to add the consumer_utilisation in the QueueInfo struct but I'm not sure how to achieve this without using a more flexible unpacking routine than encoding/json.

On the wire, an empty value looks like this:

"consumer_utilisation":"",

And a populated value looks like this:

"consumer_utilisation": 0.04539788196622643,

So if I try, this will work for the empty value, but blows up with a populated value:

ConsumerUtilisation string `json:"consumer_utilisation"`

Conversely, if I try

ConsumerUtilisation float64 `json:"consumer_utilisation"`

This will unpack the the populated float but will blow up with an empty string.

The option

ConsumerUtilisation float64 `json:"consumer_utilisation,string"`

doesn't seem to handle the empty string either.

Another approach might be to ask RabbitHQ if this could get patched on the server, but this might end up breaking other clients, and is only available from a certain release forwards.

Any ideas on how to proceed?