agent

Sep 22, 2023

Changes in this version

+ type SupportedTaskTypes []TaskType

+ type TaskType = string

Jul 31, 2023

Changes in this version

+ type Agent struct

+ DefaultServiceConfig string

+ DefaultTimeout config.Duration

+ Endpoint string

+ Insecure bool

+ Timeouts map[string]config.Duration

type Config

+ AgentForTaskTypes map[string]string

+ Agents map[string]*Agent

+ DefaultAgent Agent

Jun 5, 2023

Changes in this version

+ func RegisterAgentPlugin()

+ func SetConfig(cfg *Config) error

+ type Config struct

+ DefaultGrpcEndpoint string

+ EndpointForTaskTypes map[string]string

+ ResourceConstraints core.ResourceConstraintsSpec

+ SupportedTaskTypes []string

+ WebAPI webapi.PluginConfig

+ func GetConfig() *Config

+ type GetClientFunc func(ctx context.Context, endpoint string, ...) (service.AsyncAgentServiceClient, error)

+ 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

+ Outputs *flyteIdl.LiteralMap

+ State admin.State