yanniszark

apiVersion: v1
kind: Service
metadata:
  labels:
    app: ldap
  name: ldap-service
  namespace: kubeflow
spec:
  type: ClusterIP
  clusterIP: None

yanniszark

# This already exists.
# If it doesn't, uncomment this.
#dn: dc=arrikto,dc=com
#objectClass: dcObject
#objectClass: organization
#o: Arrikto
#dc: arrikto

dn: ou=People,dc=arrikto,dc=com
objectClass: organizationalUnit

yanniszark

connectors:
- type: ldap
  # Required field for connector id.
  id: ldap
  # Required field for connector name.
  name: LDAP
  config:
    # Host and optional port of the LDAP server in the form "host:port".
    # If the port is not supplied, it will be guessed based on "insecureNoSSL",
    # and "startTLS" flags. 389 for insecure or StartTLS connections, 636

yanniszark

apiVersion: networking.istio.io/v1alpha3
kind: EnvoyFilter
metadata:
  name: authn-filter
spec:
  workloadLabels:
    istio: ingressgateway
  filters:
  - filterConfig:
      httpService:

yanniszark

apiVersion: kubeflow.org/v1alpha1
kind: KfDef
spec:
  applications:
    - name:
      kustomizeConfig:
        name: jupyter-web-app
        overlays:
          - istio
        repoRef:

yanniszark

# This is the config to install Kubeflow on an existing K8s cluster, with support
# for multi-user and LDAP auth using Dex.

apiVersion: kfdef.apps.kubeflow.org/v1alpha1
kind: KfDef
metadata:
  name: demo
  namespace: kubeflow
spec:
  applications:

yanniszark

#!/bin/bash

HOSTFS="/mnt/hostfs"

function sleep_forever() {
    while true; do sleep 100; done
}

function setup_kubectl() {
# Setup kubectl

yanniszark

#!/usr/bin/env python3
import argparse
import sys
import os

template = """
apiVersion: batch/v1
kind: Job
metadata:
  name: {d.name}-{}

yanniszark

#!/usr/bin/env python3

import os
import sys
from subprocess import run

deps = [
    "k8s.io/api@kubernetes-{version}",
    "k8s.io/apiextensions@kubernetes-{version}",
    "k8s.io/apimachinery@kubernetes-{version}",

yanniszark

import goyaml "github.com/go-yaml/yaml"

func SplitYAML(resources []byte) ([][]byte, error) {

	dec := goyaml.NewDecoder(bytes.NewReader(resources))

	var res [][]byte
	for {
		var value interface{}
		err := dec.Decode(&value)