brabster

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

brabster

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

properties:
  apiVersion:
    type: string
  kind:

brabster

title: Argo CronWorkflow
required:
- metadata
- spec
type: object
properties:
  apiVersion:
    type: string
  kind:
    type: string

brabster

title: Argo Workflow
required:
- metadata
- spec
type: object
properties:
  apiVersion:
    type: string
  kind:
    type: string

brabster

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

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

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)
  }
}