connector

Mar 28, 2025

Changes in this version

+ const ID

+ func RegisterConnectorPlugin(connectorService *ConnectorService)

+ func SetConfig(cfg *Config) error

+ type ClientSet struct

+ type Config struct

+ ConnectorDeployments map[string]*Deployment

+ ConnectorForTaskTypes map[string]string

+ DefaultConnector Deployment

+ PollInterval config.Duration

+ ResourceConstraints core.ResourceConstraintsSpec

+ SupportedTaskTypes []string

+ WebAPI webapi.PluginConfig

+ func GetConfig() *Config

+ type Connector struct

+ ConnectorDeployment *Deployment

+ IsSync bool

+ type ConnectorService struct

+ CorePlugin core.Plugin

+ func (p *ConnectorService) ContainTaskType(taskType string) bool

+ func (p *ConnectorService) SetSupportedTaskType(taskTypes []string)

+ type Deployment struct

+ DefaultServiceConfig string

+ DefaultTimeout config.Duration

+ Endpoint string

+ Insecure bool

+ Timeouts map[string]config.Duration

+ 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) ExecuteTaskSync(ctx context.Context, client service.SyncAgentServiceClient, ...) (webapi.ResourceMeta, webapi.Resource, 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 Registry map[string]map[int32]*Connector

+ type ResourceMetaWrapper struct

+ ConnectorResourceMeta []byte

+ OutputPrefix string

+ TaskCategory admin.TaskCategory

+ type ResourceWrapper struct

+ ConnectorError *admin.AgentError

+ CustomInfo *structpb.Struct

+ LogLinks []*flyteIdl.TaskLog

+ Message string

+ Outputs *flyteIdl.LiteralMap

+ Phase flyteIdl.TaskExecution_Phase

+ State admin.State

+ func (r ResourceWrapper) IsTerminal() bool