app

Documentation

Index

• func CreateSharedActions(actionConfigs []*action.Config) (map[string]action.Action, error)
• func CreateTriggers(tConfigs []*trigger.Config, actions map[string]action.Action, ...) (map[string]trigger.Trigger, error)
• func GetName() string
• func GetProperties(properties []*data.Attribute) (map[string]interface{}, error)
• func GetVersion() string
• func RegisterPropertyValueResolver(relType string, resolver PropertyValueResolver) error
• func RegisterResources(rConfigs []*resource.Config) error
• type Config
  • func LoadConfig(flogoJson string) (*Config, error)
• type ConfigProvider
  • func DefaultConfigProvider() ConfigProvider
• type EnvVariableValueResolver
  • func (resolver *EnvVariableValueResolver) ResolveValue(toResolve string) (interface{}, error)
• type PropertyProvider
  • func GetPropertyProvider() *PropertyProvider
  • func (pp *PropertyProvider) GetProperty(property string) (interface{}, bool)
  • func (pp *PropertyProvider) SetProperties(value map[string]interface{})
  • func (pp *PropertyProvider) SetProperty(property string, value interface{})
• type PropertyValueResolver
  • func GetPropertyValueResolver(relType string) PropertyValueResolver

Functions

func CreateSharedActions

func CreateSharedActions(actionConfigs []*action.Config) (map[string]action.Action, error)

func CreateTriggers

func CreateTriggers(tConfigs []*trigger.Config, actions map[string]action.Action, runner action.Runner) (map[string]trigger.Trigger, error)

func GetName

func GetName() string

Returns name of the application

func GetProperties

func GetProperties(properties []*data.Attribute) (map[string]interface{}, error)

func GetVersion

func GetVersion() string

Returns version of the application

func RegisterPropertyValueResolver

func RegisterPropertyValueResolver(relType string, resolver PropertyValueResolver) error

func RegisterResources

func RegisterResources(rConfigs []*resource.Config) error

Types

type Config

type Config struct {
	Name        string `json:"name"`
	Type        string `json:"type"`
	Version     string `json:"version"`
	Description string `json:"description"`

	Properties []*data.Attribute  `json:"properties"`
	Channels   []string           `json:"channels"`
	Triggers   []*trigger.Config  `json:"triggers"`
	Resources  []*resource.Config `json:"resources"`
	Actions    []*action.Config   `json:"actions"`
}

Config is the configuration for the App

func LoadConfig

func LoadConfig(flogoJson string) (*Config, error)

type ConfigProvider

type ConfigProvider interface {
	GetApp() (*Config, error)
}

ConfigProvider interface to implement to provide the app configuration

func DefaultConfigProvider

func DefaultConfigProvider() ConfigProvider

DefaultSerializer returns the default App Serializer

type EnvVariableValueResolver

type EnvVariableValueResolver struct {
}

Resolve property value from environment variable

func (*EnvVariableValueResolver) ResolveValue

func (resolver *EnvVariableValueResolver) ResolveValue(toResolve string) (interface{}, error)

type PropertyProvider

type PropertyProvider struct {
	// contains filtered or unexported fields
}

func GetPropertyProvider

func GetPropertyProvider() *PropertyProvider

func (*PropertyProvider) GetProperty

func (pp *PropertyProvider) GetProperty(property string) (interface{}, bool)

func (*PropertyProvider) SetProperties

func (pp *PropertyProvider) SetProperties(value map[string]interface{})

func (*PropertyProvider) SetProperty

func (pp *PropertyProvider) SetProperty(property string, value interface{})

type PropertyValueResolver

type PropertyValueResolver interface {
	ResolveValue(toResolve string) (interface{}, error)
}

func GetPropertyValueResolver

func GetPropertyValueResolver(relType string) PropertyValueResolver