grpc

Apr 21, 2023

Changes in this version

+ 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.ExternalPluginServiceClient, 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

+ JobID string

+ OutputPrefix string

+ TaskType string

+ Token string

+ type ResourceWrapper struct

+ Outputs *flyteIdl.LiteralMap

+ State service.State