Привет. Меня зовут Дима Унковский, я – ведущий разработчик в команде Platform в Grammarly, и я ищу хороших DevOps ребят в нашу команду.
Наша область ответственности – облачная инфраструктура, сопутствующие инструменты и инфраструктурные сервисы. Улучшая их, мы делаем все, чтобы продуктовым командам было удобнее разрабатывать и поддерживать продукт Grammarly.
| # This is an example of a high-level application (service) that can run along with | |
| # platform agents, write metrics and logs to them. | |
| namespace: example | |
| containers: | |
| app: | |
| image: alpine:3.2 | |
| # We wrote a simple program that on every tick prints the iterator, | |
| # increments a metric in StatsD and writes a line to the log file | |
| cmd: |- |
| # This is a manifest that describes "platform" agents that we run on every instance. | |
| # It includes auxilary services that work alongside with the application containers | |
| # to provide logging and monitoring. | |
| # | |
| # This file looks a bit tough, but that's what happens when you meet the reality. | |
| # We have also pruned it a bit to remove our company specifics. | |
| # | |
| # You may notice "env", "role" and "track" variables. We specify them as EC2 instance | |
| # tags and pass them to rocker-compose on every run. This allows us to distinguish | |
| # instances and do basic service discovery and A/B testing. |
| -module(brute). | |
| -export([brute/1]). | |
| brute_(N, M, _, O) when N == M -> | |
| O; | |
| brute_(N, M, L, O) -> | |
| [string:right(integer_to_list(N), L, $0) | brute_(N + 1, M, L, O)]. | |
| brute(N) -> | |
| brute_(0, math:pow(10, N), N, []). |
| // Заюзай node-sync v0.1.9beta2, в ней есть .asyncMiddleware() | |
| // это маленькая магия, которая позволяет писать "синхронные" функции типа function(req, res, next) | |
| // еще не знаю, как ее лучше назвать... | |
| app.post('/q/register', function(req, res) { | |
| var mysql = database.spawnConnection(); | |
| // А можно реализацию beginSync? | |
| mysql.beginSync(); |
| createEdge : function(e, callback) | |
| { | |
| var self = this, tryNum = 0, | |
| isolateRetryAttempts = 20, | |
| isolateRetryInterval = 1000; | |
| callback = callback || function(){}; | |
| if (!(e instanceof Edge) || !e.isValid()) { | |
| return callback(new Error("Invalid edge passed")); |
| function getUserSummary(userId, callback) | |
| { | |
| async.parallel({ | |
| user : function(callback) { | |
| db.users.findUserById(userId, callback) | |
| }, | |
| tweets : function(callback) { | |
| db.users.getTweets(userId, callback) |
| var path = require('path') | |
| , fs = require('fs') | |
| , Sync = require('sync') | |
| // Return a future which just pauses for a certain amount of time | |
| function realish (p) { | |
| return path.resolve(path.dirname(fs.readlink.sync(fs, p))) | |
| } |
| function someAsyncFunction(param, callback) { | |
| setTimeout(function(){ | |
| callback(null, param); // result | |
| }, 100) | |
| } | |
| Function.prototype.sync = function(param) { | |
| this(param, function(e, result) { | |
| Fiber.run(result); // substitute result instead of yield, resume current Fiber |
| someObject = { | |
| myNewMethod : function(a, b) // <-- no callback | |
| { | |
| console.log(Fiber.current); // Inside of fiber | |
| if (a == 1) | |
| throw "'a' cannot be 1"; // we can use throw here | |