Jason Snouffer jsnouffer

jsnouffer / get-resources-by-jq.go

Last active August 5, 2022 13:13

	package main

	import (
	"context"
	"fmt"

	"github.com/itchyny/gojq"
	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
	"k8s.io/apimachinery/pkg/runtime"
	"k8s.io/client-go/dynamic"

jsnouffer / get-deployments.go

Last active August 4, 2022 14:35

	package main

	import (
	"context"
	"fmt"

	v1 "k8s.io/api/apps/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes"
	ctrl "sigs.k8s.io/controller-runtime"

jsnouffer / get-resources-dynamic.go

Last active February 20, 2022 02:56

API Machinery unstructured package

	import (
	"context"
	"fmt"

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
	"k8s.io/apimachinery/pkg/runtime/schema"
	"k8s.io/client-go/dynamic"
	ctrl "sigs.k8s.io/controller-runtime"
	)

jsnouffer / sensitivity_analysis_example.py

Created July 25, 2021 14:55 — forked from romainmartinez/sensitivity_analysis_example.py

Sensitivity analysis of a (scikit-learn) machine learning model

	from sklearn.datasets import make_regression
	import pandas as pd
	from xgboost import XGBRegressor
	import matplotlib.pyplot as plt
	import seaborn as sns

	X, y = make_regression(n_samples=500, n_features=4, n_informative=2, noise=0.3)
	X = pd.DataFrame(X, columns=['A', 'B', 'C', 'D'])

	model = XGBRegressor()

jsnouffer / kstreams-join.java

Last active August 14, 2020 14:36

	import org.apache.kafka.streams.KafkaStreams;
	import org.apache.kafka.streams.StreamsBuilder;
	import org.apache.kafka.streams.StreamsConfig;
	import org.apache.kafka.streams.kstream.JoinWindows;
	import org.apache.kafka.streams.kstream.KStream;

	// ... //

	StreamsBuilder builder = new StreamsBuilder();
	KStream<String, JsonObject> inputStream = builder.stream(inputTopic);

jsnouffer / kstreams-simple-branches.java

Last active August 13, 2020 04:00

	public static final double SOME_CONSTANT = ...;

	// ... //

	// define conditions for each branch (edge) of topology
	Predicate<String, JsonObject> greaterThan = (String key, JsonObject value) -> {
	double dValue = value.get("my_double_value").getAsDouble();
	return dValue > SOME_CONSTANT;
	};

jsnouffer / kstreams-simple.java

Last active August 13, 2020 03:30

	import java.util.Properties;
	import com.google.gson.JsonObject;
	import org.apache.kafka.common.serialization.Serdes;
	import org.apache.kafka.streams.KafkaStreams;
	import org.apache.kafka.streams.StreamsBuilder;
	import org.apache.kafka.streams.StreamsConfig;
	import org.apache.kafka.streams.kstream.KStream;

	// ... //

jsnouffer / kstreams-pom.xml

Created August 12, 2020 19:24

	<dependency>
	<groupId>org.apache.kafka</groupId>
	<artifactId>kafka-streams</artifactId>
	<version>2.6.0</version>
	</dependency>
	<dependency>
	<groupId>org.apache.kafka</groupId>
	<artifactId>kafka-clients</artifactId>
	<version>2.6.0</version>
	</dependency>

jsnouffer / update_service_type.go

Last active August 9, 2020 20:12

	package services

	import (
	"fmt"
	v1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes"
	)

	const typeAnnotation string = "original-service-type"

jsnouffer / list_services.go

Last active August 9, 2020 20:09

	package services

	import (
	apiv1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes"
	)

	// ListServices returns a list of K8 services
	func ListServices(namespace string, client kubernetes.Interface) (*apiv1.ServiceList, error) {