bossek’s gists

bossek / main.rs

Created February 16, 2021 08:24

kafka topic config using librdkafka

	use rdkafka::admin::{AdminClient, AdminOptions, AlterConfig, ResourceSpecifier};
	use rdkafka::client::DefaultClientContext;
	use rdkafka::ClientConfig;
	use tokio;

	#[tokio::main]
	async fn main() {
	let topic = ResourceSpecifier::Topic("accounts_log_changes");
	// kafka-configs.sh --zookeeper zookeeper:2181 --entity-type topics --entity-name accounts_log_changes --describe
	// let config = [AlterConfig::new(topic).set("message.timestamp.type", "CreateTime")];

bossek / day23.ex

Created December 25, 2020 19:22

AoC 2020 Day 23 Part 2 (atomics)

	defmodule Day23 do
	def p2 do
	i = "389547612"
	cups = String.split(i, "", trim: true) \|> Enum.map(&String.to_integer/1)
	start = hd(cups)
	max = 1_000_000
	steps = 10_000_000
	mem = :atomics.new(max, [])
	Enum.each(Enum.zip(cups, tl(cups) ++ [10]), fn {i, next} -> :atomics.put(mem, i, next) end)
	Enum.each(10..max, &:atomics.put(mem, &1, &1 + 1))

bossek / day15part2.ex

Created December 16, 2020 20:10

AoC 2020 Day 15 Part 2 - brute force without Enum.reduce

	defmodule Day15Part2 do
	def go do
	261_214 = solve([1, 2, 3])
	end

	defp solve(already_spoken) do
	start = Enum.count(already_spoken) + 1
	stop = 30_000_000

	spoken = :atomics.new(stop, [])

bossek / day15part2.ex

Created December 16, 2020 19:40

AoC 2020 Day 15 Part 2

	defmodule Day15Part2 do
	def go do
	261_214 = solve([1, 2, 3]) \|> elem(0)
	end

	defp solve(already_spoken) do
	start = Enum.count(already_spoken) + 1
	stop = 30_000_000

	# Assumes last spoken was spoken for the first time.

bossek / day10_p2.ex

Created December 11, 2020 07:30

AoC 2020 Day 10 Part 2

	defmodule Day10P2 do
	def run do
	data = "data/10" \|> File.read!() \|> String.split() \|> Enum.map(&String.to_integer/1)

	[0 \| data]
	\|> Enum.sort(:desc)
	\|> Enum.reduce([{hd(data) + 3, 1}], &[{&1, sum3(&1, &2)} \| &2])
	\|> hd()
	\|> elem(1)
	end

bossek / day16.exs

Created December 16, 2019 15:36

Advent of Code 2019 Day16

	defmodule Day16 do
	def part2(data) do
	signal = parse(data)

	signal
	\|> Enum.reverse()
	\|> Stream.cycle()
	\|> Stream.take(length(signal) * 10000 - offset(data))
	\|> Stream.iterate(fn signal -> Stream.scan(signal, &rem(&1 + &2, 10)) end)
	\|> Enum.at(100)

bossek / day08.exs

Created December 8, 2019 10:52

Advent of Code 2019 Day08

	defmodule Day08 do
	@x 25
	@y 6

	def part1 do
	read_layers()
	\|> Enum.min_by(fn layer -> length(Enum.filter(layer, &(&1 == ?0))) end)
	\|> Enum.group_by(& &1)
	\|> Map.take([?1, ?2])
	\|> Map.values()

bossek / day06.exs

Created December 6, 2019 11:53

Advent of Code 2019 - Day 06