Documentation ¶
Index ¶
- Constants
- func LoadFlowModelFile(file string) ([]byte, error)
- func NewUseContainer() basicapi.BasicContainer
- type ContainerInst
- func (c *ContainerInst) AddConfigureManager(manager basicapi.ConfigureManager) error
- func (c *ContainerInst) LoadFlowModel(tomlContent string) error
- func (c *ContainerInst) LoadMerged(content string) error
- func (c *ContainerInst) NewModel() pluginapi.Model
- func (c *ContainerInst) RegisterBuiltinFn(methodName string, fg pluginapi.FnGen) error
- func (c *ContainerInst) RegisterCustomFn(name string, fn pluginapi.FnGen) error
- func (c *ContainerInst) RegisterSourceConnectorGen(connGen pluginapi.SourceConnectorGenerator) error
- func (c *ContainerInst) RegisterTargetConnectorGen(connGen pluginapi.TargetConnectorGenerator) error
- func (c *ContainerInst) StartContainer() error
- func (c *ContainerInst) WrapReadonlyModelFromMap(m map[string]interface{}) (pluginapi.Model, error)
- type DataTypeDefinitions
- type EnvConfigureManager
- type Flow
- type MergedDefinition
- type NestedConfigureManager
- type Pipeline
- type SettableConfigureManager
- func (s *SettableConfigureManager) ReplaceDynamicConfigure(placeholder string) string
- func (s *SettableConfigureManager) ReplaceStaticConfigure(placeholder string) string
- func (s *SettableConfigureManager) SetConfigure(key, value string) (string, bool)
- func (s *SettableConfigureManager) SupportDynamicConfigure(placeholder string) bool
Constants ¶
View Source
const ( ConfigurePrefixStatic = "configure-static://" ConfigurePrefixDynamic = "configure-dynamic://" )
Variables ¶
This section is empty.
Functions ¶
func LoadFlowModelFile ¶
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 ¶
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) 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
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
Source Files ¶
Click to show internal directories.
Click to hide internal directories.