payload

type Dataset struct {
	ProjectID string `json:"project_id"`
	DatasetID string `json:"dataset_id"`
	Bucket    string `json:"bucket"`
	Root      string `json:"root"`
}

type DatasetCreateInput struct{}

type DatasetCreateOutput struct {
	Dataset
}

type DatasetDescribeOutput struct {
	Dataset
}

type DatasetListOutput struct {
	Datasets []*Dataset `json:"datasets"`
}

type Error struct {
	//Retry indicates if the client can retry the request as is, this is mostly false on validation/encoding errors and true in other cases
	Retry bool `json:"retry"`

	//Message contains a overall message to the user, it should always be set to provide some feedback
	Message string `json:"message"`

	//Trace is set if the server is running in development mode, if it is empty it can be ignored
	Trace []string `json:"trace,omitempty"`

	//Fields can hold validation messages for individual fields, if empty the cause of the overal error is not due to specific field's input
	Fields map[string]string `json:"fields,omitempty"`
}

type NerdClaims struct {
	*jwt.StandardClaims
	ProjectID string `json:"proj,omitempty"`
}

type SessionCreateOutput struct {
	AWSAccessKeyID     string    `json:"aws_access_key_id"`
	AWSExpiration      time.Time `json:"aws_expiration"`
	AWSSecretAccessKey string    `json:"aws_secret_access_key"`
	AWSSessionToken    string    `json:"aws_session_token"`

	AWSQueueURL      string `json:"aws_queue_url"`
	AWSStorageBucket string `json:"aws_storage_bucket"`
	AWSStorageRoot   string `json:"aws_storage_root"`
}

type Task struct {
	ProjectID     string            `json:"project_id"`
	TaskID        string            `json:"task_id"`
	InputID       string            `json:"input_id"`
	OutputID      string            `json:"output_id,omitempty"`
	WorkerID      string            `json:"worker_id,omitempty"`
	Image         string            `json:"image"`
	Environment   map[string]string `json:"environment,omitempty"`
	CreatedAt     time.Time         `json:"created_at"`
	ActivityToken string            `json:"activity_token,omitempty"`
}

type TaskCreateInput struct {
	Image       string            `json:"image" valid:"min=1,max=64,required"`
	InputID     string            `json:"input_id" valid:"datasetid"`
	Environment map[string]string `json:"environment"`
}

type TaskCreateOutput struct {
	Task
}

type TaskDescribeOutput struct {
	Task
}

type TaskListOutput struct {
	Tasks []*TaskSummary `json:"tasks"`
}

type TaskResult struct {
	ProjectID  string `json:"project_id"`
	TaskID     string `json:"task_id"`
	OutputID   string `json:"output_id"`
	ExitStatus string `json:"exit_status"`
}

type TaskSummary struct {
	ProjectID string    `json:"project_id"`
	TaskID    string    `json:"task_id"`
	InputID   string    `json:"input_id"`
	Image     string    `json:"image"`
	CreatedAt time.Time `json:"created_at"`
}

type Worker struct {
	ProjectID string `json:"project_id"`
	WorkerID  string `json:"worker_id"`
	QueueURL  string `json:"queue_url"`
}

type WorkerCreateInput struct{}

type WorkerCreateOutput struct {
	Worker
}

type WorkerDescribeOutput struct {
	Worker
}

type WorkerListOutput struct {
	Workers []*Worker `json:"workers"`
}