Versions in this module Expand all Collapse all v2 v2.0.0 Dec 22, 2025 Changes in this version + const ErrNotFound + type AutoRefresh interface + DeleteDelayed func(id ItemID) error + Get func(id ItemID) (Item, error) + GetOrCreate func(id ItemID, item Item) (Item, error) + Start func(ctx context.Context) error + func NewAutoRefreshBatchedCache(name string, createBatches CreateBatchesFunc, syncCb SyncFunc, ...) (AutoRefresh, error) + func NewAutoRefreshCache(name string, syncCb SyncFunc, syncRateLimiter workqueue.RateLimiter, ...) (AutoRefresh, error) + type Batch = []ItemWrapper + func SingleItemBatches(_ context.Context, snapshot []ItemWrapper) (batches []Batch, err error) + type CreateBatchesFunc func(ctx context.Context, snapshot []ItemWrapper) (batches []Batch, err error) + type InMemoryAutoRefresh struct + func NewInMemoryAutoRefresh(name string, syncCb SyncFunc, syncRateLimiter workqueue.RateLimiter, ...) (*InMemoryAutoRefresh, error) + func (w *InMemoryAutoRefresh) Delete(key interface{}) + func (w *InMemoryAutoRefresh) DeleteDelayed(id ItemID) error + func (w *InMemoryAutoRefresh) Get(id ItemID) (Item, error) + func (w *InMemoryAutoRefresh) GetOrCreate(id ItemID, item Item) (Item, error) + func (w *InMemoryAutoRefresh) Start(ctx context.Context) error + func (w *InMemoryAutoRefresh) Update(id ItemID, item Item) (ok bool) + type Item interface + IsTerminal func() bool + type ItemID = string + type ItemSyncResponse struct + Action SyncAction + ID ItemID + Item Item + type ItemWrapper interface + GetID func() ItemID + GetItem func() Item + type Option func(*Options) + func WithClock(clock clock.WithTicker) Option + func WithCreateBatchesFunc(createBatchesCb CreateBatchesFunc) Option + func WithSyncOnCreate(syncOnCreate bool) Option + type Options struct + type SyncAction int + const Unchanged + const Update + type SyncFunc func(ctx context.Context, batch Batch) (updatedBatch []ItemSyncResponse, err error) Other modules containing this package github.com/flyteorg/flyte/flytestdlib
Go to main page