Versions in this module Expand all Collapse all v2 v2.0.8 Mar 17, 2026 v2.0.7 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)
Go to main page