fimcore

package

Go to main page

Versions in this module

v0

v0.0.4

Aug 6, 2023

Changes in this version

type ContainerInst

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

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

v0.0.3

Jul 7, 2023

Changes in this version

type Application

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

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

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

type ContainerInst

+ func (c *ContainerInst) AddApplicationListener(listener pluginapi.LifecycleListener)

+ func (c *ContainerInst) StopContainer() error

type EnvConfigureManager

+ func (e *EnvConfigureManager) Startup() error

+ func (e *EnvConfigureManager) Stop() error

type SettableConfigureManager

+ func (s *SettableConfigureManager) Startup() error

+ func (s *SettableConfigureManager) Stop() error

v0.0.2

Jul 1, 2023

Changes in this version

+ func Init() error

+ func NewApplication() basicapi.Application

+ func NewPluginApplication() pluginapi.ApplicationSupport

+ type Application struct

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

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

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

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

+ func (a *Application) SpawnUseContainer() basicapi.BasicContainer

+ func (a *Application) Startup() error

+ func (a *Application) Stop() error

type ContainerInst

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

v0.0.1

Jun 5, 2023

Changes in this version

+ const ConfigurePrefixDynamic

+ const ConfigurePrefixStatic

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

+ func NewUseContainer() basicapi.BasicContainer

+ type ContainerInst struct

+ func NewContainer() *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 struct

+ PrimitiveArrayElementType pluginapi.DataType

+ func NewDataTypeDefinitions() *DataTypeDefinitions

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

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

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

+ type EnvConfigureManager struct

+ func NewEnvConfigureManager() *EnvConfigureManager

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

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

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

+ type Flow struct

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

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

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

+ type MergedDefinition struct

+ Flows map[string]*templateFlow

+ Pipelines map[string]*Pipeline

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

+ type NestedConfigureManager struct

+ func NewNestedConfigureManager() *NestedConfigureManager

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

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

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

+ type Pipeline struct

+ ConnectorMapping map[string]struct{ ... }

+ Metadata struct{ ... }

+ Parameter struct{ ... }

+ Pipeline struct{ ... }

+ type SettableConfigureManager struct

+ func NewSettableConfigureManager() *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

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