Documentation ¶
Index ¶
- Variables
- func Retry(attempts int, sleep time.Duration, callback func() error) (err error)
- type Bundle
- type 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
- type SeenBlockCache
Constants ¶
This section is empty.
Variables ¶
View Source
var DeleteObjectTimeout = 5 * time.Minute
View Source
var GetObjectTimeout = 5 * time.Minute
View Source
var ListFilesTimeout = 10 * time.Minute
View Source
var WriteObjectTimeout = 5 * time.Minute
Functions ¶
Types ¶
type Merger ¶
func (*Merger) CacheInvalid ¶
func (*Merger) Check ¶
func (m *Merger) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error)
func (*Merger) FindNextBaseBlock ¶
findNextBaseBlock will return an error if there is a gap found ...
func (*Merger) PreMergedBlocks ¶
func (*Merger) SetupBundle ¶
type OneBlockFile ¶
type OneBlockFile struct {
// contains filtered or unexported fields
}
type SeenBlockCache ¶
type SeenBlockCache struct { M map[string]bool HighestSeen uint64 // contains filtered or unexported fields }
func NewSeenBlockCache ¶
func NewSeenBlockCache(filename string, keepSize uint64) (c *SeenBlockCache)
func (*SeenBlockCache) Add ¶
func (c *SeenBlockCache) Add(filename string)
func (*SeenBlockCache) IsTooOld ¶
func (c *SeenBlockCache) IsTooOld(num uint64) bool
func (*SeenBlockCache) Reset ¶
func (c *SeenBlockCache) Reset()
func (*SeenBlockCache) Save ¶
func (c *SeenBlockCache) Save() error
func (*SeenBlockCache) SeenBefore ¶
func (c *SeenBlockCache) SeenBefore(filename string) bool
func (*SeenBlockCache) Truncate ¶
func (c *SeenBlockCache) Truncate()
Source Files ¶
Click to show internal directories.
Click to hide internal directories.