app

Documentation

Index

• Constants
• func ContinueOnError(a *App) error
• func DeleteValue(name string)
• func EnableFlowControl() bool
• func EngineSettings(svcManager *service.Manager, actionSettings map[string]map[string]interface{}) func(*App) error
• func FinalizeProperties(processors ...property.PostProcessor) func(*App) error
• func GetDelayedStopInterval() string
• func GetValue(name string) (value interface{}, exists bool)
• func SetValue(name string, value interface{}) error
• type App
  • func New(config *Config, runner action.Runner, options ...Option) (*App, error)
  • func (a *App) GetProperty(name string) (interface{}, bool)
  • func (a *App) GetResource(id string) *resource.Resource
  • func (a *App) Name() interface{}
  • func (a *App) PostAppEvent(appStatus Status)
  • func (a *App) ResourceManager() *resource.Manager
  • func (a *App) RuntimeSettings() map[string]interface{}
  • func (a *App) ServiceManager() *service.Manager
  • func (a *App) Start() error
  • func (a *App) Stop() error
  • func (a *App) TriggerStatuses() []*managed.StatusInfo
  • func (a *App) Version() interface{}
• type AppEvent
• type AppResolver
  • func (r *AppResolver) GetResolverInfo() *resolve.ResolverInfo
  • func (r *AppResolver) Resolve(scope data.Scope, itemName, valueName string) (interface{}, error)
• type Config
• type Controller
  • func GetEventFlowController() Controller
• type LifecycleAware
• type Option
• type Status

Constants

const (
	FAILED   = "Failed"
	STARTED  = "Started"
	STARTING = "Starting"
	STOPPING = "Stopping"
	STOPPED  = "Stopped"
)

const (
	EnvKeyDelayedAppStopInterval = "FLOGO_APP_DELAYED_STOP_INTERVAL"
	EnvKeyEnableFlowControl      = "FLOGO_APP_ENABLE_FLOW_CONTROL"
)

const (
	AlreadyControlled = "app is already event flow controlled"
)

const AppEventType = "appevent"

Functions

func ContinueOnError

func ContinueOnError(a *App) error

func DeleteValue

func DeleteValue(name string)

DeleteValue remove an app attribute

func EnableFlowControl

func EnableFlowControl() bool

func EngineSettings

func EngineSettings(svcManager *service.Manager, actionSettings map[string]map[string]interface{}) func(*App) error

func FinalizeProperties

func FinalizeProperties(processors ...property.PostProcessor) func(*App) error

func GetDelayedStopInterval

func GetDelayedStopInterval() string

func GetValue

func GetValue(name string) (value interface{}, exists bool)

GetValue gets an app attribute value

func SetValue

func SetValue(name string, value interface{}) error

SetValue sets an app attribute value

Types

type App

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

func New

func New(config *Config, runner action.Runner, options ...Option) (*App, error)

func (*App) GetProperty

func (a *App) GetProperty(name string) (interface{}, bool)

func (*App) GetResource

func (a *App) GetResource(id string) *resource.Resource

func (*App) Name

func (a *App) Name() interface{}

func (*App) PostAppEvent

func (a *App) PostAppEvent(appStatus Status)

func (*App) ResourceManager

func (a *App) ResourceManager() *resource.Manager

func (*App) RuntimeSettings

func (a *App) RuntimeSettings() map[string]interface{}

func (*App) ServiceManager

func (a *App) ServiceManager() *service.Manager

func (*App) Start

func (a *App) Start() error

func (*App) Stop

func (a *App) Stop() error

func (*App) TriggerStatuses

func (a *App) TriggerStatuses() []*managed.StatusInfo

TriggerStatuses gets the status information for the triggers

func (*App) Version

func (a *App) Version() interface{}

type AppEvent

type AppEvent interface {
	AppName() string
	AppVersion() string
	AppStatus() Status
}

type AppResolver

type AppResolver struct {
}

func (*AppResolver) GetResolverInfo

func (r *AppResolver) GetResolverInfo() *resolve.ResolverInfo

func (*AppResolver) Resolve

func (r *AppResolver) Resolve(scope data.Scope, itemName, valueName string) (interface{}, error)

type Config

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

	Imports     []string                      `json:"imports,omitempty"`
	Properties  []*data.Attribute             `json:"properties,omitempty"`
	Channels    []string                      `json:"channels,omitempty"`
	Triggers    []*trigger.Config             `json:"triggers"`
	Resources   []*resource.Config            `json:"resources,omitempty"`
	Actions     []*action.Config              `json:"actions,omitempty"`
	Schemas     map[string]*schema.Def        `json:"schemas,omitempty"`
	Connections map[string]*connection.Config `json:"connections,omitempty"`
}

Def is the configuration for the App

type Controller

type Controller interface {
	StartControl() error
	ReleaseControl() error
}

func GetEventFlowController

func GetEventFlowController() Controller

type LifecycleAware

type LifecycleAware interface {
	OnStartup() error
	OnShutdown() error
}

type Option

type Option func(*App) error

type Status

type Status string