Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + type TaskNodeHandler struct + func (_m *TaskNodeHandler) Abort(ctx context.Context, executionContext interfaces.NodeExecutionContext, ...) error + func (_m *TaskNodeHandler) Finalize(ctx context.Context, executionContext interfaces.NodeExecutionContext) error + func (_m *TaskNodeHandler) FinalizeRequired() bool + func (_m *TaskNodeHandler) GetCatalogKey(ctx context.Context, executionContext interfaces.NodeExecutionContext) (catalog.Key, error) + func (_m *TaskNodeHandler) Handle(ctx context.Context, executionContext interfaces.NodeExecutionContext) (handler.Transition, error) + func (_m *TaskNodeHandler) IsCacheable(ctx context.Context, executionContext interfaces.NodeExecutionContext) (bool, bool, error) + func (_m *TaskNodeHandler) OnAbort(ctx context.Context, executionContext interfaces.NodeExecutionContext, ...) *TaskNodeHandler_Abort + func (_m *TaskNodeHandler) OnAbortMatch(matchers ...interface{}) *TaskNodeHandler_Abort + func (_m *TaskNodeHandler) OnFinalize(ctx context.Context, executionContext interfaces.NodeExecutionContext) *TaskNodeHandler_Finalize + func (_m *TaskNodeHandler) OnFinalizeMatch(matchers ...interface{}) *TaskNodeHandler_Finalize + func (_m *TaskNodeHandler) OnFinalizeRequired() *TaskNodeHandler_FinalizeRequired + func (_m *TaskNodeHandler) OnFinalizeRequiredMatch(matchers ...interface{}) *TaskNodeHandler_FinalizeRequired + func (_m *TaskNodeHandler) OnGetCatalogKey(ctx context.Context, executionContext interfaces.NodeExecutionContext) *TaskNodeHandler_GetCatalogKey + func (_m *TaskNodeHandler) OnGetCatalogKeyMatch(matchers ...interface{}) *TaskNodeHandler_GetCatalogKey + func (_m *TaskNodeHandler) OnHandle(ctx context.Context, executionContext interfaces.NodeExecutionContext) *TaskNodeHandler_Handle + func (_m *TaskNodeHandler) OnHandleMatch(matchers ...interface{}) *TaskNodeHandler_Handle + func (_m *TaskNodeHandler) OnIsCacheable(ctx context.Context, executionContext interfaces.NodeExecutionContext) *TaskNodeHandler_IsCacheable + func (_m *TaskNodeHandler) OnIsCacheableMatch(matchers ...interface{}) *TaskNodeHandler_IsCacheable + func (_m *TaskNodeHandler) OnSetup(ctx context.Context, setupContext interfaces.SetupContext) *TaskNodeHandler_Setup + func (_m *TaskNodeHandler) OnSetupMatch(matchers ...interface{}) *TaskNodeHandler_Setup + func (_m *TaskNodeHandler) OnValidateOutput(ctx context.Context, nodeID string, i io.InputReader, r io.OutputReader, ...) *TaskNodeHandler_ValidateOutput + func (_m *TaskNodeHandler) OnValidateOutputMatch(matchers ...interface{}) *TaskNodeHandler_ValidateOutput + func (_m *TaskNodeHandler) Setup(ctx context.Context, setupContext interfaces.SetupContext) error + func (_m *TaskNodeHandler) ValidateOutput(ctx context.Context, nodeID string, i io.InputReader, r io.OutputReader, ...) (*io.ExecutionError, error) + type TaskNodeHandler_Abort struct + func (_m TaskNodeHandler_Abort) Return(_a0 error) *TaskNodeHandler_Abort + type TaskNodeHandler_Finalize struct + func (_m TaskNodeHandler_Finalize) Return(_a0 error) *TaskNodeHandler_Finalize + type TaskNodeHandler_FinalizeRequired struct + func (_m TaskNodeHandler_FinalizeRequired) Return(_a0 bool) *TaskNodeHandler_FinalizeRequired + type TaskNodeHandler_GetCatalogKey struct + func (_m TaskNodeHandler_GetCatalogKey) Return(_a0 catalog.Key, _a1 error) *TaskNodeHandler_GetCatalogKey + type TaskNodeHandler_Handle struct + func (_m TaskNodeHandler_Handle) Return(_a0 handler.Transition, _a1 error) *TaskNodeHandler_Handle + type TaskNodeHandler_IsCacheable struct + func (_m TaskNodeHandler_IsCacheable) Return(_a0 bool, _a1 bool, _a2 error) *TaskNodeHandler_IsCacheable + type TaskNodeHandler_Setup struct + func (_m TaskNodeHandler_Setup) Return(_a0 error) *TaskNodeHandler_Setup + type TaskNodeHandler_ValidateOutput struct + func (_m TaskNodeHandler_ValidateOutput) Return(_a0 *io.ExecutionError, _a1 error) *TaskNodeHandler_ValidateOutput