runtime

Documentation

Overview

Interface for configurable values used in entity registration and validation

Index

• func NewApplicationConfigurationProvider() interfaces.ApplicationConfiguration
• func NewClusterConfigurationProvider() interfaces.ClusterConfiguration
• func NewClusterResourceConfigurationProvider() interfaces.ClusterResourceConfiguration
• func NewConfigurationProvider() interfaces.Configuration
• func NewNamespaceMappingConfigurationProvider() interfaces.NamespaceMappingConfiguration
• func NewQueueConfigurationProvider() interfaces.QueueConfiguration
• func NewRegistrationValidationProvider() interfaces.RegistrationValidationConfiguration
• func NewTaskResourceProvider() interfaces.TaskResourceConfiguration
• func NewWhitelistConfigurationProvider() interfaces.WhitelistConfiguration
• type ApplicationConfigurationProvider
  • func (p *ApplicationConfigurationProvider) GetDbConfig() interfaces.DbConfig
  • func (p *ApplicationConfigurationProvider) GetDomainsConfig() *interfaces.DomainsConfig
  • func (p *ApplicationConfigurationProvider) GetNotificationsConfig() *interfaces.NotificationsConfig
  • func (p *ApplicationConfigurationProvider) GetRemoteDataConfig() *interfaces.RemoteDataConfig
  • func (p *ApplicationConfigurationProvider) GetSchedulerConfig() *interfaces.SchedulerConfig
  • func (p *ApplicationConfigurationProvider) GetTopLevelConfig() *interfaces.ApplicationConfig
• type ClusterConfigurationProvider
  • func (p *ClusterConfigurationProvider) GetClusterConfigs() []interfaces.ClusterConfig
  • func (p *ClusterConfigurationProvider) GetClusterSelectionStrategy() interfaces.ClusterSelectionStrategy
• type ClusterResourceConfigurationProvider
  • func (p *ClusterResourceConfigurationProvider) GetRefreshInterval() time.Duration
  • func (p *ClusterResourceConfigurationProvider) GetTemplateData() map[string]interfaces.DataSource
  • func (p *ClusterResourceConfigurationProvider) GetTemplatePath() string
• type ConfigurationProvider
  • func (p *ConfigurationProvider) ApplicationConfiguration() interfaces.ApplicationConfiguration
  • func (p *ConfigurationProvider) ClusterConfiguration() interfaces.ClusterConfiguration
  • func (p *ConfigurationProvider) ClusterResourceConfiguration() interfaces.ClusterResourceConfiguration
  • func (p *ConfigurationProvider) NamespaceMappingConfiguration() interfaces.NamespaceMappingConfiguration
  • func (p *ConfigurationProvider) QueueConfiguration() interfaces.QueueConfiguration
  • func (p *ConfigurationProvider) RegistrationValidationConfiguration() interfaces.RegistrationValidationConfiguration
  • func (p *ConfigurationProvider) TaskResourceConfiguration() interfaces.TaskResourceConfiguration
  • func (p *ConfigurationProvider) WhitelistConfiguration() interfaces.WhitelistConfiguration
• type NamespaceMappingConfigurationProvider
  • func (p *NamespaceMappingConfigurationProvider) GetNamespaceMappingConfig() common.NamespaceMapping
• type QueueConfigurationProvider
  • func (p *QueueConfigurationProvider) GetExecutionQueues() []interfaces.ExecutionQueue
  • func (p *QueueConfigurationProvider) GetWorkflowConfigs() []interfaces.WorkflowConfig
• type RegistrationValidationProvider
  • func (p *RegistrationValidationProvider) GetMaxAnnotationEntries() int
  • func (p *RegistrationValidationProvider) GetMaxLabelEntries() int
  • func (p *RegistrationValidationProvider) GetWorkflowNodeLimit() int
  • func (p *RegistrationValidationProvider) GetWorkflowSizeLimit() string
• type TaskResourceProvider
  • func (p *TaskResourceProvider) GetDefaults() interfaces.TaskResourceSet
  • func (p *TaskResourceProvider) GetLimits() interfaces.TaskResourceSet
• type TaskResourceSpec
• type WhitelistConfigurationProvider
  • func (p *WhitelistConfigurationProvider) GetTaskTypeWhitelist() interfaces.TaskTypeWhitelist

Functions

func NewApplicationConfigurationProvider

func NewApplicationConfigurationProvider() interfaces.ApplicationConfiguration

func NewClusterConfigurationProvider

func NewClusterConfigurationProvider() interfaces.ClusterConfiguration

func NewClusterResourceConfigurationProvider

func NewClusterResourceConfigurationProvider() interfaces.ClusterResourceConfiguration

func NewConfigurationProvider

func NewConfigurationProvider() interfaces.Configuration

func NewNamespaceMappingConfigurationProvider

func NewNamespaceMappingConfigurationProvider() interfaces.NamespaceMappingConfiguration

func NewQueueConfigurationProvider

func NewQueueConfigurationProvider() interfaces.QueueConfiguration

func NewRegistrationValidationProvider

func NewRegistrationValidationProvider() interfaces.RegistrationValidationConfiguration

func NewTaskResourceProvider

func NewTaskResourceProvider() interfaces.TaskResourceConfiguration

func NewWhitelistConfigurationProvider

func NewWhitelistConfigurationProvider() interfaces.WhitelistConfiguration

Types

type ApplicationConfigurationProvider

type ApplicationConfigurationProvider struct{}

Implementation of an interfaces.ApplicationConfiguration

func (*ApplicationConfigurationProvider) GetDbConfig

func (p *ApplicationConfigurationProvider) GetDbConfig() interfaces.DbConfig

func (*ApplicationConfigurationProvider) GetDomainsConfig

func (p *ApplicationConfigurationProvider) GetDomainsConfig() *interfaces.DomainsConfig

