atxsync

Documentation

Index

• func Clear(db sql.Executor) error
• func GetRequest(db sql.Executor, epoch types.EpochID) (time.Time, int64, int64, error)
• func GetSyncState(db sql.Executor, epoch types.EpochID) (map[types.ATXID]int, error)
• func SaveRequest(db sql.Executor, epoch types.EpochID, timestamp time.Time, ...) error
• func SaveSyncState(db sql.Executor, epoch types.EpochID, states map[types.ATXID]int, max int) error

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 GetSyncState

func GetSyncState(db sql.Executor, epoch types.EpochID) (map[types.ATXID]int, 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 map[types.ATXID]int, max int) error