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 + const BadReturnCodeError + func CreateRemotePlugin(pluginEntry webapi.PluginEntry) core.PluginEntry + type CacheItem struct + Resource webapi.Resource + func (c CacheItem) IsTerminal() bool + type Client interface + Get func(ctx context.Context, tCtx webapi.GetContext) (latest webapi.Resource, err error) + Status func(ctx context.Context, tCtx webapi.StatusContext) (phase core.PhaseInfo, err error) + type CorePlugin struct + func (c CorePlugin) Abort(ctx context.Context, tCtx core.TaskExecutionContext) error + func (c CorePlugin) Finalize(ctx context.Context, tCtx core.TaskExecutionContext) error + func (c CorePlugin) GetID() string + func (c CorePlugin) GetProperties() core.PluginProperties + func (c CorePlugin) Handle(ctx context.Context, tCtx core.TaskExecutionContext) (core.Transition, error) + type Metrics struct + AllocationGranted labeled.Counter + AllocationNotGranted labeled.Counter + FailedUnmarshalState labeled.Counter + ResourceReleaseFailed labeled.Counter + ResourceReleased labeled.Counter + ResourceWaitTime prometheus.Summary + Scope promutils.Scope + SucceededUnmarshalState labeled.StopWatch + type Phase int + const PhaseAllocationTokenAcquired + const PhaseNotStarted + const PhaseResourcesCreated + const PhaseSucceeded + const PhaseSystemFailure + const PhaseUserFailure + func PhaseString(s string) (Phase, error) + func PhaseValues() []Phase + func ToPluginPhase(s core.Phase) (Phase, error) + func (i Phase) IsAPhase() bool + func (i Phase) IsTerminal() bool + func (i Phase) String() string + type ResourceCache struct + func NewResourceCache(ctx context.Context, name string, client Client, cfg webapi.CachingConfig, ...) (ResourceCache, error) + func (q *ResourceCache) SyncResource(ctx context.Context, batch cache.Batch) (updatedBatch []cache.ItemSyncResponse, err error) + type State struct + AllocationTokenRequestStartTime time.Time + CreationFailureCount int + ErrorMessage string + Phase Phase + ResourceMeta webapi.ResourceMeta + SyncFailureCount int