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 + const IDMaxLength + const MaxPluginStateSizeBytes + func ComputePreviousCheckpointPath(ctx context.Context, length int, nCtx interfaces.NodeExecutionContext, ...) (storage.DataReference, error) + func ComputeRawOutputPrefix(ctx context.Context, length int, nCtx interfaces.NodeExecutionContext, ...) (io.RawOutputPaths, string, error) + func GetTaskExecutionIdentifier(nCtx interfaces.NodeExecutionContext) *core.TaskExecutionIdentifier + func ToTaskEventPhase(p pluginCore.Phase) core.TaskExecution_Phase + func ToTaskExecutionEvent(input ToTaskExecutionEventInputs) (*event.TaskExecutionEvent, error) + func ToTransitionType(ttype pluginCore.TransitionType) handler.TransitionType + func WranglePluginsAndGenerateFinalList(ctx context.Context, cfg *config.TaskPluginConfig, pr PluginRegistryIface, ...) (enabledPlugins []core.PluginEntry, defaultForTaskTypes map[pluginID][]taskType, ...) + type CacheContents struct + CompiledWorkflow *core.CompiledWorkflowClosure + WorkflowCRD *v1alpha1.KozmoWorkflow + type CodecVersion uint8 + const GobCodecVersion + type FutureFileReader struct + func NewRemoteFutureFileReader(ctx context.Context, dataDir storage.DataReference, store *storage.DataStore) (FutureFileReader, error) + func (f FutureFileReader) Cache(ctx context.Context, wf *v1alpha1.KozmoWorkflow, ...) error + func (f FutureFileReader) CacheExists(ctx context.Context) (bool, error) + func (f FutureFileReader) Exists(ctx context.Context) (bool, error) + func (f FutureFileReader) GetLoc() storage.DataReference + func (f FutureFileReader) Read(ctx context.Context) (*core.DynamicJobSpec, error) + func (f FutureFileReader) RetrieveCache(ctx context.Context) (CacheContents, error) + type Handler struct + func New(ctx context.Context, kubeClient executors.Client, ...) (*Handler, error) + func (t *Handler) FinalizeRequired() bool + func (t *Handler) GetCatalogKey(ctx context.Context, nCtx interfaces.NodeExecutionContext) (catalog.Key, error) + func (t *Handler) IsCacheable(ctx context.Context, nCtx interfaces.NodeExecutionContext) (bool, bool, error) + func (t *Handler) Setup(ctx context.Context, sCtx interfaces.SetupContext) error + func (t *Handler) ValidateOutput(ctx context.Context, nodeID v1alpha1.NodeID, i io.InputReader, ...) (*io.ExecutionError, error) + func (t Handler) Abort(ctx context.Context, nCtx interfaces.NodeExecutionContext, reason string) error + func (t Handler) Finalize(ctx context.Context, nCtx interfaces.NodeExecutionContext) error + func (t Handler) Handle(ctx context.Context, nCtx interfaces.NodeExecutionContext) (handler.Transition, error) + func (t Handler) ResolvePlugin(ctx context.Context, ttype string, executionConfig v1alpha1.ExecutionConfig) (pluginCore.Plugin, error) + type MetricKey = string + type PluginRegistryIface interface + GetCorePlugins func() []pluginCore.PluginEntry + GetK8sPlugins func() []pluginK8s.PluginEntry + type RemoteFileWorkflowStore struct + func NewRemoteWorkflowStore(store *storage.DataStore) RemoteFileWorkflowStore + func (r RemoteFileWorkflowStore) Exists(ctx context.Context, path storage.DataReference) (bool, error) + func (r RemoteFileWorkflowStore) GetCompiledWorkflow(ctx context.Context, source storage.DataReference) (*core.CompiledWorkflowClosure, error) + func (r RemoteFileWorkflowStore) GetWorkflowCRD(ctx context.Context, source storage.DataReference) (*v1alpha1.KozmoWorkflow, error) + func (r RemoteFileWorkflowStore) PutCompiledKozmoWorkflow(ctx context.Context, workflow *core.CompiledWorkflowClosure, ...) error + func (r RemoteFileWorkflowStore) PutKozmoWorkflowCRD(ctx context.Context, wf *v1alpha1.KozmoWorkflow, target storage.DataReference) error + type ToTaskExecutionEventInputs struct + ClusterID string + EventConfig *config.EventConfig + ExecContext executors.ExecutionContext + Info pluginCore.PhaseInfo + InputReader io.InputFilePaths + Inputs *core.LiteralMap + NodeExecutionMetadata interfaces.NodeExecutionMetadata + OccurredAt time.Time + OutputWriter io.OutputFilePaths + PluginID string + ResourcePoolInfo []*event.ResourcePoolInfo + TaskExecContext pluginCore.TaskExecutionContext + TaskType string
Go to main page