Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // Module wires the invocation log pruner into the fx graph and registers // its cron job when a retention window is configured. Module = fx.Module( "vef:integration:worker", fx.Provide(NewLogPruner), fx.Invoke(registerJobs), ) )
Functions ¶
This section is empty.
Types ¶
type LogPruner ¶
type LogPruner struct {
// contains filtered or unexported fields
}
LogPruner deletes invocation log rows older than the configured retention window. Deletion by cutoff is idempotent, so concurrent runs across replicas are harmless and no distributed lock is needed.
func NewLogPruner ¶
func NewLogPruner(db orm.DB, cfg *config.IntegrationConfig) *LogPruner
NewLogPruner builds the pruner from the configured retention.
Source Files
Click to show internal directories.
Click to hide internal directories.