persist

Documentation

Index

• func PersistPacemaker(ctx context.Context, chPersist <-chan types.PersistentState, ...)
• func PersistTransmission(ctx context.Context, chPersist <-chan TransmissionDBUpdate, db types.Database, ...)
• type TransmissionDBUpdate

Functions

func PersistPacemaker

func PersistPacemaker(
	ctx context.Context,
	chPersist <-chan types.PersistentState,
	configDigest types.ConfigDigest,
	database types.Database,
	databaseTimeout time.Duration,
	logger loghelper.LoggerWithContext,
)

PersistPacemaker receives states from the pacemaker protocol it should persist to the db through chPersist and writes them to database.

func PersistTransmission

func PersistTransmission(
	ctx context.Context,
	chPersist <-chan TransmissionDBUpdate,
	db types.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
}