grampelberg

//! Utilities to work with metrics up for tests.
use std::sync::atomic::Ordering;

use eyre::{Result, eyre};
use metrics::{
    Counter, Gauge, Histogram, Key, KeyName, Metadata, Recorder, SharedString,
    Unit,
};
use metrics_util::registry::{AtomicStorage, Registry, Storage};
use tokio::time;

grampelberg

loop {
            tokio::select! {
                _ = connect_retry.tick(), if connection.is_none() => {
                    let Ok(conn) = endpoint.connect(self.reader_addr.clone(), reader::Sink::ALPN).await else {
                        writer_log!(self, info, "connection failed");
                        metrics::counter!("writer.connect_failed").increment(1);

                        continue;
                    };

grampelberg

        let errors: Vec<kube::Error> = futures::stream::iter(crate::resources::all())
            .map(|resource| async move { client.create(&PostParams::default(), &resource).await })
            .buffered(100)
            .inspect(|result| {
                if let Ok(o) = result {
                    info!(name = o.name_any(), "created CRD");
                }
            })
            .collect::<Vec<Result<CustomResourceDefinition, _>>>()
            .await

grampelberg

let mut serializer = serde_yaml::Serializer::new(std::io::stdout());
for resource in resources::all() {
    resource.serialize(&mut serializer)?;
}

grampelberg

def my_func(foo, bar):
  def construct(fn):
    class Object:
      pass
    
    Object.foo = foo
    Object.bar = bar
      
    return Object
  

grampelberg

pub fn add(a: i32, b: i32) -> i32 {
    a + b
}

// This is a really bad adding function, its purpose is to fail in this
// example.
#[allow(dead_code)]
fn bad_add(a: i32, b: i32) -> i32 {
    a - b
}

grampelberg

#[derive(Debug, Clone)]
pub struct Client {
    service_url: url::Url,
}

impl Client {
    pub fn new(service_url: &str) -> Result<Self, Report> {
        let url = url::Url::parse(service_url)?;

        Ok(Self { service_url: url })

grampelberg

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">
<plist version="1.0">
<dict>
	<key>KeepAlive</key>
	<true/>
	<key>Label</key>
	<string>com.openssh.ssh-agent-brew</string>
	<key>ProgramArguments</key>
	<array>

grampelberg

#!/usr/bin/env bash

set -o errexit -o nounset -o pipefail

cfg="${HOME}/.oprc"

required_cfg=(
    'OP_ADDRESS'
    'OP_EMAIL'
    'OP_ACCOUNT_KEY'

grampelberg

MKFILE_PATH := $(abspath $(lastword $(MAKEFILE_LIST)))
CURRENT_DIR := $(notdir $(patsubst %/,%,$(dir $(MKFILE_PATH))))

include $(CURRENT_DIR)/.env

include $(CURRENT_DIR)/mk/dependency.mk
include$(CURRENT_DIR)/mk/other.mk

main: dependency-one other-two