atxsync

Documentation

Index

• func Clear(db sql.Executor) error
• func GetRequest(db sql.Executor, epoch types.EpochID) (time.Time, int64, int64, error)
• func SaveRequest(db sql.Executor, epoch types.EpochID, timestamp time.Time, ...) error
• func SaveSyncState(db sql.Executor, epoch types.EpochID, states EpochSyncState, max int) error
• type EpochSyncState
  • func GetSyncState(db sql.Executor, epoch types.EpochID) (EpochSyncState, error)
• type IDSyncState
  • func (s *IDSyncState) TriesPersisted() bool

Functions

func Clear

func Clear(db sql.Executor) error

func GetRequest

func GetRequest(db sql.Executor, epoch types.EpochID) (time.Time, int64, int64, error)

func SaveRequest

func SaveRequest(db sql.Executor, epoch types.EpochID, timestamp time.Time, total, downloaded int64) error

func SaveSyncState

func SaveSyncState(db sql.Executor, epoch types.EpochID, states EpochSyncState, max int) error

Types

type EpochSyncState

type EpochSyncState = map[types.ATXID]*IDSyncState

func GetSyncState

func GetSyncState(db sql.Executor, epoch types.EpochID) (EpochSyncState, error)

type IDSyncState

type IDSyncState struct {
	Tries int
	// contains filtered or unexported fields
}

IDSyncState tracks how many times we tried to sync an ATX.

func (*IDSyncState) TriesPersisted

func (s *IDSyncState) TriesPersisted() bool

TriesPersisted returns true if the number of tries is equal to the number of persisted tries.