Versions in this module Expand all Collapse all v0 v0.0.2 Jun 23, 2020 v0.0.1 Jun 23, 2020 Changes in this version + var DeleteObjectTimeout = 5 * time.Minute + var GetObjectTimeout = 5 * time.Minute + var ListFilesTimeout = 10 * time.Minute + var WriteObjectTimeout = 5 * time.Minute + func Retry(attempts int, sleep time.Duration, callback func() error) (err error) + type Bundle struct + func NewBundle(lowerBlockNum, chunkSize uint64) *Bundle + type Merger struct + func NewMerger(sourceStore dstore.Store, destStore dstore.Store, ...) *Merger + func (m *Merger) CacheInvalid() bool + func (m *Merger) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error) + func (m *Merger) FindNextBaseBlock() (uint64, error) + func (m *Merger) Launch() + func (m *Merger) PreMergedBlocks(ctx context.Context, req *pbmerge.Request) (*pbmerge.Response, error) + func (m *Merger) SetupBundle(start, stop uint64) + type OneBlockFile struct + type SeenBlockCache struct + HighestSeen uint64 + M map[string]bool + func NewSeenBlockCache(filename string, keepSize uint64) (c *SeenBlockCache) + func (c *SeenBlockCache) Add(filename string) + func (c *SeenBlockCache) IsTooOld(num uint64) bool + func (c *SeenBlockCache) Reset() + func (c *SeenBlockCache) Save() error + func (c *SeenBlockCache) SeenBefore(filename string) bool + func (c *SeenBlockCache) Truncate()