Documentation ¶
Index ¶
- Constants
- func ConfigOption(engineJson string, compressed bool) func(*engineImpl) error
- func ConfigViaEnv(e *engineImpl)
- func DirectRunner(e *engineImpl) error
- func EnvPropertyProcessor(properties map[string]interface{}) error
- func GetAppName() string
- func GetAppPropertyValueResolvers(logger log.Logger) string
- func GetAppVersion() string
- func GetFlogoAppConfigPath() string
- func GetFlogoEngineConfigPath() string
- func GetRunnerQueueSize() int
- func GetRunnerType() string
- func GetRunnerWorkers() int
- func IsSchemaSupportEnabled() bool
- func IsSchemaValidationEnabled() bool
- func LifeCycle(managedEntity managed.Managed)
- func LoadAppConfig(flogoJson string, compressed bool) (*app.Config, error)
- func NewPooledRunnerConfig() *runner.PooledConfig
- func RunEngine(e Engine) int
- func StopEngineOnError() bool
- type Config
- type Engine
- type Option
- type ServiceConfig
Constants ¶
View Source
const ( EnvKeyAppConfigLocation = "FLOGO_CONFIG_PATH" DefaultAppConfigLocation = "flogo.json" EnvKeyEngineConfigLocation = "FLOGO_ENG_CONFIG_PATH" DefaultEngineConfigLocation = "engine.json" EnvKeyStopEngineOnError = "FLOGO_ENGINE_STOP_ON_ERROR" DefaultStopEngineOnError = true EnvKeyRunnerType = "FLOGO_RUNNER_TYPE" DefaultRunnerType = ValueRunnerTypePooled EnvKeyRunnerWorkers = "FLOGO_RUNNER_WORKERS" DefaultRunnerWorkers = 5 //Deprecated EnvKeyRunnerQueueSizeLegacy = "FLOGO_RUNNER_QUEUE" EnvKeyRunnerQueueSize = "FLOGO_RUNNER_QUEUE_SIZE" DefaultRunnerQueueSize = 50 EnvAppPropertyResolvers = "FLOGO_APP_PROP_RESOLVERS" EnvEnableSchemaSupport = "FLOGO_SCHEMA_SUPPORT" EnvEnableSchemaValidation = "FLOGO_SCHEMA_VALIDATION" ValueRunnerTypePooled = "POOLED" ValueRunnerTypeDirect = "DIRECT" )
Variables ¶
This section is empty.
Functions ¶
func ConfigOption ¶
func ConfigViaEnv ¶
func ConfigViaEnv(e *engineImpl)
func DirectRunner ¶
func DirectRunner(e *engineImpl) error
func EnvPropertyProcessor ¶
func GetFlogoAppConfigPath ¶
func GetFlogoAppConfigPath() string
GetFlogoAppConfigPath returns the flogo config path
func GetFlogoEngineConfigPath ¶
func GetFlogoEngineConfigPath() string
GetFlogoEngineConfigPath returns the flogo engine config path
func GetRunnerQueueSize ¶
func GetRunnerQueueSize() int
GetRunnerQueueSize returns the runner queue size
func GetRunnerWorkers ¶
func GetRunnerWorkers() int
GetRunnerWorkers returns the number of workers to use
func IsSchemaSupportEnabled ¶
func IsSchemaSupportEnabled() bool
func IsSchemaValidationEnabled ¶
func IsSchemaValidationEnabled() bool
func NewPooledRunnerConfig ¶
func NewPooledRunnerConfig() *runner.PooledConfig
NewPooledRunnerConfig creates a new Pooled config, looks for environment variables to override default values
func StopEngineOnError ¶
func StopEngineOnError() bool
Types ¶
type Config ¶
type Config struct { Name string `json:"name"` Type string `json:"type"` Description string `json:"description"` StopEngineOnError bool `json:"stopEngineOnError,omitempty"` RunnerType string `json:"runnerType,omitempty"` Imports []string `json:"imports,omitempty"` ActionSettings map[string]map[string]interface{} `json:"actionSettings,omitempty"` Services []*ServiceConfig `json:"services,omitempty"` }
Config is the configuration for the Engine, assumes all necessary imports have been add to go code
type Engine ¶
type Engine interface { //App get the application associated with this engine App() *app.App // Start starts the engine Start() error // Stop stop the engine Stop() error }
Interface for the engine behaviour
type ServiceConfig ¶
ServiceConfig is the configuration for Engine Services
Source Files ¶
Click to show internal directories.
Click to hide internal directories.