Paul Brabban brabster

Lead Consultant with Equal Experts, specialising in solving data intensive problems with cloud technology

brabster / argo-schema-with-discriminator-values.json

Created November 16, 2020 19:05

	{
	"$id": "http://workflows.argoproj.io/schema.json",
	"$schema": "http://json-schema.org/schema#",
	"definitions": {
	"google.protobuf.Any": {
	"properties": {
	"type_url": {
	"type": "string"
	},
	"value": {

brabster / argo-workflowtemplate-schema-2.11.7.yaml

Created November 6, 2020 07:02

Argo WorkflowTemplate Schema

	title: Argo WorkflowTemplate
	required:
	- metadata
	- spec
	type: object

	properties:
	apiVersion:
	type: string
	kind:

brabster / argo-cronworkflow-schema-2.11.7.yaml

Last active November 6, 2020 06:57

Argo CronWorkflow Schema

brabster / argo-workflow-schema-2.11.7.yaml

Created November 6, 2020 06:54

Argo workflow schema

brabster / argo-controller-crash-log.txt

Last active July 30, 2020 07:43


	time="2020-07-28T16:08:04Z" level=info msg="Alloc=9702 TotalAlloc=2322341 Sys=71872 NumGC=739 Goroutines=165"

	time="2020-07-28T16:08:53Z" level=info msg="Processing default/foo-workflow"


	goroutine 139 [running]:

	k8s.io/apimachinery/pkg/util/runtime.logPanic(0x171b000, 0xc0012ea520)

brabster / AccessLog-with-types.scala

Created September 6, 2018 10:25

Scala Types in Scio Pipelines

	type ClientIp = String
	type UserId = String
	type Path = String
	type StatusCode = Int
	case class Entry(clientIp: ClientIp, userId: UserId, timestamp: Instant, path: Path, statusCode: StatusCode)

brabster / AccessLog.scala

Created September 6, 2018 10:22

Scala Types in Scio Pipelines - 1

	object AccessLog {
	case class Entry(clientIp: String, userId: String, timestamp: Instant, path: String, statusCode: Int)

	def parseLine(line: String): Entry = line.split(",") match {
	case Array(clientIp, userId, timestamp, path, statusCode) =>
	Entry(clientIp, userId, new Instant(timestamp), path, statusCode.toInt)
	}
	}