Here be deamons, this module is still under heavy development not all parsers
are hooked up on the API's yet. Feel free to contribute and build the best
HAProxy orchestration module out there.

haproxy

HAProxy is an amazing proxy, it has support for many different algorithms for load balancing, it can handle HTTP, TCP, WebSocket connects, does SSL termination and much much more. But managing these proxies can be a bit of a pain. That's where haproxy comes in, it provides a access to the stat socket of HAProxy which allows you to enable, disable servers and front-ends, read out stats and much more. In addition to that it's also capable of hot reloading configuration changes and starting, stopping your HAProxy, even when it's running as a daemon.

Installation

The package is released in npm, the Node.js package registry:

npm install haproxy --save

haproxy.cfg

In order to make your HAProxy installation work with this module you need to expose the stats socket interface of HAProxy. If you don't have this specified in your configuration please add the following to the global section of your configuration.

global
  # Exposes the stat socket so we can manage the proxy through node.js
  stats socket /tmp/haproxy.sock level admin

Reload you configuration to make this change active and you should be ready to rock.

API

'use strict';

var HAProxy = require('haproxy');

var haproxy = new HAProxy('/optional/socket/path.sock', { /* options */ });

An alternate interface is:

var haproxy = new HAProxy({ socket: 'path' /*, the rest of the options */});

I personally prefer the first interface as a correct socket path is required for a functioning module. The options are not required, but the following options are supported:

• pid: The process id
• pidFile: The location of the pid file
• config: The location of the configuration file
• discover: Tries to find your HAProxy instance if you don't know the pid
• socket: The location of the unix socket
• [optional] which: The location of the HAProxy

There's a lot of freedom in this module, callbacks are always optional so you can do fire and forget management as well as how you add the callbacks.

haproxy.method('value', function () { .. });

//
// Is the same as
//

haproxy.method('value').call(function () { .. });

It also supports a chaining API:

haproxy.method().and.method2('value').and.method3('value', function () {
  // woop woop
});

//
// The example above will call method() and method() as fire and forget and
// method3() is called with a callback. It doesn't maintain order so it could be
// that method() is called after method3() as it could take longer to complete.
//

The following methods are available:

HAProxy.clear(all, fn)

Clear the max values of the statistic counts in the proxy for each front-end and backend. When the all boolean is supplied it will clean all the stats. This has the same effect as restarting.

haproxy.clear(function (err) {
  // stats cleared
})

HAProxy.disable(backend, server, fn)

Mark the given server a down for maintenance, in this mode no checks will be preformed on the server until it leaves maintenance.

haproxy.disable('realtime', 'server1', function (err) {
  // server out of the pool
});

HAProxy.enable(backend, server, fn)

If the server was previously marked as down for maintenance, it will mark the server as up again and all checks will be re-enabled.

haproxy.enable('realtime', 'server1', function (err) {
  // server enabled again
});

HAProxy.pause(frontend, fn)

Mark the frontend as temporarily stopped. This corresponds to the mode which is used during a softrestart. The frontend releases the port it was bound on but it can be enabled again when needed.

haproxy.pause('frontend', function (err) {
  // disable the frontend
});

HAProxy.resume(frontend, fn)

Resume the front-end that you previously paused.

haproxy.resume('frontend', function (err) {
  // enable the frontend
});

HAProxy.errors([id], fn)

Show the server errors or the errors for the given session id. The session id is optional.

haproxy.errors(function (err, errors) {
  console.log(errors);
});

HAProxy.weight(backend, server, [weight], fn)

Get the assigned weight for the server from the given backend.

haproxy.weight('backend', 'server1', function (err, weight) {
  console.log(weight);
});

If the weight argument is set, it will automatically set the weight for this server:

haproxy.weight('backend', 'server1', 10, function (err) {
// woop
});

Please note that the weight should be between 0 and 255

HAProxy.maxconn([frontend], max, fn)

Update the maxconnection setting for the frontend.

haproxy.maconn('public', 809809, function (err) {
  // handle failures.
});

If no frontend is supplied it will apply this configuration globally

haproxy.maconn(809809, function (err) {
  // handle failures.
});

HAProxy.ratelimit(24242, fn)

Change the process-wide rate limit. Setting this value to 0 will disable the rate-limitter.

haproxy.connections(4242, function (err) {
  // handle errors ._.
});

HAProxy.compression(2, fn)

Change the maximum input compression rate.

haproxy.compression(3, function (err) {
  // oh noes. error handling, but this is optional, if you don't care about
  // errors
});

HAProxy.info(fn)

Retrieve some information about the HAProxy

haproxy.info(function (err, info) {
  // do something with the info..
});

HAProxy.session([id], fn)

Dump all know session if no session id is provided.

haproxy.session(function (err, sess) {
  // wooop
});

HAProxy.stats(id, type, id, fn)

Dump all statistics, if you want everything, supply -1 for all values.

haproxy.stats('-1', '-1', '-1', function () {

});

License

MIT