fimcore

package
v0.0.1 Latest Latest
Warning

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

Go to latest
Published: Jun 5, 2023 License: MPL-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func LoadFlowModelFile

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

func NewUseContainer

func NewUseContainer() basicapi.BasicContainer

Types

type ContainerInst

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

func NewContainer

func NewContainer() *ContainerInst

func (*ContainerInst) AddConfigureManager

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

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) RegisterSourceConnectorGen

func (c *ContainerInst) RegisterSourceConnectorGen(connGen pluginapi.SourceConnectorGenerator) error

func (*ContainerInst) RegisterTargetConnectorGen

func (c *ContainerInst) RegisterTargetConnectorGen(connGen pluginapi.TargetConnectorGenerator) error

func (*ContainerInst) StartContainer

func (c *ContainerInst) StartContainer() 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

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) 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"`
	ConnectorMapping map[string]struct {
		Req       modelinst.MappingRuleRaw `toml:"req"`
		Res       modelinst.MappingRuleRaw `toml:"res"`
		ErrSimple []map[string]string      `toml:"err_simple"`
	} `toml:"connector_mapping"`
	// 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) SupportDynamicConfigure

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL