Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PersistTransmission ¶
func PersistTransmission( ctx context.Context, chPersist <-chan TransmissionDBUpdate, db ocr3types.Database, dbTimeout time.Duration, logger loghelper.LoggerWithContext, )
Persists state from the transmission protocol to the database to allow for recovery after restarts
Types ¶
type TransmissionDBUpdate ¶
type TransmissionDBUpdate struct {
Timestamp types.ReportTimestamp
PendingTransmission *types.PendingTransmission
}
Click to show internal directories.
Click to hide internal directories.