Proxy

Proxy connector

$3

- connection manager for simple proxy with/without http liveness probe
- patroni compatible
- stats page

$3

``ts
import { Server as HTTPServer } from 'http';
import { Server as TCPServer } from 'net';
import { inject, container, Types, Core } from '@biorate/inversion';
import { IConfig, Config } from '@biorate/config';
import { ProxyConnector } from '@biorate/proxy';

const httpPort = 8001;
const clientPort = 7001;
const serverPort = 7002;

export class Root extends Core() {
public static connect() {
const socket = new TCPSocket();
socket.connect(serverPort);
return socket;
}

@inject(ProxyConnector) public connector: ProxyConnector;

public http: HTTPServer;

public tcp: TCPServer;

protected constructor() {
super();
this.http = new HTTPServer();
this.http.listen(httpPort);
this.http.on('request', (req, res) => {
res.writeHead(200);
res.end('1');
});
this.tcp = new TCPServer();
this.tcp.listen(clientPort);
this.tcp.on('connection', (socket) =>
socket.on('data', (data) => socket.write(${data} world!)),
);
}
}

container.bind(Types.Config).to(Config).inSingletonScope();
container.bind(ProxyConnector).toSelf().inSingletonScope();
container.bind(Root).toSelf().inSingletonScope();

container.get(Types.Config).merge({
Proxy: [
{
name: 'connection',
retry: 10,
server: {
address: {
host: 'localhost',
port: serverPort,
},
},
clients: [
{
liveness: http://localhost:${httpPort},
address: {
host: 'localhost',
port: clientPort,
},
},
],
},
],
});

(async () => {
const root = container.get(Root);
await root.$run();
const socket = Root.connect();
socket.write('Hello');
socket.on('data', (data) => {
console.log(data.toString()); // Hello world!
});
})();
``

$3

- Documentation can be found here - docs.

$3

See the CHANGELOG

$3

MIT

Copyright (c) 2021-present Leonid Levkin (llevkin)