airmodel

package module
v0.0.0-...-5f34eba Latest Latest
Warning

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

 Go to latest Published: Aug 11, 2022 License: BSD-3-Clause Imports: 11 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromFile 

func FromFile(filename string) (map[string]interface{}, error)

Types

type BasePipelineComponent 

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

func (BasePipelineComponent) Get 

func (this BasePipelineComponent) Get(key string) interface{}

func (BasePipelineComponent) GetData 

func (this BasePipelineComponent) GetData() map[string]interface{}

func (BasePipelineComponent) Set 

func (this BasePipelineComponent) Set(key string, value interface{}) interface{}

type Connections 

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

func NewConnections 

func NewConnections() Connections

Connections

func (*Connections) Add 

func (this *Connections) Add(connections interface{})

func (*Connections) Clone 

func (this *Connections) Clone() Connections

func (*Connections) GetConnections 

func (this *Connections) GetConnections() interface{}

type Contributes 

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

func NewContributes 

func NewContributes() Contributes

func (*Contributes) Add 

func (this *Contributes) Add(contributes interface{})

func (*Contributes) AddContributes 

func (this *Contributes) AddContributes(encodedContributeString string)

func (*Contributes) Clone 

func (this *Contributes) Clone() Contributes

func (*Contributes) GetString 

func (this *Contributes) GetString() string

type DataSource 

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

func NewDataSource 

func NewDataSource(category string, datasource string, subflowActivity map[string]interface{}) (DataSource, error)

func (DataSource) Build 

func (this DataSource) Build(subflowID string)

func (DataSource) BuildActivities 

func (this DataSource) BuildActivities(subflowID string) []interface{}

func (DataSource) Clone 

func (this DataSource) Clone(sn int, name string, runtimeProperties []interface{}) PipelineComponent

func (DataSource) Get 

func (this DataSource) Get(key string) interface{}

func (DataSource) GetConnections 

func (this DataSource) GetConnections() interface{}

func (DataSource) GetContribution 

func (this DataSource) GetContribution() interface{}

func (DataSource) GetData 

func (this DataSource) GetData() map[string]interface{}

func (DataSource) GetID 

func (this DataSource) GetID() string

func (DataSource) GetImports 

func (this DataSource) GetImports() []interface{}

func (DataSource) GetProperties 

func (this DataSource) GetProperties() []interface{}

func (DataSource) GetRawProperties 

func (this DataSource) GetRawProperties() []interface{}

func (DataSource) GetResource 

func (this DataSource) GetResource() interface{}

func (DataSource) GetRuntimeProperties 

func (this DataSource) GetRuntimeProperties() []interface{}

func (DataSource) GetTriggers 

func (this DataSource) GetTriggers() []interface{}

func (DataSource) SetRuntimeProperties 

func (this DataSource) SetRuntimeProperties(runtimeProperties []interface{})

type FlogoTemplateLibrary 

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

func NewFlogoTemplateLibrary 

func NewFlogoTemplateLibrary(folder string) (*FlogoTemplateLibrary, error)

func (*FlogoTemplateLibrary) GetComponent 

func (this *FlogoTemplateLibrary) GetComponent(sn int, category string, name string, properties []interface{}) PipelineComponent

func (*FlogoTemplateLibrary) GetComponentDescriptor 

func (this *FlogoTemplateLibrary) GetComponentDescriptor(category string, name string) interface{}

func (*FlogoTemplateLibrary) GetPipeline 

func (this *FlogoTemplateLibrary) GetPipeline() Pipeline

type Imports 

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

func NewImports 

func NewImports() Imports

Imports

func (*Imports) Add 

func (this *Imports) Add(imports []interface{})

func (*Imports) Clone 

func (this *Imports) Clone() Imports

func (*Imports) GetImports 

func (this *Imports) GetImports() []interface{}

type Logic 

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

func NewLogic 

func NewLogic(
	category string,
	filename string,
	subflowActivity map[string]interface{},
	metadata map[string]interface{},
	errorHandler map[string]interface{}) (Logic, error)

func (Logic) Build 

func (this Logic) Build(nextSubflowID string, last bool)

func (Logic) Clone 

func (this Logic) Clone(sn int, name string, runtimeProperties []interface{}) PipelineComponent

func (Logic) Get 

func (this Logic) Get(key string) interface{}

func (Logic) GetCategory 

func (this Logic) GetCategory() string

func (Logic) GetConnections 

func (this Logic) GetConnections() interface{}

func (Logic) GetContribution 

func (this Logic) GetContribution() interface{}

func (Logic) GetData 

func (this Logic) GetData() map[string]interface{}

func (Logic) GetID 

func (this Logic) GetID() string

func (Logic) GetImports 

func (this Logic) GetImports() []interface{}

func (Logic) GetNotificationBroker 

func (this Logic) GetNotificationBroker() interface{}

func (Logic) GetProperties 

func (this Logic) GetProperties() []interface{}

func (Logic) GetRawProperties 

func (this Logic) GetRawProperties() []interface{}

func (Logic) GetResource 

func (this Logic) GetResource() interface{}

func (Logic) GetRunner 

func (this Logic) GetRunner() interface{}

func (Logic) GetRuntimeProperties 

func (this Logic) GetRuntimeProperties() []interface{}

func (Logic) SetRuntimeProperties 

func (this Logic) SetRuntimeProperties(runtimeProperties []interface{})

type Notifier 

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

func NewNotifier 

func NewNotifier(category string, datasource string) (Notifier, error)

func (Notifier) Build 

func (this Notifier) Build(subflowID string)

func (Notifier) BuildTriggers 

func (this Notifier) BuildTriggers(subflowID string) []interface{}

func (Notifier) Clone 

func (this Notifier) Clone(sn int, name string, runtimeProperties []interface{}) PipelineComponent

func (Notifier) Get 

func (this Notifier) Get(key string) interface{}

func (Notifier) GetConnections 

func (this Notifier) GetConnections() interface{}

func (Notifier) GetContribution 

func (this Notifier) GetContribution() interface{}

func (Notifier) GetData 

func (this Notifier) GetData() map[string]interface{}

func (Notifier) GetID 

func (this Notifier) GetID() string

func (Notifier) GetImports 

func (this Notifier) GetImports() []interface{}

func (Notifier) GetProperties 

func (this Notifier) GetProperties() []interface{}

func (Notifier) GetRawProperties 

func (this Notifier) GetRawProperties() []interface{}

func (Notifier) GetRuntimeProperties 

func (this Notifier) GetRuntimeProperties() []interface{}

func (Notifier) GetTriggers 

func (this Notifier) GetTriggers(notifierID string, listeners map[string]interface{}) []interface{}

func (Notifier) SetRuntimeProperties 

func (this Notifier) SetRuntimeProperties(runtimeProperties []interface{})

type ObjectStringValueReplaceHandler 

type ObjectStringValueReplaceHandler struct {
	objectbuilder.FlogoBuilder
	ID string
}

func (ObjectStringValueReplaceHandler) HandleElements 

func (this ObjectStringValueReplaceHandler) HandleElements(namespace objectbuilder.ElementId, element interface{}, dataType interface{}) interface{}

type Pipeline 

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

func BuildFlogoApp 

func BuildFlogoApp(
	template *FlogoTemplateLibrary,
	applicationName string,
	applicationPipelineDescriptor map[string]interface{},
	config map[string]interface{},
) (descriptorString string, pipeline Pipeline, extra []interface{}, runner interface{}, ports []interface{}, replicas int, err error)

func NewPipeline 

func NewPipeline(applicationName string, filename string) (Pipeline, error)

func (*Pipeline) AddErrorLogic 

func (this *Pipeline) AddErrorLogic(logic Logic)

func (*Pipeline) AddLogic 

func (this *Pipeline) AddLogic(logic Logic)

func (*Pipeline) AddNormalLogic 

func (this *Pipeline) AddNormalLogic(logic Logic)

func (*Pipeline) AddNotifier 

func (this *Pipeline) AddNotifier(ID string, notifier Notifier)

func (*Pipeline) Build 

func (this *Pipeline) Build() (string, error)

func (Pipeline) Clone 

func (this Pipeline) Clone() Pipeline

func (*Pipeline) GetConnections 

func (this *Pipeline) GetConnections() Connections

func (*Pipeline) GetContributes 

func (this *Pipeline) GetContributes() Contributes

func (*Pipeline) GetData 

func (this *Pipeline) GetData() map[string]interface{}

func (*Pipeline) GetDataSource 

func (this *Pipeline) GetDataSource() DataSource

func (*Pipeline) GetImports 

func (this *Pipeline) GetImports() Imports

func (*Pipeline) GetProperties 

func (this *Pipeline) GetProperties() Properties

func (*Pipeline) SetDataSource 

func (this *Pipeline) SetDataSource(source DataSource)

func (*Pipeline) SetListeners 

func (this *Pipeline) SetListeners(listeners map[string]interface{})

type PipelineComponent 

type PipelineComponent interface {
	GetData() map[string]interface{}
	GetProperties() []interface{}
	GetRuntimeProperties() []interface{}
	SetRuntimeProperties(runtimeProperties []interface{})
	Clone(sn int, name string, runtimeProperties []interface{}) PipelineComponent
}

type Properties 

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

func NewProperties 

func NewProperties() Properties

func (*Properties) Add 

func (this *Properties) Add(
	component string,
	properties []interface{},
	propertyMamingMap []interface{},
	newDefinedProperties []interface{},
	runtimeProperties []interface{})

func (*Properties) Clone 

func (this *Properties) Clone() Properties

func (*Properties) GetProperties 

func (this *Properties) GetProperties() []interface{}

func (*Properties) GetPropertyNameDef 

func (this *Properties) GetPropertyNameDef() map[string]interface{}

func (*Properties) GetReplacements 

func (this *Properties) GetReplacements() ([]interface{}, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.