Versions in this module Expand all Collapse all v1 v1.0.1 Jan 30, 2026 v1.0.0 Jan 28, 2026 Changes in this version + const DefaultCheckpointName + type Checkpoint struct + Job string + LastCompletedTime time.Time + Name string + type CheckpointQuery struct + Job string + Name string + type CheckpointRepository interface + EnforceMinimumCheckpointTime func(minimum time.Time) error + GetCheckpoint func(query *CheckpointQuery) (*Checkpoint, error) + ListCheckpoints func() ([]*Checkpoint, error) + QueryCheckpoints func(query *CheckpointQuery) ([]*Checkpoint, error) + ResetAllCheckpoints func(newCheckpointTime time.Time) error + ResetCheckpoints func(request *ResetCheckpointsRequest) error + SetCheckpoint func(checkpoint *Checkpoint) error + func NewPostgresqlCheckpointRepository() CheckpointRepository + type ListCheckpointsResult struct + Checkpoints []*Checkpoint + type PostgresqlCheckpointRepository struct + func (r *PostgresqlCheckpointRepository) EnforceMinimumCheckpointTime(minimum time.Time) error + func (r *PostgresqlCheckpointRepository) GetCheckpoint(query *CheckpointQuery) (*Checkpoint, error) + func (r *PostgresqlCheckpointRepository) Initialize(connection database.Connection) error + func (r *PostgresqlCheckpointRepository) ListCheckpoints() ([]*Checkpoint, error) + func (r *PostgresqlCheckpointRepository) QueryCheckpoints(query *CheckpointQuery) ([]*Checkpoint, error) + func (r *PostgresqlCheckpointRepository) ResetAllCheckpoints(newCheckpointTime time.Time) error + func (r *PostgresqlCheckpointRepository) ResetCheckpoints(request *ResetCheckpointsRequest) error + func (r *PostgresqlCheckpointRepository) SetCheckpoint(checkpoint *Checkpoint) error + type QueryCheckpointsRequest struct + type QueryCheckpointsResult struct + Checkpoints []*Checkpoint + type ResetCheckpointsRequest struct + NewCheckpointTime time.Time
Go to main page