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 + var DefaultPluginConfig = PluginConfig + type AsyncPlugin interface + Create func(ctx context.Context, tCtx TaskExecutionContextReader) (resourceMeta ResourceMeta, optionalResource Resource, err error) + Delete func(ctx context.Context, tCtx DeleteContext) error + Get func(ctx context.Context, tCtx GetContext) (latest Resource, err error) + GetConfig func() PluginConfig + ResourceRequirements func(ctx context.Context, tCtx TaskExecutionContextReader) (namespace pluginsCore.ResourceNamespace, ...) + Status func(ctx context.Context, tCtx StatusContext) (phase pluginsCore.PhaseInfo, err error) + type CachingConfig struct + MaxSystemFailures int + ResyncInterval config.Duration + Size int + Workers int + type DeleteContext interface + Reason func() string + ResourceMeta func() ResourceMeta + type GetContext interface + ResourceMeta func() ResourceMeta + type PluginConfig struct + Caching CachingConfig + ReadRateLimiter RateLimiterConfig + ResourceMeta ResourceMeta + ResourceQuotas ResourceQuotas + WriteRateLimiter RateLimiterConfig + func (cfg PluginConfig) GetPFlagSet(prefix string) *pflag.FlagSet + type PluginEntry struct + DefaultForTaskTypes []pluginsCore.TaskType + ID pluginsCore.TaskType + IsDefault bool + PluginLoader PluginLoader + SupportedTaskTypes []pluginsCore.TaskType + type PluginLoader func(ctx context.Context, iCtx PluginSetupContext) (AsyncPlugin, error) + type PluginSetupContext interface + MetricsScope func() promutils.Scope + type RateLimiterConfig struct + Burst int + QPS int + type Resource = interface + type ResourceMeta = interface + type ResourceQuotas map[core.ResourceNamespace]int + type StatusContext interface + Resource func() Resource + ResourceMeta func() ResourceMeta + type SyncPlugin interface + Do func(ctx context.Context, tCtx TaskExecutionContext) (phase pluginsCore.PhaseInfo, err error) + GetConfig func() PluginConfig + type TaskExecutionContext interface + DataStore func() *storage.DataStore + MaxDatasetSizeBytes func() int64 + type TaskExecutionContextReader interface + InputReader func() io.InputReader + OutputWriter func() io.OutputWriter + SecretManager func() pluginsCore.SecretManager + TaskExecutionMetadata func() pluginsCore.TaskExecutionMetadata + TaskReader func() pluginsCore.TaskReader
Go to main page