persist

Documentation

Index

• func PersistTransmission(ctx context.Context, chPersist <-chan TransmissionDBUpdate, ...)
• type TransmissionDBUpdate

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
}