This is an incremental tutorial on how to share JetStream assets between accounts.
The options are not going to be fully explained unless they are vital. The tools used
are nats cli and nsc, and both have excellent --help.
Note that this tutorial is expected to be followed in sequence.
| DROP VIEW IF EXISTS uuid7; | |
| CREATE VIEW uuid7 AS | |
| WITH unixtime AS ( | |
| SELECT CAST((STRFTIME('%s') * 1000) + ((STRFTIME('%f') * 1000) % 1000) AS INTEGER) AS time | |
| -- SELECT CAST((UNIXEPOCH('subsec') * 1000) AS INTEGER) AS time -- for SQLite v3.38.0 (2022) | |
| ) | |
| SELECT PRINTF('%08x-%04x-%04x-%04x-%012x', | |
| (select time from unixtime) >> 16, | |
| (select time from unixtime) & 0xffff, | |
| ABS(RANDOM()) % 0x0fff + 0x7000, |
| def accept(port) do | |
| {:ok, socket} = | |
| :gen_tcp.listen(port, [:binary, active: false, reuseaddr: true, packet: 0, nodelay: true]) | |
| Logger.info("Accepting connections on port #{port}") | |
| loop_acceptor(socket) | |
| end | |
| defp loop_acceptor(socket) do | |
| {:ok, client_conn} = :gen_tcp.accept(socket) |
| #NoEnv | |
| #Persistent | |
| SetBatchLines, -1 | |
| #Include <Socket> | |
| /* | |
| Launch AutoHotkey code from a StreamDeck efficiently using GET requests |
| #!/bin/bash | |
| # 0 - SSH | |
| # This isn't necessary but if you ssh into the computer all the other steps are copy and paste | |
| # Set a password for root | |
| passwd | |
| # Get network access | |
| iwctl | |
| """ |
| /* | |
| * MIT License | |
| * | |
| * Copyright (c) 2023-2024 Fabio Lima | |
| * | |
| * Permission is hereby granted, free of charge, to any person obtaining a copy | |
| * of this software and associated documentation files (the "Software"), to deal | |
| * in the Software without restriction, including without limitation the rights | |
| * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | |
| * copies of the Software, and to permit persons to whom the Software is |
set inputVolume to input volume of (get volume settings)
if inputVolume = 0 then
set inputVolume to 100
display notification "Volume set to 100" with title "✅ Microphone is on"
| defmodule Hungarian do | |
| @moduledoc """ | |
| Written by Adam Kirk – Jan 18, 2020 | |
| Most helpful resources used: | |
| https://www.youtube.com/watch?v=dQDZNHwuuOY | |
| https://www.youtube.com/watch?v=cQ5MsiGaDY8 | |
| https://www.geeksforgeeks.org/hungarian-algorithm-assignment-problem-set-1-introduction/ |
| IO.puts("I'm here! Sleeping for 2 seconds") | |
| Process.sleep 2_000 # waiting for the other node | |
| nodes = MapSet.new([:app@app1, :app@app2]) | |
| other_node = | |
| nodes | |
| |> MapSet.delete(Node.self()) | |
| |> MapSet.to_list() | |
| |> List.first() |
| # We use this ClusterLoadBalancer to prevent hot nodes in our load balanced setup. | |
| # The WebSockets are provided by Phoenix through the PushEx application https://github.com/pushex-project/pushex/ | |
| # The load balancer's `Worker` module is where the bulk of the cluster orchestration happens, using pg2 for cross node communication | |
| defmodule ClusterLoadBalancer.Behavior do | |
| @moduledoc """ | |
| Behavior for implementing a ClusterLoadBalancer compatible tool. | |
| """ | |
| @callback count() :: number |
