Versions in this module Expand all Collapse all v0 v0.2.4 Apr 23, 2022 Changes in this version + const StepGroupBackground + const StepGroupRepeating + const StepGroupSequential + const TransformOnce + const TransformRepeating + func CleanupHandlerDefault(log logger.Logger, t TransformManager, s StatsManager, ...) + func GetPanicHandlerWithChannelsFunc(tc *TransformCloser) components.PanicHandlerFunc + func LaunchTransform(log logger.Logger, transformDefn *TransformDefinition, transformGuid string, ...) + func LaunchTransformDefinition(log logger.Logger, ti *SafeMapTransformInfo, t *TransformDefinition, ...) (guid string, err error) + func LaunchTransformJson(log logger.Logger, ti *SafeMapTransformInfo, transformJson string, ...) (guid string, err error) + func LaunchTransformWithControlChannels(log logger.Logger, transformDefn *TransformDefinition, transformGuid string, ...) + func NewMetadataInjection(i interface{}) (outputChan chan stream.Record, controlChan chan components.ControlAction) + func NewStepGroupManager(log logger.Logger, g TransformManager, transformGroupName string) *stepGroup + func StartStepGroup(log logger.Logger, sg *StepGroup, sgm StepGroupManager, stats StatsManager, ...) + type CleanupHandlerFunc = func(log logger.Logger, g TransformManager, s StatsManager, ...) + func GetCleanupHandlerWithChannelsFunc(log logger.Logger, transformGuid string, tc *TransformCloser) CleanupHandlerFunc + type ComponentRegistration struct + type ComponentRegistrationType1 struct + type ComponentRegistrationType2 struct + type ComponentRegistrationType3 struct + type LaunchTransformFunc = func(log logger.Logger, transformDefn *TransformDefinition, transformGuid string, ...) + type MapComponentFuncs map[string]ComponentRegistration + type MetadataInjectionConfig struct + GlobalTransformManager TransformManager + InputChan chan stream.Record + Log logger.Logger + Name string + OutputChanFieldName4JSON string + PanicHandlerFn components.PanicHandlerFunc + ReplacementDateTimeFormat string + ReplacementVariableWithFieldNameCSV string + StepWatcher *stats.StepWatcher + TransformGroupName string + WaitCounter components.ComponentWaiter + type MockStepGroupManager struct + type MockTransformManager struct + type RepeatMetadata struct + SleepSeconds int + type SafeMapTransformInfo struct + Internal map[string]TransformInfo + func NewSafeMapTransformInfo() *SafeMapTransformInfo + func (t *SafeMapTransformInfo) ConsumeTransformStatusChanges(transformGuid string, chanStatus chan TransformStatus) + func (t *SafeMapTransformInfo) Delete(key string) + func (t *SafeMapTransformInfo) Load(key string) (ti TransformInfo, ok bool) + func (t *SafeMapTransformInfo) Store(key string, value TransformInfo) + type StatsManager interface + AddStepWatcher func(stepName string) *stats.StepWatcher + StartDumping func() + StopDumping func() + type Status uint32 + const StatusComplete + const StatusCompleteWithError + const StatusMissing + const StatusRunning + const StatusShutdown + const StatusStarting + func (s Status) MarshalJSON() ([]byte, error) + type Step struct + ComponentSteps []components.ComponentStep + Data map[string]string + Type string + type StepGroup struct + RepeatMeta RepeatMetadata + Sequence []string + Steps map[string]Step + Type string + type StepGroupManager interface + type StepStatus uint32 + const StepStatusDone + const StepStatusRunning + const StepStatusStarting + type Transform struct + func NewTransformManager(log logger.Logger, t *TransformDefinition, transformGuid string) (gt *Transform) + type TransformCloser struct + func NewTransformCloser(chanStatus chan TransformStatus, chanShutdown chan error) *TransformCloser + func (c *TransformCloser) ChannelsAreOpen() bool + func (c *TransformCloser) CloseChannels(statusToSend *TransformStatus) + type TransformDefinition struct + Connections shared.DBConnections + Description string + RepeatMeta RepeatMetadata + SchemaVersion int + Sequence []string + StepGroups map[string]StepGroup + Type string + type TransformInfo struct + ChanStop chan error + Stats stats.StatsFetcher + Status TransformStatus + Transform TransformDefinition + type TransformManager interface + type TransformStatus struct + EndTime time.Time + Error string + StartTime time.Time + Status Status + func (t *TransformStatus) TransformIsFinished() bool
Go to main page