svc

type CreateDatasetInput struct {
	Name string `validate:"printascii"`
	Size uint64

	StoreOptions    transferstore.StoreOptions       `validate:"required"`
	ArchiverOptions transferarchiver.ArchiverOptions `validate:"required"`
}

type CreateDatasetOutput struct {
	Name string
}

type DI interface {
	Kube() kubernetes.Interface
	Crd() crd.Interface
	Validator() Validator
	Logger() Logger
	Namespace() string
}

type DatasetDetails struct {
	CreatedAt  time.Time
	Size       uint64
	InputFor   []string
	OutputFrom []string
}

type DeleteDatasetInput struct {
	Name string `validate:"min=1,printascii"`
}

type DeleteDatasetOutput struct{}

type DeleteJobInput struct {
	Name string `validate:"min=1,printascii"`
}

type DeleteJobOutput struct{}

type FetchJobLogsInput struct {
	Tail int64  `validate:"min=0"`
	Name string `validate:"min=1,printascii"`
}

type FetchJobLogsOutput struct {
	Data []byte
}

type GetDatasetInput struct {
	Name string `validate:"printascii"`
}

type GetDatasetOutput struct {
	Name string
	Size uint64

	InputFor   []string
	OutputFrom []string

	StoreOptions    transferstore.StoreOptions
	ArchiverOptions transferarchiver.ArchiverOptions
}

type JobDetails struct {
	SeenAt               time.Time
	Phase                JobDetailsPhase
	Scheduled            bool   //indicate if the pod was scheduled
	Parallelism          int32  //job width, if 0 this means it was stopped
	WaitingReason        string //why the job -> pod -> container is waiting
	WaitingMessage       string //explains why we're waiting
	TerminatedReason     string //termination of main container
	TerminatedMessage    string //explains why its terminated
	UnschedulableReason  string //when scheduling condition is false
	UnschedulableMessage string
}

type JobDetailsPhase string

type JobVolume struct {
	MountPath     string `validate:"is-abs-path"`
	InputDataset  string
	OutputDataset string
}

type JobVolumeType string

type Kube struct {
	// contains filtered or unexported fields
}

type ListDatasetItem struct {
	Name    string
	Details DatasetDetails
}

type ListDatasetsInput struct{}

type ListDatasetsOutput struct {
	Items []*ListDatasetItem
}

type ListJobItem struct {
	Name        string
	Image       string
	Input       []string
	Output      []string
	Memory      string
	VCPU        string
	CreatedAt   time.Time
	DeletedAt   time.Time
	ActiveAt    time.Time
	CompletedAt time.Time
	FailedAt    time.Time

	Details JobDetails
}

type ListJobsInput struct{}

type ListJobsOutput struct {
	Items []*ListJobItem
}

type Logger interface {
	Debugf(format string, args ...interface{})
}

type RunJobInput struct {
	Image        string `validate:"min=1"`
	Name         string `validate:"printascii"`
	Env          map[string]string
	BackoffLimit *int32
	Args         []string
	Volumes      []JobVolume
	Memory       string
	VCPU         string
}

type RunJobOutput struct {
	Name string
}

type UpdateDatasetInput struct {
	Name       string `validate:"printascii"`
	NewName    string `validate:"printascii"`
	Size       *uint64
	InputFor   string
	OutputFrom string
}

type UpdateDatasetOutput struct {
	Name string
}

type Validator interface {
	StructCtx(ctx context.Context, s interface{}) (err error)
	Struct(s interface{}) (err error)
}