Skip to content

Instantly share code, notes, and snippets.

View hexfusion's full-sized avatar
🐀
scampering

Sam Batschelet hexfusion

🐀
scampering
  • Red Hat
  • gRPC stream
View GitHub Profile
type PoolSynchronizerStatus struct {
// poolSynchronizerType describes the type of the pool synchronizer.
// +kubebuilder:validation:Required
PoolSynchronizerType PoolSynchronizerType `json:"poolSynchronizerType"`
// machineCount is the number of machines that are managed by the node synchronizer.
// +kubebuilder:validation:Required
// +kubebuilder:validation:Minimum=0
MachineCount int64 `json:"machineCount"`
// updatedMachineCount is the number of machines that have been updated by the node synchronizer.
// +kubebuilder:validation:Required
featureGateAccessor := featuregates.NewFeatureGateAccess(
desiredVersion, missingVersion,
configSharedInformer.Config().V1().ClusterVersions(), configSharedInformer.Config().V1().FeatureGates(),
recorder,
)
go featureGateAccessor.Run(ctx)
// dep for feature gate
ctrlctx.ConfigInformerFactory.Start(ctrlctx.Stop)
#!/usr/bin/env bash
#set -x
IMAGE_NAME="$1"
RELEASE="$2"
TAG="$3"
if [ "$IMAGE_NAME" == "" ]; then
echo "IMAGE_NAME is required. example cluster-etcd-operator"
set $mod Mod4
new_window pixel 1
new_float normal
workspace_layout default
hide_edge_borders none
bindsym $mod+u border none
extern crate serde;
extern crate serde_yaml;
use serde::{Deserialize, Serialize};
#[derive(Debug, Serialize, Deserialize, PartialEq)]
struct Config {
max_memory_pages: u32,
}
A WebSocket is a persistent connection between a client and server.
WebSockets provide a bidirectional, full-duplex communications channel
that operates over HTTP through a single TCP/IP socket connection.
Allows for bidirectional communication of a single tcp conn.
#!/usr/bin/python3
def binarySearch(arr, x):
l = 0
import exec from 'k6/execution';
export const options = {
scenarios: {
constant_request_rate: {
executor: 'constant-arrival-rate',
rate: 1000,
timeUnit: '1s', // 1000 iterations per second
duration: '120s',
preAllocatedVUs: 1500, // how large the initial pool of VUs would be
@hexfusion
hexfusion / gist:0596b051e857030b6b7cc907241ac1aa
Last active June 2, 2023 16:00
Interview Reference Materials
Introduction. A couple of minutes about what you’re most interested in and excited about at ava labs and crypto in general.
- Tell me about your previous most exciting task.
- Tell me about a tech project you’ve worked on in your spare time.
- Tell me about NodeJs event loop.
- Implement API to serve crypto prices in NodeJS.
───────────────────────────┐
┌─>│ timers │
│ └─────────────┬─────────────┘
#!/bin/bash
# start server in another window
# avalanche-network-runner server \
# --log-level debug \
# --port=":8080" \
# --grpc-gateway-port=":8081"
# tested with v1.8.6
AVALANCHEGO_EXEC_PATH=""
func Test_NewAggregate(t *testing.T) {
assert := assert.New(t)
scenarios := []struct {
name string
errs []error
wantNil bool
}{
{
name: "no errors",
errs: nil,