Versions in this module Expand all Collapse all v3 v3.2.5 Oct 26, 2021 v3.2.4 Oct 26, 2021 v3.2.3 Oct 26, 2021 Changes in this version + var EmptyConfigFunc = func() interface{} + type Config struct + ArtifactRepository wfv1.ArtifactRepository + ContainerRuntimeExecutor string + ContainerRuntimeExecutors ContainerRuntimeExecutors + DockerSockPath string + Executor *apiv1.Container + ExecutorImage string + ExecutorImagePullPolicy string + ExecutorResources *apiv1.ResourceRequirements + Images map[string]Image + InitialDelay metav1.Duration + InstanceID string + KubeConfig *KubeConfig + KubeletInsecure bool + KubeletPort int + Links []*wfv1.Link + MainContainer *apiv1.Container + MetricsConfig MetricsConfig + Namespace string + NamespaceParallelism int + NodeEvents NodeEvents + Parallelism int + Persistence *PersistConfig + PodGCDeleteDelayDuration *metav1.Duration + PodGCGracePeriodSeconds *int64 + PodSpecLogStrategy PodSpecLogStrategy + ResourceRateLimit *ResourceRateLimit + TelemetryConfig MetricsConfig + WorkflowDefaults *wfv1.Workflow + WorkflowRestrictions *WorkflowRestrictions + func (c Config) GetContainerRuntimeExecutor(labels labels.Labels) (string, error) + func (c Config) GetPodGCDeleteDelayDuration() time.Duration + func (c Config) GetResourceRateLimit() ResourceRateLimit + type ConnectionPool struct + ConnMaxLifetime TTL + MaxIdleConns int + MaxOpenConns int + type ContainerRuntimeExecutor struct + Name string + Selector metav1.LabelSelector + func (e ContainerRuntimeExecutor) Matches(labels labels.Labels) (bool, error) + type ContainerRuntimeExecutors []ContainerRuntimeExecutor + func (e ContainerRuntimeExecutors) Select(labels labels.Labels) (string, error) + type Controller interface + Get func(context.Context) (interface{}, error) + Run func(stopCh <-chan struct{}, onChange func(config interface{}) error) + func NewController(namespace, name string, kubeclientset kubernetes.Interface, ...) Controller + type DatabaseConfig struct + Database string + Host string + PasswordSecret apiv1.SecretKeySelector + Port int + TableName string + UsernameSecret apiv1.SecretKeySelector + func (c DatabaseConfig) GetHostname() string + type Image struct + Args []string + Command []string + type KubeConfig struct + MountPath string + SecretKey string + SecretName string + VolumeName string + type MetricsConfig struct + DisableLegacy bool + Enabled *bool + IgnoreErrors bool + MetricsTTL TTL + Path string + Port int + type MySQLConfig struct + Options map[string]string + type NodeEvents struct + Enabled *bool + SendAsPod bool + func (e NodeEvents) IsEnabled() bool + type PersistConfig struct + Archive bool + ArchiveLabelSelector *metav1.LabelSelector + ArchiveTTL TTL + ClusterName string + ConnectionPool *ConnectionPool + MySQL *MySQLConfig + NodeStatusOffload bool + PostgreSQL *PostgreSQLConfig + SkipMigration bool + func (c PersistConfig) GetArchiveLabelSelector() (labels.Selector, error) + func (c PersistConfig) GetClusterName() string + type PodSpecLogStrategy struct + AllPods bool + FailedPod bool + type PostgreSQLConfig struct + SSL bool + SSLMode string + type ResourceRateLimit struct + Burst int + Limit float64 + type TTL time.Duration + func (l *TTL) UnmarshalJSON(b []byte) error + func (l TTL) MarshalJSON() ([]byte, error) + type TemplateReferencing string + const TemplateReferencingSecure + const TemplateReferencingStrict + type WorkflowRestrictions struct + TemplateReferencing TemplateReferencing + func (req *WorkflowRestrictions) MustNotChangeSpec() bool + func (req *WorkflowRestrictions) MustUseReference() bool