Author: Brian Thorne Status: Draft Created: 2020-03-31 Updated: 2020-04-06
In early 2020 blocking has been added to increase the capacity of the Anonlink system, however the system cannot
import numpy as np | |
from collections import deque | |
import time | |
import threading | |
import matplotlib.pyplot as plt | |
def rollingFFT(s, n, dt): | |
fy = np.fft.fft(s) | |
# Frequencies associated with each samples |
"""Streaming pickle implementation for efficiently serializing and | |
de-serializing an iterable (e.g., list) | |
Created on 2010-06-19 by Philip Guo | |
http://code.google.com/p/streaming-pickle/ | |
Modified by Brian Thorne 2013 to add base64 encoding to support | |
python3 bytearray and the like. | |
""" |
from datetime import datetime | |
import hmac | |
import hashlib | |
import xml.etree.ElementTree | |
from urllib.parse import urlencode | |
from minio.credentials import Static, Credentials | |
from minio.fold_case_dict import FoldCaseDict | |
from minio.compat import urlsplit | |
from minio.helpers import get_sha256_hexdigest |
Cross posted from blog.n1analytics.com
At N1 Analytics we use Kubernetes for running experiments, continuous integration testing and deployment. In this post I document setting up a Kubernetes cluster to automatically provision TLS certificates from Let's Encrypt using Jetstack's Certificate Manager, the helm package manager and the nginx-ingress controller.
I wrote this after migrating our cluster from traefik to use cert manager and nginx-ingress. The end state will be one where we can create Kubernetes ingress with a TLS certificate with only a set of annotations in the respective helm template.
I'm going to assume some background knowlege for this post, if you haven't heard of [Let's Encrypt](https://letsencrypt.org/abou
package com.lightbend.akka.sample; | |
import akka.actor.Props; | |
import akka.actor.UntypedAbstractActor; | |
class UntyptedSimplePrime { | |
static class IsPrimeActor extends UntypedAbstractActor { | |
// Define the messages |
package com.lightbend.akka.sample; | |
import akka.actor.*; | |
public class StatefulPrime { | |
static class IsPrimeActor extends AbstractLoggingActor { | |
// Define the actor protocol | |
static class IsPrimeRequest { |
package com.lightbend.akka.sample; | |
import akka.actor.AbstractLoggingActor; | |
import akka.actor.Props; | |
import java.util.HashMap; | |
import java.util.Map; | |
class StatelessPrime { |