runtime

Documentation

Overview

Interface for configurable values used in entity registration and validation

Index

• Constants
• func NewApplicationConfigurationProvider() interfaces.ApplicationConfiguration
• func NewClusterConfigurationProvider() interfaces.ClusterConfiguration
• func NewClusterPoolAssignmentConfigurationProvider() interfaces.ClusterPoolAssignmentConfiguration
• func NewClusterResourceConfigurationProvider() interfaces.ClusterResourceConfiguration
• func NewConfigurationProvider() interfaces.Configuration
• func NewNamespaceMappingConfigurationProvider() interfaces.NamespaceMappingConfiguration
• func NewQualityOfServiceConfigProvider() interfaces.QualityOfServiceConfiguration
• func NewQueueConfigurationProvider() interfaces.QueueConfiguration
• func NewRegistrationValidationProvider() interfaces.RegistrationValidationConfiguration
• func NewTaskResourceProvider() interfaces.TaskResourceConfiguration
• func NewWhitelistConfigurationProvider() interfaces.WhitelistConfiguration
• type ApplicationConfigurationProvider
  • func (p *ApplicationConfigurationProvider) GetCloudEventsConfig() *interfaces.CloudEventsConfig
  • func (p *ApplicationConfigurationProvider) GetDbConfig() *database.DbConfig
  • func (p *ApplicationConfigurationProvider) GetDomainsConfig() *interfaces.DomainsConfig
  • func (p *ApplicationConfigurationProvider) GetExternalEventsConfig() *interfaces.ExternalEventsConfig
  • 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) GetDefaultExecutionLabel() string
  • func (p *ClusterConfigurationProvider) GetLabelClusterMap() map[string][]interfaces.ClusterEntity
• type ClusterPoolAssignmentConfigurationProvider
  • func (p *ClusterPoolAssignmentConfigurationProvider) GetClusterPoolAssignments() interfaces.ClusterPoolAssignments
• type ClusterResourceConfigurationProvider
  • func (p *ClusterResourceConfigurationProvider) GetCustomTemplateData() map[interfaces.DomainName]interfaces.TemplateData
  • func (p *ClusterResourceConfigurationProvider) GetRefreshInterval() time.Duration
  • func (p *ClusterResourceConfigurationProvider) GetTemplateData() interfaces.TemplateData
  • func (p *ClusterResourceConfigurationProvider) GetTemplatePath() string
  • func (p *ClusterResourceConfigurationProvider) IsStandaloneDeployment() bool
• type ConfigurationProvider
  • func (p *ConfigurationProvider) ApplicationConfiguration() interfaces.ApplicationConfiguration
  • func (p *ConfigurationProvider) ClusterConfiguration() interfaces.ClusterConfiguration
  • func (p *ConfigurationProvider) ClusterPoolAssignmentConfiguration() interfaces.ClusterPoolAssignmentConfiguration
  • func (p *ConfigurationProvider) ClusterResourceConfiguration() interfaces.ClusterResourceConfiguration
  • func (p *ConfigurationProvider) NamespaceMappingConfiguration() interfaces.NamespaceMappingConfiguration
  • func (p *ConfigurationProvider) QualityOfServiceConfiguration() interfaces.QualityOfServiceConfiguration
  • 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) GetNamespaceTemplate() string
• type QualityOfServiceConfigProvider
  • func (p *QualityOfServiceConfigProvider) GetDefaultTiers() map[interfaces.DomainName]core.QualityOfService_Tier
  • func (p *QualityOfServiceConfigProvider) GetTierExecutionValues() map[core.QualityOfService_Tier]*core.QualityOfServiceSpec
• 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

Constants

const KB = 1024

const MB = KB * KB

Functions

func NewApplicationConfigurationProvider

func NewApplicationConfigurationProvider() interfaces.ApplicationConfiguration

func NewClusterConfigurationProvider

