Versions in this module Expand all Collapse all v0 v0.0.1 Jun 13, 2023 Changes in this version + const Content_location_key + const Content_type_key + func FlagsetFromConfigurationOptions(param ConfigurationOptions) *pflag.FlagSet + func GetCommandFromWorkflowIdentifier(id Identifier) string + func JsonFromConfigurationOptions(param ConfigurationOptions) []byte + type Callback func(invocation InvocationContext, input []Data) ([]Data, error) + type ConfigurationOptions interface + func ConfigurationOptionsFromFlagset(flagset *pflag.FlagSet) ConfigurationOptions + func ConfigurationOptionsFromJson(bytes []byte) ConfigurationOptions + func GetGlobalConfiguration() ConfigurationOptions + type ConfigurationOptionsImpl struct + type Data interface + GetContentLocation func() string + GetContentType func() string + GetIdentifier func() Identifier + GetMetaData func(key string) (string, error) + GetPayload func() interface{} + SetContentLocation func(string) + SetMetaData func(key string, value string) + SetPayload func(payload interface{}) + func NewData(id Identifier, contentType string, payload interface{}) Data + func NewDataFromInput(input Data, typeIdentifier Identifier, contentType string, payload interface{}) Data + type DataImpl struct + func (d *DataImpl) GetContentLocation() string + func (d *DataImpl) GetContentType() string + func (d *DataImpl) GetIdentifier() Identifier + func (d *DataImpl) GetMetaData(key string) (string, error) + func (d *DataImpl) GetPayload() interface{} + func (d *DataImpl) SetContentLocation(location string) + func (d *DataImpl) SetMetaData(key string, value string) + func (d *DataImpl) SetPayload(payload interface{}) + func (d *DataImpl) String() string + type Engine interface + AddExtensionInitializer func(initializer ExtensionInit) + GetAnalytics func() analytics.Analytics + GetConfiguration func() configuration.Configuration + GetLogger func() *zerolog.Logger + GetNetworkAccess func() networking.NetworkAccess + GetWorkflow func(id Identifier) (Entry, bool) + GetWorkflows func() []Identifier + Init func() error + Invoke func(id Identifier) ([]Data, error) + InvokeWithConfig func(id Identifier, config configuration.Configuration) ([]Data, error) + InvokeWithInput func(id Identifier, input []Data) ([]Data, error) + InvokeWithInputAndConfig func(id Identifier, input []Data, config configuration.Configuration) ([]Data, error) + Register func(id Identifier, config ConfigurationOptions, callback Callback) (Entry, error) + SetConfiguration func(config configuration.Configuration) + SetLogger func(logger *zerolog.Logger) + func NewDefaultWorkFlowEngine() Engine + func NewWorkFlowEngine(configuration configuration.Configuration) Engine + type EngineImpl struct + func (e *EngineImpl) AddExtensionInitializer(initializer ExtensionInit) + func (e *EngineImpl) GetAnalytics() analytics.Analytics + func (e *EngineImpl) GetConfiguration() configuration.Configuration + func (e *EngineImpl) GetLogger() *zerolog.Logger + func (e *EngineImpl) GetNetworkAccess() networking.NetworkAccess + func (e *EngineImpl) GetWorkflow(id Identifier) (Entry, bool) + func (e *EngineImpl) GetWorkflows() []Identifier + func (e *EngineImpl) Init() error + func (e *EngineImpl) Invoke(id Identifier) ([]Data, error) + func (e *EngineImpl) InvokeWithConfig(id Identifier, config configuration.Configuration) ([]Data, error) + func (e *EngineImpl) InvokeWithInput(id Identifier, input []Data) ([]Data, error) + func (e *EngineImpl) InvokeWithInputAndConfig(id Identifier, input []Data, config configuration.Configuration) ([]Data, error) + func (e *EngineImpl) Register(id Identifier, config ConfigurationOptions, entryPoint Callback) (Entry, error) + func (e *EngineImpl) SetConfiguration(config configuration.Configuration) + func (e *EngineImpl) SetLogger(logger *zerolog.Logger) + type Entry interface + GetConfigurationOptions func() ConfigurationOptions + GetEntryPoint func() Callback + IsVisible func() bool + SetVisibility func(visible bool) + type EntryImpl struct + func (e *EntryImpl) GetConfigurationOptions() ConfigurationOptions + func (e *EntryImpl) GetEntryPoint() Callback + func (e *EntryImpl) IsVisible() bool + func (e *EntryImpl) SetVisibility(visible bool) + type ExtensionInit func(engine Engine) error + type Identifier = *url.URL + func NewTypeIdentifier(workflowID Identifier, dataType string) Identifier + func NewWorkflowIdentifier(command string) Identifier + type InvocationContext interface + GetAnalytics func() analytics.Analytics + GetConfiguration func() configuration.Configuration + GetEngine func() Engine + GetEnhancedLogger func() *zerolog.Logger + GetLogger func() *log.Logger + GetNetworkAccess func() networking.NetworkAccess + GetWorkflowIdentifier func() Identifier + type InvocationContextImpl struct + Analytics analytics.Analytics + Configuration configuration.Configuration + WorkflowEngine *EngineImpl + WorkflowID Identifier + func (ici *InvocationContextImpl) GetAnalytics() analytics.Analytics + func (ici *InvocationContextImpl) GetConfiguration() configuration.Configuration + func (ici *InvocationContextImpl) GetEngine() Engine + func (ici *InvocationContextImpl) GetEnhancedLogger() *zerolog.Logger + func (ici *InvocationContextImpl) GetLogger() *log.Logger + func (ici *InvocationContextImpl) GetNetworkAccess() networking.NetworkAccess + func (ici *InvocationContextImpl) GetWorkflowIdentifier() Identifier
Go to main page