file_task.go

type FileTaskReader struct {
  Path string
  task *tes.Task
}

func (f *FileTaskReader) Task() (*tes.Task, error) {
  if f.task != nil {
    return f.task, nil
  }

  fh, err := os.Open(f.Path)
  if err != nil {
    return nil, err
  }

  f.task = &tes.Task{}
  err = jsonpb.Unmarshal(fh, f.task)
  return f.task, err
}

func (f *FileTaskReader) State() (tes.State, error) {
  return tes.State_UNKNOWN, nil
}