interfaces

type ApplicationConfig struct {
	RoleNameKey           string   `json:"roleNameKey"`
	KubeConfig            string   `json:"kubeconfig"`
	MetricsScope          string   `json:"metricsScope"`
	ProfilerPort          int      `json:"profilerPort"`
	MetadataStoragePrefix []string `json:"metadataStoragePrefix"`
}

type ApplicationConfiguration interface {
	GetDbConfig() DbConfig
	GetTopLevelConfig() *ApplicationConfig
	GetSchedulerConfig() *SchedulerConfig
	GetRemoteDataConfig() *RemoteDataConfig
	GetNotificationsConfig() *NotificationsConfig
	GetDomainsConfig() *DomainsConfig
}

type Auth struct {
	Type      string `json:"type"`
	TokenPath string `json:"tokenPath"`
	CertPath  string `json:"certPath"`
}

type ClusterConfig struct {
	Name           string   `json:"name"`
	Endpoint       string   `json:"endpoint"`
	Auth           Auth     `json:"auth"`
	Enabled        bool     `json:"enabled"`
	Weight         float32  `json:"weight"`
	AllowedDomains []string `json:"allowedDomains"`
}

type ClusterConfiguration interface {
	// Returns clusters defined in runtime configuration files.
	GetClusterConfigs() []ClusterConfig

	// The cluster selection strategy setting
	GetClusterSelectionStrategy() ClusterSelectionStrategy
}

type ClusterResourceConfig struct {
	TemplatePath string `json:"templatePath"`
	// TemplateData maps template keys e.g. my_super_secret_password to a data source
	// which is then substituted in cluster resource templated config files wherever
	// {{ my_super_secret_password }} appears.
	TemplateData    map[string]DataSource `json:"templateData"`
	RefreshInterval config.Duration       `json:"refreshInterval"`
}

type ClusterResourceConfiguration interface {
	GetTemplatePath() string
	GetTemplateData() map[string]DataSource
	GetRefreshInterval() time.Duration
}

type ClusterSelectionStrategy string

type Clusters struct {
	ClusterConfigs   []ClusterConfig          `json:"clusterConfigs"`
	ClusterSelection ClusterSelectionStrategy `json:"clusterSelectionStrategy"`
}

type Configuration interface {
	ApplicationConfiguration() ApplicationConfiguration
	QueueConfiguration() QueueConfiguration
	ClusterConfiguration() ClusterConfiguration
	TaskResourceConfiguration() TaskResourceConfiguration
	WhitelistConfiguration() WhitelistConfiguration
	RegistrationValidationConfiguration() RegistrationValidationConfiguration
	ClusterResourceConfiguration() ClusterResourceConfiguration
}

type DataSource struct {
	Value     string              `json:"value"`
	ValueFrom DataSourceValueFrom `json:"valueFrom"`
}

type DataSourceValueFrom struct {
	EnvVar   string `json:"env"`
	FilePath string `json:"filePath"`
}

type DbConfig struct {
	Host         string `json:"host"`
	Port         int    `json:"port"`
	DbName       string `json:"dbname"`
	User         string `json:"username"`
	Password     string `json:"password"`
	ExtraOptions string `json:"options"`
}

type DbConfigSection struct {
	Host   string `json:"host"`
	Port   int    `json:"port"`
	DbName string `json:"dbname"`
	User   string `json:"username"`
	// Either Password or PasswordPath must be set.
	Password     string `json:"password"`
	PasswordPath string `json:"passwordPath"`
	// See http://gorm.io/docs/connecting_to_the_database.html for available options passed, in addition to the above.
	ExtraOptions string `json:"options"`
}

type Domain struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

type DomainsConfig = []Domain

type EventSchedulerConfig struct {
	Scheme       string `json:"scheme"`
	Region       string `json:"region"`
	ScheduleRole string `json:"scheduleRole"`
	TargetName   string `json:"targetName"`
}

type ExecutionQueue struct {
	Primary    string
	Dynamic    string
	Attributes []string
}

type ExecutionQueues []ExecutionQueue

type NotificationsConfig struct {
	Type                         string                       `json:"type"`
	Region                       string                       `json:"region"`
	NotificationsPublisherConfig NotificationsPublisherConfig `json:"publisher"`
	NotificationsProcessorConfig NotificationsProcessorConfig `json:"processor"`
	NotificationsEmailerConfig   NotificationsEmailerConfig   `json:"emailer"`
}

type NotificationsEmailerConfig struct {
	Subject string `json:"subject"`
	Sender  string `json:"sender"`
	Body    string `json:"body"`
}

type NotificationsProcessorConfig struct {
	QueueName string `json:"queueName"`
	AccountID string `json:"accountId"`
}

type NotificationsPublisherConfig struct {
	TopicName string `json:"topicName"`
}

type QueueConfig struct {
	ExecutionQueues ExecutionQueues `json:"executionQueues"`
	WorkflowConfigs WorkflowConfigs `json:"workflowConfigs"`
}

type QueueConfiguration interface {
	// Returns executions queues defined in runtime configuration files.
	GetExecutionQueues() []ExecutionQueue
	// Returns workflow configurations defined in runtime configuration files.
	GetWorkflowConfigs() []WorkflowConfig
}

type RegistrationValidationConfig struct {
	MaxWorkflowNodes     int    `json:"maxWorkflowNodes"`
	MaxLabelEntries      int    `json:"maxLabelEntries"`
	MaxAnnotationEntries int    `json:"maxAnnotationEntries"`
	WorkflowSizeLimit    string `json:"workflowSizeLimit"`
}

type RegistrationValidationConfiguration interface {
	GetWorkflowNodeLimit() int
	GetMaxLabelEntries() int
	GetMaxAnnotationEntries() int
	GetWorkflowSizeLimit() string
}

type RemoteDataConfig struct {
	Scheme    string    `json:"scheme"`
	Region    string    `json:"region"`
	SignedURL SignedURL `json:"signedUrls"`
}

type SchedulerConfig struct {
	EventSchedulerConfig   EventSchedulerConfig   `json:"eventScheduler"`
	WorkflowExecutorConfig WorkflowExecutorConfig `json:"workflowExecutor"`
}

type SignedURL struct {
	DurationMinutes int `json:"durationMinutes"`
}

type TaskResourceConfiguration interface {
	GetDefaults() TaskResourceSet
	GetLimits() TaskResourceSet
}

type TaskResourceSet struct {
	CPU     string `json:"cpu"`
	GPU     string `json:"gpu"`
	Memory  string `json:"memory"`
	Storage string `json:"storage"`
}

type TaskTypeWhitelist = map[string][]WhitelistScope

type WhitelistConfiguration interface {
	// Returns whitelisted task types defined in runtime configuration files.
	GetTaskTypeWhitelist() TaskTypeWhitelist
}

type WhitelistScope struct {
	Project string `json:"project"`
	Domain  string `json:"domain"`
}

type WorkflowConfig struct {
	Project      string   `json:"project"`
	Domain       string   `json:"domain"`
	WorkflowName string   `json:"workflowName"`
	Tags         []string `json:"tags"`
}

type WorkflowConfigs []WorkflowConfig

type WorkflowExecutorConfig struct {
	Scheme            string `json:"scheme"`
	Region            string `json:"region"`
	ScheduleQueueName string `json:"scheduleQueueName"`
	AccountID         string `json:"accountId"`
}