config

package
v2.0.13 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 17, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AppsConfig added in v2.0.12

type AppsConfig struct {
	// PublicURLPattern is a Go template for generating public ingress URLs.
	// Available variables: {{.Name}}, {{.Project}}, {{.Domain}}
	// Example: "https://{{.Name}}-{{.Project}}.apps.flyte.example.com"
	PublicURLPattern string `json:"publicUrlPattern" pflag:",URL pattern for app ingress"`

	// InternalAppServiceURL is the base URL of the InternalAppService (actions data plane).
	// In unified mode this is overridden by sc.BaseURL.
	InternalAppServiceURL string `json:"internalAppServiceUrl" pflag:",URL of the internal app service"`
}

AppsConfig holds configuration for the App service in the runs (control plane).

type Config

type Config struct {
	// HTTP server configuration
	Server ServerConfig `json:"server"`

	// Database configuration
	Database database.DbConfig `json:"database"`

	// Watch/streaming settings
	WatchBufferSize int `json:"watchBufferSize" pflag:",Buffer size for watch streams"`

	// Actions service URL for enqueuing actions
	ActionsServiceURL string `json:"actionsServiceUrl" pflag:",URL of the actions service"`

	// StoragePrefix is the base URI for storing run data (inputs, outputs)
	// e.g. "s3://my-bucket" or "gs://my-bucket" or "file:///tmp/flyte/data"
	StoragePrefix string `json:"storagePrefix" pflag:",Base URI prefix for storing run inputs and outputs"`

	// SeedProjects are created at startup. If unset, the service seeds the default project list.
	SeedProjects []string `json:"seedProjects" pflag:",Projects to create by default at startup"`

	// Domains are injected into project responses (not stored per project row).
	Domains []DomainConfig `json:"domains"`

	// TriggerScheduler configures the cron-based trigger scheduler worker.
	TriggerScheduler TriggerSchedulerConfig `json:"triggerScheduler"`

	// Apps holds configuration for the App service.
	Apps AppsConfig `json:"apps"`
}

Config holds the configuration for the Runs service

func GetConfig

func GetConfig() *Config

GetConfig returns the parsed runs configuration

func (Config) GetPFlagSet added in v2.0.7

func (cfg Config) GetPFlagSet(prefix string) *pflag.FlagSet

GetPFlagSet will return strongly types pflags for all fields in Config and its nested types. The format of the flags is json-name.json-sub-name... etc.

type DomainConfig added in v2.0.8

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

DomainConfig defines a system domain to inject into project responses.

type ServerConfig

type ServerConfig struct {
	Port int    `json:"port" pflag:",Port to bind the HTTP server"`
	Host string `json:"host" pflag:",Host to bind the HTTP server"`
}

ServerConfig holds HTTP server configuration

type TriggerSchedulerConfig added in v2.0.12

type TriggerSchedulerConfig struct {
	// Enabled turns the scheduler worker on or off.
	Enabled bool `json:"enabled" pflag:",Enable the trigger scheduler worker"`

	// ResyncInterval is how often the scheduler re-reads active triggers from the DB.
	ResyncInterval time.Duration `json:"resyncInterval" pflag:",How often to resync active triggers from the database"`

	// MaxCatchupRunsPerLoop caps how many catchup runs are fired per resync loop.
	MaxCatchupRunsPerLoop int `json:"maxCatchupRunsPerLoop" pflag:",Maximum catchup runs fired per resync loop"`

	// ExecutionQPS is the token-bucket rate for CreateRun calls (tokens/second).
	ExecutionQPS float64 `json:"executionQps" pflag:",Rate limit for CreateRun calls (requests per second)"`

	// ExecutionBurst is the token-bucket burst size.
	ExecutionBurst int `json:"executionBurst" pflag:",Burst size for CreateRun rate limiter"`
}

TriggerSchedulerConfig controls the cron-based scheduler worker.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL