fimcore

package
v0.0.4 Latest Latest
Warning

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

 Go to latest Published: Aug 6, 2023 License: MPL-2.0 Imports: 16 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	ConfigurePrefixStatic  = "configure-static://"
	ConfigurePrefixDynamic = "configure-dynamic://"
)

Variables

This section is empty.

Functions

func Init added in v0.0.2 

func Init() error

func LoadFlowModelFile 

func LoadFlowModelFile(file string) ([]byte, error)

func NewApplication added in v0.0.2 

func NewApplication(applicationName string) basicapi.Application

func NewPluginApplication added in v0.0.2 

func NewPluginApplication(applicationName string) pluginapi.ApplicationSupport

Types

type Application added in v0.0.2 

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

func (*Application) AddApplicationListener added in v0.0.3 

func (a *Application) AddApplicationListener(listener pluginapi.LifecycleListener)

func (*Application) AddConfigureManager added in v0.0.3 

func (a *Application) AddConfigureManager(manager basicapi.FullConfigureManager) error

func (*Application) AddFileResourceManager added in v0.0.2 

func (a *Application) AddFileResourceManager(fileManager pluginapi.FileResourceManager) error

func (*Application) AddSourceConnectorGenerator added in v0.0.2 

func (a *Application) AddSourceConnectorGenerator(gen pluginapi.SourceConnectorGenerator) error

func (*Application) AddSubConnectorGeneratorDefinitions added in v0.0.3 

func (a *Application) AddSubConnectorGeneratorDefinitions(tomlData string) error

func (*Application) AddTargetConnectorGenerator added in v0.0.2 

func (a *Application) AddTargetConnectorGenerator(gen pluginapi.TargetConnectorGenerator) error

func (*Application) GetFileResourceManager added in v0.0.2 

func (a *Application) GetFileResourceManager(name string) pluginapi.FileResourceManager

func (*Application) SpawnUseContainer added in v0.0.2 

func (a *Application) SpawnUseContainer(businessName string) basicapi.BasicContainer

func (*Application) Startup added in v0.0.2 

func (a *Application) Startup() error

func (*Application) Stop added in v0.0.2 

func (a *Application) Stop() error

type ContainerInst 

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

func (*ContainerInst) AddConfigureManager 

func (c *ContainerInst) AddConfigureManager(manager basicapi.ConfigureManager) error

func (*ContainerInst) AddLifecycleListener added in v0.0.4 

func (c *ContainerInst) AddLifecycleListener(listener pluginapi.LifecycleListener)

func (*ContainerInst) GetContainerLoggerManager added in v0.0.2 

func (c *ContainerInst) GetContainerLoggerManager() providers.LoggerManager

func (*ContainerInst) LoadFlowModel 

func (c *ContainerInst) LoadFlowModel(tomlContent string) error

func (*ContainerInst) LoadMerged 

func (c *ContainerInst) LoadMerged(content string) error

func (*ContainerInst) NewModel 

func (c *ContainerInst) NewModel() pluginapi.Model

func (*ContainerInst) RegisterBuiltinFn 

func (c *ContainerInst) RegisterBuiltinFn(methodName string, fg pluginapi.FnGen) error

func (*ContainerInst) RegisterCustomFn 

func (c *ContainerInst) RegisterCustomFn(name string, fn pluginapi.FnGen) error

func (*ContainerInst) SetupDispatchDecider added in v0.0.4 

func (c *ContainerInst) SetupDispatchDecider(decider pluginapi.DispatchDecider) error

func (*ContainerInst) StartContainer 

func (c *ContainerInst) StartContainer() error

func (*ContainerInst) StopContainer added in v0.0.3 

func (c *ContainerInst) StopContainer() error

func (*ContainerInst) WrapReadonlyModelFromMap 

func (c *ContainerInst) WrapReadonlyModelFromMap(m map[string]interface{}) (pluginapi.Model, error)

type DataTypeDefinitions 

type DataTypeDefinitions struct {
	pluginapi.DataType
	PrimitiveArrayElementType pluginapi.DataType // exists only when the element data type is primitive
	// contains filtered or unexported fields
}

func NewDataTypeDefinitions 

func NewDataTypeDefinitions() *DataTypeDefinitions

func (*DataTypeDefinitions) AddTypeDefinitions 

func (d *DataTypeDefinitions) AddTypeDefinitions(m *templateFlowModel) error

func (*DataTypeDefinitions) MergeToml 

func (d *DataTypeDefinitions) MergeToml(data string) error

func (*DataTypeDefinitions) TypeOfPath 

func (d *DataTypeDefinitions) TypeOfPath(path string) (pluginapi.DataType, pluginapi.DataType, error)

TypeOfPath returns the path data type, primitive array element data type and error

type EnvConfigureManager 

type EnvConfigureManager struct {
}

func NewEnvConfigureManager 

func NewEnvConfigureManager() *EnvConfigureManager

func (*EnvConfigureManager) ReplaceDynamicConfigure 

func (e *EnvConfigureManager) ReplaceDynamicConfigure(placeholder string) string

func (*EnvConfigureManager) ReplaceStaticConfigure 

func (e *EnvConfigureManager) ReplaceStaticConfigure(placeholder string) string

func (*EnvConfigureManager) Startup added in v0.0.3 

func (e *EnvConfigureManager) Startup() error

func (*EnvConfigureManager) Stop added in v0.0.3 

func (e *EnvConfigureManager) Stop() error

func (*EnvConfigureManager) SupportDynamicConfigure 

func (e *EnvConfigureManager) SupportDynamicConfigure(placeholder string) bool

type Flow 

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

func NewFlow 

func NewFlow(dtd *DataTypeDefinitions, c *ContainerInst) *Flow

func (*Flow) FlowFn 

func (f *Flow) FlowFn(casePreFn func(m pluginapi.Model) (bool, error)) func() func(global pluginapi.Model) error

func (*Flow) FlowFnNoResp 

func (f *Flow) FlowFnNoResp(casePreFn func(m pluginapi.Model) (bool, error)) func() func(global pluginapi.Model) error

type MergedDefinition 

type MergedDefinition struct {
	Pipelines map[string]*Pipeline     `toml:"pipelines"`
	Flows     map[string]*templateFlow `toml:"flows"`
}

func LoadMergedDefinition 

func LoadMergedDefinition(content string) (*MergedDefinition, error)

type NestedConfigureManager 

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

func NewNestedConfigureManager 

func NewNestedConfigureManager() *NestedConfigureManager

func (*NestedConfigureManager) ReplaceDynamicConfigure 

func (n *NestedConfigureManager) ReplaceDynamicConfigure(placeholder string) string

func (*NestedConfigureManager) ReplaceStaticConfigure 

func (n *NestedConfigureManager) ReplaceStaticConfigure(placeholder string) string

func (*NestedConfigureManager) SupportDynamicConfigure 

func (n *NestedConfigureManager) SupportDynamicConfigure(placeholder string) bool

type Pipeline 

type Pipeline struct {
	Metadata struct {
		Version string `toml:"version"`
	} `toml:"metadata"`
	Parameter struct {
		Inputs        []string            `toml:"inputs"`
		PreOutputs    []map[string]string `toml:"pre_outputs"`
		Outputs       []string            `toml:"outputs"`
		LocalVariable []map[string]string `toml:"local_variables"`
	} `toml:"parameter"`
	Pipeline struct {
		Steps            [][][]interface{} `toml:"steps"`
		SourceConnectors [][][]interface{} `toml:"source_connectors"`
	} `toml:"pipeline"`
	// contains filtered or unexported fields
}

type SettableConfigureManager 

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

func NewSettableConfigureManager 

func NewSettableConfigureManager() *SettableConfigureManager

func (*SettableConfigureManager) ReplaceDynamicConfigure 

func (s *SettableConfigureManager) ReplaceDynamicConfigure(placeholder string) string

func (*SettableConfigureManager) ReplaceStaticConfigure 

func (s *SettableConfigureManager) ReplaceStaticConfigure(placeholder string) string

func (*SettableConfigureManager) SetConfigure 

func (s *SettableConfigureManager) SetConfigure(key, value string) (string, bool)

func (*SettableConfigureManager) Startup added in v0.0.3 

func (s *SettableConfigureManager) Startup() error

func (*SettableConfigureManager) Stop added in v0.0.3 

func (s *SettableConfigureManager) Stop() error

func (*SettableConfigureManager) SupportDynamicConfigure 

func (s *SettableConfigureManager) SupportDynamicConfigure(placeholder string) bool

Source Files

View all Source files

Directories

Path Synopsis

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.