Let
For any text input
Let
For any text input
| defmodule EventStore do | |
| @moduledoc """ | |
| - Resilient disk_log handling with automatic repair | |
| - Batch writing for better performance | |
| - Automatic log file maintenance | |
| - Monitoring and metrics | |
| - Quick recovery after crashes | |
| """ | |
| use GenServer |
| #!/usr/bin/env bash | |
| # Requires direnv: https://direnv.net/ | |
| # Check if this is a devcontainer project | |
| if [[ ! -f .devcontainer/devcontainer.json ]] && [[ ! -f devcontainer.json ]]; then | |
| return # Not a devcontainer project, do nothing | |
| fi | |
| if ! command -v devpod >/dev/null 2>&1; then | |
| return # devpod not available, do nothing |
| You are an assistant that engages in extremely thorough, self-questioning reasoning. Your approach mirrors human stream-of-consciousness thinking, characterized by continuous exploration, self-doubt, and iterative analysis. | |
| ## Core Principles | |
| 1. EXPLORATION OVER CONCLUSION | |
| - Never rush to conclusions | |
| - Keep exploring until a solution emerges naturally from the evidence | |
| - If uncertain, continue reasoning indefinitely | |
| - Question every assumption and inference |
| defmodule MCP.Types do | |
| @moduledoc """ | |
| Core types for the Model Context Protocol (MCP). | |
| """ | |
| use TypedStruct | |
| defmodule RequestId do | |
| @type t :: String.t() | integer() | |
| end |
| import { Observable, Scheduler } from 'rxjs'; | |
| import { Subscription } from 'rxjs'; | |
| import { Action } from 'rxjs/internal/scheduler/Action'; | |
| export function arrRemove<T>(arr: T[] | undefined | null, item: T) { | |
| if (arr) { | |
| const index = arr.indexOf(item); | |
| 0 <= index && arr.splice(index, 1); | |
| } | |
| } |
| /* Main font family customization for core UI elements */ | |
| .monaco-workbench *:not(.codicon) { | |
| font-family: 'IBM Plex Mono', monospace !important; | |
| } | |
| /* Set specific font size for list elements */ | |
| .monaco-list-row, | |
| .monaco-list-rows { | |
| font-size: 12px; | |
| } |
| package main | |
| import ( | |
| "context" | |
| "fmt" | |
| "log" | |
| "time" | |
| "internal/config" |
| defmodule App.Repo.Migrations.CreateExtensionTimescale do | |
| use Ecto.Migration | |
| def up do | |
| # enable extension | |
| execute("CREATE EXTENSION IF NOT EXISTS timescaledb CASCADE") | |
| # remove primary key constraint | |
| execute("ALTER TABLE events DROP CONSTRAINT events_pkey CASCADE") | |
| # create hypertable | |
| execute("SELECT create_hypertable('events', 'created_at')") |
| defmodule Nghenhan.BinanceCollector.Supervisor do | |
| use Supervisor | |
| def start_link(opts) do | |
| Supervisor.start_link(__MODULE__, opts, name: __MODULE__) | |
| end | |
| @impl true | |
| def init(_opts) do | |
| children = [ |