ochaton

local ffi = require 'ffi'

local ip = "127.1.2.3"
local p = ffi.cast('const uint8_t *', ip)

local ffi_string = ffi.string
local tonumber = tonumber

local getaddr_ffi = function(ip)
	local prev = 0

ochaton

local record fun
	record iterator<T>
		sum: function(iterator<number>): number
		reduce: function<R>(iterator<T>, (function(R, T): R), R): R
	end

	iter: function<T>({T}): iterator<T>
	sum: function({number}): number

	reduce: function<T,R>({T}, (function(R,T):R), R): R

ochaton

#!/usr/bin/env tarantool
local uuid = require 'uuid'
local fun = require 'fun'
local fiber = require 'fiber'

local instance_name = assert(arg[1], "instance_name is required")

local config = {
	replication = {'127.0.0.1:3301', '127.0.0.1:3302', '127.0.0.1:3303'},
	replication_connect_quorum = 2,

ochaton

mkdir "$HOME/tarantool";
git clone --recurse-submodules https://github.com/tarantool/tarantool.git && cd tarantool;
for tag in $(git tag | sort | perl -lnE '$h{$mj}=$_ if (($mj) = $_=~m{^(1\.10|2\.\d+)\.\d+$});}{say join " ", sort keys %h'); do
  echo "================== Installing $tag ================";
  git clean -xdf .;
  git checkout "$tag" \
    && git clean -xdf . \
    && git pull origin "$tag" \
    && git reset --hard "origin/$tag" \
    && git submodule update --init --recursive --force \

ochaton

local type Distance = number
local type VertexId = number

local record Node
	preds: {VertexId:Distance}
	succs: {VertexId:Distance}
end

local node_mt: metatable<Node> = {
	__index = Node,

ochaton

box.orm = require 'orm' . configure {
	users = {
		format = {
			{ name = 'uid',     type = 'unsigned' },
			{ name = 'email',   type = 'string'   },
		},
		indexes = {
			{ name = 'primary', parts = { 'uid'          } },
			{ name = 'email',   parts = { 'email', 'uid' } },
		},

ochaton

#!/usr/bin/env tarantool
print(_G._TARANTOOL)

-- box.cfg{}
require 'jit.dump'.start("hotloop=1")

local fiber = require 'fiber'
local log = require 'log'
local json = require 'json'
json.cfg{ encode_use_tostring = true }

ochaton

---
-- TODO:
-- Support all ops for update
-- Create separate module
local ffi = require 'ffi'
local fiber = require 'fiber'

ffi.cdef[[
	struct header_v11 {
		uint32_t header_crc32c;

ochaton

local Coro = {}
Coro.__index = Coro

local S = {
	queue = require 'q'(),
}

function S:push(o)
	self.queue:push(o)
end

ochaton

#!/usr/bin/tarantool

local fiber = require 'fiber'
local clock = require 'clock'
local log   = require 'log'

local bus = setmetatable({
	put = function(self, msg)
		while not self.closed and self.msg ~= nil do
			self.cond:wait()