Versions in this module Expand all Collapse all v0 v0.7.4 May 29, 2018 Changes in this version + type Breadcrumb struct + Deltas []syncproto.SerializedUpdate + KVs *ctrie.Ctrie + SequenceNumber uint64 + SyncStatus api.SyncStatus + Timestamp time.Time + func (b *Breadcrumb) Next(ctx context.Context) (*Breadcrumb, error) + type Cache struct + func New(config Config) *Cache + func (c *Cache) CurrentBreadcrumb() *Breadcrumb + func (c *Cache) OnStatusUpdated(status api.SyncStatus) + func (c *Cache) OnUpdates(updates []api.Update) + func (c *Cache) Start(ctx context.Context) + type Config struct + HealthAggregator healthAggregator + MaxBatchSize int + WakeUpInterval time.Duration + func (config *Config) ApplyDefaults()
Go to main page