cache

Sep 25, 2019

Changes in this version

+ const ErrNotFound

+ type AutoRefresh interface

+ Get func(id ItemID) (Item, error)

+ GetOrCreate func(id ItemID, item Item) (Item, error)

+ Start func(ctx context.Context) error

+ func NewAutoRefreshBatchedCache(createBatches CreateBatchesFunc, syncCb SyncFunc, ...) (AutoRefresh, error)

+ func NewAutoRefreshCache(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 Item interface

+ type ItemID = string

+ type ItemSyncResponse struct

+ Action SyncAction

+ ID ItemID

+ Item Item

+ type ItemWrapper interface

+ GetID func() ItemID

+ GetItem func() Item

+ type SyncAction int

+ const Unchanged

+ const Update

+ type SyncFunc func(ctx context.Context, batch Batch) (updatedBatch []ItemSyncResponse, err error)