Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + func MustRegisterSubSection(subSectionKey string, section config.Config) config.Section + type CompositeQueueConfig struct + BatchSize int + BatchingInterval config.Duration + Queue WorkqueueConfig + Sub WorkqueueConfig + Type CompositeQueueType + type CompositeQueueType = string + const CompositeQueueBatch + const CompositeQueueSimple + type Config struct + ArrayNodeEventVersion int + ClusterID string + CreateKozmoWorkflowCRD bool + DefaultRawOutputPrefix string + DownstreamEval config.Duration + EnableAdminLauncher bool + EnableGrpcLatencyMetrics bool + EventConfig EventConfig + ExcludeDomainLabel []string + ExcludeProjectLabel []string + ExcludeShardKeyLabel []string + GCInterval config.Duration + IncludeDomainLabel []string + IncludeProjectLabel []string + IncludeShardKeyLabel []string + KubeConfig KubeClientConfig + KubeConfigPath string + LeaderElection LeaderElectionConfig + LimitNamespace string + MasterURL string + MaxDatasetSizeBytes int64 + MaxStreakLength int + MaxTTLInHours int + MaxWorkflowRetries int + MetadataPrefix string + MetricKeys []string + MetricsPrefix string + NodeConfig NodeConfig + NodeExecutionWorkerCount int + ProfilerPort config.Port + PublishK8sEvents bool + Queue CompositeQueueConfig + Workers int + WorkflowReEval config.Duration + func GetConfig() *Config + func (cfg Config) GetPFlagSet(prefix string) *pflag.FlagSet + type DefaultDeadlines struct + DefaultNodeActiveDeadline config.Duration + DefaultNodeExecutionDeadline config.Duration + DefaultWorkflowActiveDeadline config.Duration + type EventConfig struct + FallbackToOutputReference bool + RawOutputPolicy RawOutputPolicy + type KubeClientConfig struct + Burst int + QPS float32 + Timeout config.Duration + type LeaderElectionConfig struct + Enabled bool + LeaseDuration config.Duration + LockConfigMap types.NamespacedName + RenewDeadline config.Duration + RetryPeriod config.Duration + type NodeConfig struct + DefaultDeadlines DefaultDeadlines + DefaultMaxAttempts int32 + EnableCRDebugMetadata bool + IgnoreRetryCause bool + InterruptibleFailureThreshold int32 + MaxNodeRetriesOnSystemFailures int64 + type RawOutputPolicy = string + const RawOutputPolicyInline + const RawOutputPolicyReference + type WorkqueueConfig struct + BaseDelay config.Duration + Capacity int + MaxDelay config.Duration + Rate int64 + Type WorkqueueType + type WorkqueueType = string + const WorkqueueTypeBucketRateLimiter + const WorkqueueTypeDefault + const WorkqueueTypeExponentialFailureRateLimiter + const WorkqueueTypeMaxOfRateLimiter
Go to main page