plugin

Apr 3, 2026

Changes in this version

+ func ComputeActionOutputPath(ctx context.Context, namespace, name, runOutputBase, actionName string, ...) (storage.DataReference, error)

Mar 2, 2026

Changes in this version

+ func NewSetupContext(kubeClient pluginsCore.KubeClient, secretManager pluginsCore.SecretManager, ...) pluginsCore.SetupContext

+ func NewTaskExecutionContext(taskAction *flyteorgv1.TaskAction, dataStore *storage.DataStore, ...) (*taskExecutionContext, error)

+ func NewTaskExecutionMetadata(ta *flyteorgv1.TaskAction) pluginsCore.TaskExecutionMetadata

+ type PluginRegistryIface interface

+ GetCorePlugins func() []pluginsCore.PluginEntry

+ GetK8sPlugins func() []k8sPlugin.PluginEntry

+ type PluginStateManager struct

+ func NewPluginStateManager(prevState []byte, prevVersion uint8) *PluginStateManager

+ func (m *PluginStateManager) Get(t interface{}) (uint8, error)

+ func (m *PluginStateManager) GetNewState() (stateBytes []byte, version uint8, written bool)

+ func (m *PluginStateManager) GetStateVersion() uint8

+ func (m *PluginStateManager) Put(stateVersion uint8, v interface{}) error

+ func (m *PluginStateManager) Reset() error

+ type Registry struct

+ func NewRegistry(setupCtx pluginsCore.SetupContext, pluginRegistry PluginRegistryIface) *Registry

+ func (r *Registry) Initialize(ctx context.Context) error

+ func (r *Registry) ResolvePlugin(taskType string) (pluginsCore.Plugin, error)