func (*ApplicationConfigurationProvider) GetNotificationsConfig

func (p *ApplicationConfigurationProvider) GetNotificationsConfig() *interfaces.NotificationsConfig

func (*ApplicationConfigurationProvider) GetRemoteDataConfig

func (p *ApplicationConfigurationProvider) GetRemoteDataConfig() *interfaces.RemoteDataConfig

func (*ApplicationConfigurationProvider) GetSchedulerConfig

func (p *ApplicationConfigurationProvider) GetSchedulerConfig() *interfaces.SchedulerConfig

func (*ApplicationConfigurationProvider) GetTopLevelConfig

func (p *ApplicationConfigurationProvider) GetTopLevelConfig() *interfaces.ApplicationConfig

type ClusterConfigurationProvider

type ClusterConfigurationProvider struct{}

Implementation of an interfaces.ClusterConfiguration

func (*ClusterConfigurationProvider) GetClusterConfigs

func (p *ClusterConfigurationProvider) GetClusterConfigs() []interfaces.ClusterConfig

func (*ClusterConfigurationProvider) GetClusterSelectionStrategy

func (p *ClusterConfigurationProvider) GetClusterSelectionStrategy() interfaces.ClusterSelectionStrategy

type ClusterResourceConfigurationProvider

type ClusterResourceConfigurationProvider struct{}

Implementation of an interfaces.ClusterResourceConfiguration

func (*ClusterResourceConfigurationProvider) GetRefreshInterval

func (p *ClusterResourceConfigurationProvider) GetRefreshInterval() time.Duration

func (*ClusterResourceConfigurationProvider) GetTemplateData

func (p *ClusterResourceConfigurationProvider) GetTemplateData() map[string]interfaces.DataSource

func (*ClusterResourceConfigurationProvider) GetTemplatePath

func (p *ClusterResourceConfigurationProvider) GetTemplatePath() string

type ConfigurationProvider

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

Implementation of an interfaces.Configuration

func (*ConfigurationProvider) ApplicationConfiguration

func (p *ConfigurationProvider) ApplicationConfiguration() interfaces.ApplicationConfiguration

func (*ConfigurationProvider) ClusterConfiguration

func (p *ConfigurationProvider) ClusterConfiguration() interfaces.ClusterConfiguration

func (*ConfigurationProvider) ClusterResourceConfiguration

func (p *ConfigurationProvider) ClusterResourceConfiguration() interfaces.ClusterResourceConfiguration

func (*ConfigurationProvider) NamespaceMappingConfiguration

func (p *ConfigurationProvider) NamespaceMappingConfiguration() interfaces.NamespaceMappingConfiguration

func (*ConfigurationProvider) QueueConfiguration

func (p *ConfigurationProvider) QueueConfiguration() interfaces.QueueConfiguration

func (*ConfigurationProvider) RegistrationValidationConfiguration

func (p *ConfigurationProvider) RegistrationValidationConfiguration() interfaces.RegistrationValidationConfiguration

func (*ConfigurationProvider) TaskResourceConfiguration

func (p *ConfigurationProvider) TaskResourceConfiguration() interfaces.TaskResourceConfiguration

func (*ConfigurationProvider) WhitelistConfiguration

func (p *ConfigurationProvider) WhitelistConfiguration() interfaces.WhitelistConfiguration

type NamespaceMappingConfigurationProvider

type NamespaceMappingConfigurationProvider struct{}

func (*NamespaceMappingConfigurationProvider) GetNamespaceMappingConfig

func (p *NamespaceMappingConfigurationProvider) GetNamespaceMappingConfig() common.NamespaceMapping

type QueueConfigurationProvider

type QueueConfigurationProvider struct{}

Implementation of an interfaces.QueueConfiguration

func (*QueueConfigurationProvider) GetExecutionQueues

func (p *QueueConfigurationProvider) GetExecutionQueues() []interfaces.ExecutionQueue

func (*QueueConfigurationProvider) GetWorkflowConfigs

func (p *QueueConfigurationProvider) GetWorkflowConfigs() []interfaces.WorkflowConfig

type RegistrationValidationProvider

type RegistrationValidationProvider struct{}

Implementation of an interfaces.TaskResourceConfiguration

func (*RegistrationValidationProvider) GetMaxAnnotationEntries

func (p *RegistrationValidationProvider) GetMaxAnnotationEntries() int

func (*RegistrationValidationProvider) GetMaxLabelEntries

func (p *RegistrationValidationProvider) GetMaxLabelEntries() int

func (*RegistrationValidationProvider) GetWorkflowNodeLimit

func (p *RegistrationValidationProvider) GetWorkflowNodeLimit() int

func (*RegistrationValidationProvider) GetWorkflowSizeLimit

func (p *RegistrationValidationProvider) GetWorkflowSizeLimit() string

type TaskResourceProvider

type TaskResourceProvider struct{}

Implementation of an interfaces.TaskResourceConfiguration

func (*TaskResourceProvider) GetDefaults

func (p *TaskResourceProvider) GetDefaults() interfaces.TaskResourceSet

func (*TaskResourceProvider) GetLimits

func (p *TaskResourceProvider) GetLimits() interfaces.TaskResourceSet

type TaskResourceSpec

type TaskResourceSpec struct {
	Defaults interfaces.TaskResourceSet `json:"defaults"`
	Limits   interfaces.TaskResourceSet `json:"limits"`
}

type WhitelistConfigurationProvider

type WhitelistConfigurationProvider struct{}

Implementation of an interfaces.QueueConfiguration

func (*WhitelistConfigurationProvider) GetTaskTypeWhitelist

func (p *WhitelistConfigurationProvider) GetTaskTypeWhitelist() interfaces.TaskTypeWhitelist