func NewClusterConfigurationProvider() interfaces.ClusterConfiguration

func NewClusterPoolAssignmentConfigurationProvider

func NewClusterPoolAssignmentConfigurationProvider() interfaces.ClusterPoolAssignmentConfiguration

func NewClusterResourceConfigurationProvider

func NewClusterResourceConfigurationProvider() interfaces.ClusterResourceConfiguration

func NewConfigurationProvider

func NewConfigurationProvider() interfaces.Configuration

func NewNamespaceMappingConfigurationProvider

func NewNamespaceMappingConfigurationProvider() interfaces.NamespaceMappingConfiguration

func NewQualityOfServiceConfigProvider

func NewQualityOfServiceConfigProvider() interfaces.QualityOfServiceConfiguration

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) GetCloudEventsConfig

func (p *ApplicationConfigurationProvider) GetCloudEventsConfig() *interfaces.CloudEventsConfig

func (*ApplicationConfigurationProvider) GetDbConfig

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

func (*ApplicationConfigurationProvider) GetDomainsConfig

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

func (*ApplicationConfigurationProvider) GetExternalEventsConfig

func (p *ApplicationConfigurationProvider) GetExternalEventsConfig() *interfaces.ExternalEventsConfig

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) GetDefaultExecutionLabel

func (p *ClusterConfigurationProvider) GetDefaultExecutionLabel() string

func (*ClusterConfigurationProvider) GetLabelClusterMap

func (p *ClusterConfigurationProvider) GetLabelClusterMap() map[string][]interfaces.ClusterEntity

type ClusterPoolAssignmentConfigurationProvider

type ClusterPoolAssignmentConfigurationProvider struct{}

Implementation of an interfaces.ClusterPoolAssignmentConfiguration

func (*ClusterPoolAssignmentConfigurationProvider) GetClusterPoolAssignments

func (p *ClusterPoolAssignmentConfigurationProvider) GetClusterPoolAssignments() interfaces.ClusterPoolAssignments

type ClusterResourceConfigurationProvider

type ClusterResourceConfigurationProvider struct{}

Implementation of an interfaces.ClusterResourceConfiguration

func (*ClusterResourceConfigurationProvider) GetCustomTemplateData

func (p *ClusterResourceConfigurationProvider) GetCustomTemplateData() map[interfaces.DomainName]interfaces.TemplateData

func (*ClusterResourceConfigurationProvider) GetRefreshInterval

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

func (*ClusterResourceConfigurationProvider) GetTemplateData

func (p *ClusterResourceConfigurationProvider) GetTemplateData() interfaces.TemplateData

func (*ClusterResourceConfigurationProvider) GetTemplatePath

func (p *ClusterResourceConfigurationProvider) GetTemplatePath() string

func (*ClusterResourceConfigurationProvider) IsStandaloneDeployment

func (p *ClusterResourceConfigurationProvider) IsStandaloneDeployment() bool

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) ClusterPoolAssignmentConfiguration

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

func (*ConfigurationProvider) ClusterResourceConfiguration

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

func (*ConfigurationProvider) NamespaceMappingConfiguration

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

func (*ConfigurationProvider) QualityOfServiceConfiguration

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

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) GetNamespaceTemplate

func (p *NamespaceMappingConfigurationProvider) GetNamespaceTemplate() string

type QualityOfServiceConfigProvider

type QualityOfServiceConfigProvider struct {
}

Implementation of an interfaces.QualityOfServiceConfiguration

func (*QualityOfServiceConfigProvider) GetDefaultTiers

func (p *QualityOfServiceConfigProvider) GetDefaultTiers() map[interfaces.DomainName]core.QualityOfService_Tier

func (*QualityOfServiceConfigProvider) GetTierExecutionValues

func (p *QualityOfServiceConfigProvider) GetTierExecutionValues() map[core.QualityOfService_Tier]*core.QualityOfServiceSpec

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