v1

func ClearRegistry ¶

func ClearRegistry(_ context.Context) error

Clears all registered plugins. This should only be called after all packages/plugins have been safely loaded. Otherwise, init-based registrations will sneak through.

func GetAllTaskTypeExecutors ¶

func GetAllTaskTypeExecutors() map[types.TaskType]types.Executor

func GetTaskExecutor ¶

func GetTaskExecutor(taskType types.TaskType) (types.Executor, error)

func K8sRegisterAsDefault ¶

func K8sRegisterAsDefault(id string, resourceToWatch runtime.Object, resyncPeriod time.Duration, handler flytek8s.K8sResourceHandler) error

func K8sRegisterForTaskTypes ¶

func K8sRegisterForTaskTypes(id string, resourceToWatch runtime.Object, resyncPeriod time.Duration, handler flytek8s.K8sResourceHandler, taskTypes ...types.TaskType) error

func ListAllTaskExecutors ¶

func ListAllTaskExecutors() []types.Executor

func RegisterAsDefault ¶

func RegisterAsDefault(executor types.Executor) error

func RegisterForTaskTypes ¶

func RegisterForTaskTypes(executor types.Executor, taskTypes ...types.TaskType) error

func RegisterLoader ¶

func RegisterLoader(fn PluginLoaderFn)

Registers a plugin loader to be called when it's safe to perform plugin initialization logic. This function is NOT thread-safe and is expected to be called in an init() function (which runs in a single thread).

func RunAllLoaders ¶

func RunAllLoaders(ctx context.Context) error

Runs all plugin loader functions and errors out if any of the loaders fails to finish successfully.