code.oscarkilo.com/klex-git/api/worker.go

..
api.go
datasets.go
f.go
funcs.go
messages.go
pipelines.go
worker.go
package api

type WorkerRequest struct {
  FNamePrefix string `json:"f_name_prefix"`
  BatchSize int `json:"batch_size"`  // can be 0
  MaxWaitMillis int `json:"max_wait_millis"`  // set to 0 to use default

  // If delivering previously completed work, fill these out.
  WorkId string `json:"work_id"`
  Out string `json:"out"`
  Err string `json:"err"`
}

type Work struct {
  WorkId string `json:"work_id"`
  Fname string `json:"fname"`
  In string `json:"in"`
}

type WorkerResponse struct {
  Works []Work `json:"work"`
}