checkpoints

type Checkpoint struct {
	Name              string    `json:"name" gorm:"primaryKey;autoIncrement:false"`
	Job               string    `json:"job" gorm:"primaryKey;autoIncrement:false"`
	LastCompletedTime time.Time `json:"lastCompletedTime" gorm:"type:timestamptz"`
}

type CheckpointQuery struct {
	Name string `json:"name,omitempty"`
	Job  string `json:"job,omitempty"`
}

type CheckpointRepository interface {
	database.Repository
	SetCheckpoint(checkpoint *Checkpoint) error
	ListCheckpoints() ([]*Checkpoint, error)
	QueryCheckpoints(query *CheckpointQuery) ([]*Checkpoint, error)
	GetCheckpoint(query *CheckpointQuery) (*Checkpoint, error)

	ResetAllCheckpoints(newCheckpointTime time.Time) error
	ResetCheckpoints(request *ResetCheckpointsRequest) error
	// EnforceMinimumCheckpointTime advances lingering checkpoints to the minimum, except the rows
	// named in excludeNames — rows a caller manages itself, where a checkpoint sitting in the past
	// is a deliberate instruction to re-meter rather than a leftover.
	EnforceMinimumCheckpointTime(minimum time.Time, excludeNames []string) error
}

type ListCheckpointsResult struct {
	Checkpoints []*Checkpoint `json:"checkpoints"`
}

type PostgresqlCheckpointRepository struct {
	database.Repository
	// contains filtered or unexported fields
}

type QueryCheckpointsRequest struct {
	CheckpointQuery
}

type QueryCheckpointsResult struct {
	Checkpoints []*Checkpoint `json:"checkpoints"`
}

type ResetCheckpointsRequest struct {
	NewCheckpointTime time.Time `json:"newCheckpointTime"`
	CheckpointQuery
}