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 + func RegisterAgentPlugin() + func SetConfig(cfg *Config) error + type Agent struct + DefaultServiceConfig string + DefaultTimeout config.Duration + Endpoint string + Insecure bool + Timeouts map[string]config.Duration + type ClientSet struct + type Config struct + AgentForTaskTypes map[string]string + Agents map[string]*Agent + DefaultAgent Agent + ResourceConstraints core.ResourceConstraintsSpec + SupportedTaskTypes []string + WebAPI webapi.PluginConfig + func GetConfig() *Config + type Plugin struct + func (p Plugin) Create(ctx context.Context, taskCtx webapi.TaskExecutionContextReader) (webapi.ResourceMeta, webapi.Resource, error) + func (p Plugin) Delete(ctx context.Context, taskCtx webapi.DeleteContext) error + func (p Plugin) Get(ctx context.Context, taskCtx webapi.GetContext) (latest webapi.Resource, err error) + func (p Plugin) GetConfig() webapi.PluginConfig + func (p Plugin) ResourceRequirements(_ context.Context, _ webapi.TaskExecutionContextReader) (namespace core.ResourceNamespace, constraints core.ResourceConstraintsSpec, ...) + func (p Plugin) Status(ctx context.Context, taskCtx webapi.StatusContext) (phase core.PhaseInfo, err error) + type ResourceMetaWrapper struct + AgentResourceMeta []byte + OutputPrefix string + TaskType string + Token string + type ResourceWrapper struct + LogLinks []*kozmoIdl.TaskLog + Message string + Outputs *kozmoIdl.LiteralMap + Phase kozmoIdl.TaskExecution_Phase + State admin.State