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 ErrBuildPodTemplate + const ErrReplaceCmdTemplate + const JobIndexVarName + const KozmoK8sArrayIndexVarName + func GetK8sClient(config ClusterConfig) (client.Client, error) + func GetNewExecutorPlugin(ctx context.Context, iCtx core.SetupContext) (core.Plugin, error) + func IsResourceConfigSet(resourceConfig ResourceConfig) bool + func LaunchAndCheckSubTasksState(ctx context.Context, tCtx core.TaskExecutionContext, ...) (newState *arrayCore.State, externalResources []*core.ExternalResource, ...) + func NewKubeClientObj(c client.Client) core.KubeClient + func RemoteClusterConfig(host string, auth Auth) (*restclient.Config, error) + func TerminateSubTasks(ctx context.Context, tCtx core.TaskExecutionContext, ...) (*arrayCore.State, []*core.ExternalResource, error) + func TerminateSubTasksOnAbort(ctx context.Context, tCtx core.TaskExecutionContext, ...) error + type Auth struct + CertPath string + TokenPath string + Type string + func (auth Auth) GetCA() ([]byte, error) + func (auth Auth) GetToken() (string, error) + type ClusterConfig struct + Auth Auth + Enabled bool + Endpoint string + Name string + type Config struct + DefaultScheduler string + ErrorAssembler workqueue.Config + LogConfig LogConfig + MaxArrayJobSize int64 + MaxErrorStringLength int + NamespaceTemplate string + NodeSelector map[string]string + OutputAssembler workqueue.Config + RemoteClusterConfig ClusterConfig + ResourceConfig ResourceConfig + Tolerations []v1.Toleration + func GetConfig() *Config + func (cfg Config) GetPFlagSet(prefix string) *pflag.FlagSet + type Executor struct + func NewExecutor(kubeClient core.KubeClient, cfg *Config, scope promutils.Scope) (Executor, error) + func (Executor) GetProperties() core.PluginProperties + func (e Executor) Abort(ctx context.Context, tCtx core.TaskExecutionContext) error + func (e Executor) Finalize(ctx context.Context, tCtx core.TaskExecutionContext) error + func (e Executor) GetID() string + func (e Executor) Handle(ctx context.Context, tCtx core.TaskExecutionContext) (core.Transition, error) + func (e Executor) Start(ctx context.Context) error + type KubeClientObj struct + func (k KubeClientObj) GetCache() cache.Cache + func (k KubeClientObj) GetClient() client.Client + type LogConfig struct + Config logs.LogConfig + type ResourceConfig struct + Limit int + PrimaryLabel string + type SubTaskExecutionContext struct + func NewSubTaskExecutionContext(ctx context.Context, tCtx pluginsCore.TaskExecutionContext, ...) (SubTaskExecutionContext, error) + func (s SubTaskExecutionContext) InputReader() io.InputReader + func (s SubTaskExecutionContext) OutputWriter() io.OutputWriter + func (s SubTaskExecutionContext) PluginStateReader() pluginsCore.PluginStateReader + func (s SubTaskExecutionContext) TaskExecutionMetadata() pluginsCore.TaskExecutionMetadata + func (s SubTaskExecutionContext) TaskReader() pluginsCore.TaskReader + type SubTaskExecutionID struct + func NewSubTaskExecutionID(taskExecutionID pluginsCore.TaskExecutionID, executionIndex int, ...) SubTaskExecutionID + func (s SubTaskExecutionID) GetGeneratedName() string + func (s SubTaskExecutionID) GetLogSuffix() string + func (s SubTaskExecutionID) TemplateVarsByScheme() []tasklog.TemplateVar + type SubTaskExecutionMetadata struct + func NewSubTaskExecutionMetadata(taskExecutionMetadata pluginsCore.TaskExecutionMetadata, ...) (SubTaskExecutionMetadata, error) + func (s SubTaskExecutionMetadata) GetAnnotations() map[string]string + func (s SubTaskExecutionMetadata) GetLabels() map[string]string + func (s SubTaskExecutionMetadata) GetTaskExecutionID() pluginsCore.TaskExecutionID + func (s SubTaskExecutionMetadata) IsInterruptible() bool + type SubTaskReader struct + func (s SubTaskReader) Read(ctx context.Context) (*core.TaskTemplate, error)