environment

Documentation

Index

• Constants
• func GetApplicationNamespace() string
• func GetCACERTSecretName() string
• func GetCACERTSecretNamespace() string
• func GetCSPPath() string
• func GetCertSecretName() string
• func GetCertSecretNamespace() string
• func GetControllerNamespace() string
• func GetDataCatalogServiceAddress() string
• func GetDataDir() string
• func GetDataPathMaxSize() (int, error)
• func GetDefaultModulesNamespace() string
• func GetEnvAsFloat32(key string, defaultValue float32) float32
• func GetEnvAsInt(key string, defaultValue int) int
• func GetLocalClusterName() string
• func GetLocalRegion() string
• func GetLocalVaultAuthPath() string
• func GetLocalZone() string
• func GetModulesRole() string
• func GetSystemNamespace() string
• func GetVaultAddress() string
• func IsUsingMTLS() bool
• func IsUsingTLS() bool
• func IsVaultEnabled() bool
• func LogEnvVariables(log *zerolog.Logger)
• func MustGetEnv(key string) (string, error)
• func UseCSP() bool

Constants

const (
	CatalogConnectorServiceAddressKey string = "CATALOG_CONNECTOR_URL"
	VaultEnabledKey                   string = "VAULT_ENABLED"
	VaultAddressKey                   string = "VAULT_ADDRESS"
	VaultModulesRoleKey               string = "VAULT_MODULES_ROLE"
	EnableWebhooksKey                 string = "ENABLE_WEBHOOKS"
	ConnectionTimeoutKey              string = "CONNECTION_TIMEOUT"
	MainPolicyManagerNameKey          string = "MAIN_POLICY_MANAGER_NAME"
	MainPolicyManagerConnectorURLKey  string = "MAIN_POLICY_MANAGER_CONNECTOR_URL"
	LoggingVerbosityKey               string = "LOGGING_VERBOSITY"
	PrettyLoggingKey                  string = "PRETTY_LOGGING"
	CatalogProviderNameKey            string = "CATALOG_PROVIDER_NAME"
	DatapathLimitKey                  string = "DATAPATH_LIMIT"
	UseCSPKey                         string = "USE_CSP"
	CSPPathKey                        string = "CSP_PATH"
	DataDir                           string = "DATA_DIR"
	ModuleNamespace                   string = "MODULES_NAMESPACE"
	ControllerNamespace               string = "CONTROLLER_NAMESPACE"
	ApplicationNamespace              string = "APPLICATION_NAMESPACE"
	UseTLS                            string = "USE_TLS"
	UseMTLS                           string = "USE_MTLS"
	CertSecretName                    string = "CERT_SECRET_NAME"
	CertSecretNamespace               string = "CERT_SECRET_NAMESPACE"
	CACERTSecretName                  string = "CACERT_SECRET_NAME"      //nolint:gosec
	CACERTSecretNamespace             string = "CACERT_SECRET_NAMESPACE" //nolint:gosec
	LocalClusterName                  string = "ClusterName"
	LocalZone                         string = "Zone"
	LocalRegion                       string = "Region"
	LocalVaultAuthPath                string = "VaultAuthPath"
)

Attributes that are defined in a config map or the runtime environment

const DefaultControllerNamespace = "fybrik-system"

DefaultControllerNamespace defines a default namespace where fybrik control plane is running

const DefaultModulesNamespace = "fybrik-blueprints"

DefaultModulesNamespace defines a default namespace where module resources will be allocated

Functions

func GetApplicationNamespace

func GetApplicationNamespace() string

func GetCACERTSecretName

func GetCACERTSecretName() string

GetCACERTSecretName returns the name of the kubernetes secret that holds the CA certificates used by the client/server to validate the manager to the manager/connectors.

func GetCACERTSecretNamespace

func GetCACERTSecretNamespace() string

GetCACERTSecretNamespace returns the namespace of the kubernetes secret that holds the CA certificate used by the client/server to validate the manager to the manager/connectors.

func GetCSPPath

func GetCSPPath() string

GetCSPPath returns the path of the CSP solver to use when generating a plotter, or "" if no CSP solver is defined

func GetCertSecretName

func GetCertSecretName() string

GetCertSecretName returns the name of the kubernetes secret which holds the manager/connectors.

func GetCertSecretNamespace

func GetCertSecretNamespace() string

GetCertSecretNamespace returns the namespace of the kubernetes secret which holds the manager/connectors.

func GetControllerNamespace

func GetControllerNamespace() string

func GetDataCatalogServiceAddress

func GetDataCatalogServiceAddress() string

GetDataCatalogServiceAddress returns the address where data catalog is running

func GetDataDir

func GetDataDir() string

GetDataDir returns the directory where the data resides.

func GetDataPathMaxSize

func GetDataPathMaxSize() (int, error)

GetDataPathMaxSize bounds the data path size (number of modules that access data for read/write/copy, not including transformations)

func GetDefaultModulesNamespace

func GetDefaultModulesNamespace() string

func GetEnvAsFloat32

func GetEnvAsFloat32(key string, defaultValue float32) float32

Returns the float32 value of an environment variable. If the environment variable is not set or cannot be parsed the default value is returned.

func GetEnvAsInt

func GetEnvAsInt(key string, defaultValue int) int

Returns the integer value of an environment variable. If the environment variable is not set or cannot be parsed the default value is returned.

func GetLocalClusterName

func GetLocalClusterName() string

func GetLocalRegion

func GetLocalRegion() string

func GetLocalVaultAuthPath

func GetLocalVaultAuthPath() string

func GetLocalZone

func GetLocalZone() string

func GetModulesRole

func GetModulesRole() string

GetModulesRole returns the modules assigned authentication role for accessing dataset credentials

func GetSystemNamespace

func GetSystemNamespace() string

GetSystemNamespace returns the namespace of control plane

func GetVaultAddress

func GetVaultAddress() string

GetVaultAddress returns the address and port of the vault system, which is used for managing data set credentials

func IsUsingMTLS

func IsUsingMTLS() bool

IsUsingMTLS returns true if the connector communication should use mtls.

func IsUsingTLS

func IsUsingTLS() bool

IsUsingTLS returns true if the connector communication should use tls.

func IsVaultEnabled

func IsVaultEnabled() bool

func LogEnvVariables

func LogEnvVariables(log *zerolog.Logger)

func MustGetEnv

func MustGetEnv(key string) (string, error)

func UseCSP

func UseCSP() bool

UseCSP return true if a CSP solver should be used when generating a plotter