pluginapi

type ApplicationSupport interface {
	basicapi.Application

	GetFileResourceManager(name string) FileResourceManager

	AddConfigureManager(manager basicapi.FullConfigureManager) error
	AddFileResourceManager(fileManager FileResourceManager) error
	AddSubConnectorGeneratorDefinitions(tomlData string) error
	AddSourceConnectorGenerator(source SourceConnectorGenerator) error
	AddTargetConnectorGenerator(target TargetConnectorGenerator) error
	AddApplicationListener(listener LifecycleListener)

	Startup() error
	Stop() error
}

type CommonSourceConnectorGenerateRequest struct {
	Options      map[string]string
	Application  ApplicationSupport
	InstanceName string
}

type CommonTargetConnectorGenerateRequest struct {
	Options      map[string]string
	Application  ApplicationSupport
	InstanceName string
}

type Connector interface {
	Start() error
	Stop() error
	Reload() error
}

type Container interface {
	RegisterBuiltinFn(name string, fnGen FnGen) error
	RegisterCustomFn(name string, fnGen FnGen) error

	NewModel() Model
	WrapReadonlyModelFromMap(map[string]interface{}) (Model, error)

	LoadFlowModel(tomlContent string) error
	LoadMerged(content string) error

	SetupDispatchDecider(decider DispatchDecider) error //TODO Temp solution: container level, due to lifecycle management
	AddLifecycleListener(listener LifecycleListener)
	StartContainer() error
	StopContainer() error
}

type DataType int

type DispatchDecider interface {
	AddFlowInvoker(f FlowInvoker) error

	InjectLocalPipeline(pipelineFullName string, process PipelineProcess) error
	PipelineDispatcher(pipelineFullName string) PipelineProcess

	StartDispatcher() error // triggered once all pipeline resources prepared
	StopDispatcher() error  // triggered once all pipeline resources prepared
}

type FileResourceManager interface {
	Name() string
	LoadFile(path string) ([]byte, error)

	Startup() error
	Stop() error
}

type FlowError struct {
	Key     string
	Message string
}

type FlowInvoker interface {
	Metadata() FlowInvokerMeta

	AddPipeline(pipelineName string, process PipelineProcess) error
	Invoke(pipelineFullName string, model Model) error

	StartFlowInvoker() error // controlled by DispatcherDecider
	StopFlowInvoker() error  // controlled by DispatcherDecider
}

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

type FlowStop struct {
	Key     string
	Message string
}

type Fn = basicapi.Fn

type FnGen = basicapi.FnGen

type LifecycleListener interface {
	OnStart() error
	OnStop() error
}

type MappingDefinition struct {
	ErrSimple    []map[string]string
	ReqConverter func(src, dst Model) error
	ReqArgPaths  []string
	ResConverter func(src, dst Model) error
	ResArgPaths  []string
}

type Model = basicapi.Model

type ModelCopy interface {
	Transfer(dst Model) error
}

type ModelEncoding interface {
	ToToml() ([]byte, error)
	FromToml([]byte) error
}

type PipelineProcess func(m Model) error

type SourceConnector interface {
	Connector

	BindPipeline(PipelineProcess) error
}

type SourceConnectorGenerateRequest struct {
	CommonSourceConnectorGenerateRequest
	Definition *MappingDefinition
	Container  Container
}

type SourceConnectorGenerator interface {
	OriginalGeneratorNames() []string
	GenerateSourceConnectorInstance(req SourceConnectorGenerateRequest) (SourceConnector, error)

	InitializeSubGeneratorInstance(req CommonSourceConnectorGenerateRequest) (SourceConnectorGenerator, error)
	Startup() error
	Stop() error
}

type TargetConnector interface {
	Connector

	InvokeFlow(s, d Model) error
}

type TargetConnectorGenerateRequest struct {
	CommonTargetConnectorGenerateRequest
	Definition *MappingDefinition
	Container  Container
}

type TargetConnectorGenerator interface {
	OriginalGeneratorNames() []string
	GenerateTargetConnectorInstance(req TargetConnectorGenerateRequest) (TargetConnector, error)

	InitializeSubGeneratorInstance(req CommonTargetConnectorGenerateRequest) (TargetConnectorGenerator, error)
	Startup() error
	Stop() error
}

type TypeOfNode int