svc

type AddNerdDependenciesInput struct {
	Dependencies []string
}

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 CreateSecretInput struct {
	Image    string `validate:"printascii"`
	Registry string `validate:"required"`
	Project  string
	Tag      string
	Username string `validate:"required"`
	Password string `validate:"required"`
}

type CreateSecretOutput struct {
	Name string
}

type DI interface {
	Kube() kubernetes.Interface
	Crd() crd.Interface
	APIExt() apiext.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 DeleteSecretInput struct {
	Name string `validate:"min=1,printascii"`
}

type DeleteSecretOutput 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 GetSecretInput struct {
	Name string `validate:"printascii"`
}

type GetSecretOutput struct {
	Name      string
	Size      int
	Image     string
	CreatedAt time.Time
	Type      string
}

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
	TerminatedExitCode   int32  //exit code it was terminated with
	UnschedulableReason  string //when scheduling condition is false
	UnschedulableMessage string
	FailedCreateEvents   []JobEvent
}

type JobDetailsPhase string

type JobEvent struct {
	Message 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      int64
	VCPU        int64
	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 ListQuotaItem struct {
	RequestCPU    int64
	LimitCPU      int64
	LimitMemory   int64
	RequestMemory int64

	UseRequestCPU    int64
	UseLimitCPU      int64
	UseLimitMemory   int64
	UseRequestMemory int64

	Labels map[string]string
}

type ListQuotasInput struct{}

type ListQuotasOutput struct {
	Items []*ListQuotaItem
}

type ListSecretItem struct {
	Name    string
	Details SecretDetails
}

type ListSecretsInput struct {
	Labels []string
}

type ListSecretsOutput struct {
	Items []*ListSecretItem
}

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
	Secret       string
}

type RunJobOutput struct {
	Name string
}

type SecretDetails struct {
	CreatedAt time.Time
	Size      int
	Type      string
	Image     string
}

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

type UpdateDatasetOutput struct {
	Name string
}

type UpdateSecretInput struct {
	Name     string `validate:"printascii"`
	Username string
	Password string
}

type UpdateSecretOutput struct {
	Name string
}

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