diff --git a/core/services/ocr2/plugins/ccip/internal/ccipdata/reader.go b/core/services/ocr2/plugins/ccip/internal/ccipdata/reader.go index aae0989c7d..3f57d419e1 100644 --- a/core/services/ocr2/plugins/ccip/internal/ccipdata/reader.go +++ b/core/services/ocr2/plugins/ccip/internal/ccipdata/reader.go @@ -29,18 +29,14 @@ const ( // be able to bring back processing without replaying any logs from chain. You can read that param as // "how long CCIP can be down and still be able to process all the messages after getting back to life". // Breaching this threshold would require replaying chain using LogPoller from the beginning of the outage. - - CommitExecLogsRetention = 3 * time.Hour // 3 hours for testing TODO: REMOVE FOR PRODUCTION! - + CommitExecLogsRetention = 30 * 24 * time.Hour // 30 days // CacheEvictionLogsRetention defines the duration for which logs used for caching on-chain data are kept. // Restarting node clears the cache entirely and rebuilds it from scratch by fetching data from chain, // so we don't need to keep these logs for very long. All events relying on cache.NewLogpollerEventsBased should use this retention. - - CacheEvictionLogsRetention = 1 * time.Hour // 1 hour for testing TODO: REMOVE FOR PRODUCTION! - + CacheEvictionLogsRetention = 7 * 24 * time.Hour // 7 days // PriceUpdatesLogsRetention defines the duration for which logs with price updates are kept. // These logs are emitted whenever the token price or gas price is updated and Commit scans very small time windows (e.g. 2 hours) - PriceUpdatesLogsRetention = 5 * time.Minute // 5 minutes for testing TODO: REMOVE FOR PRODUCTION! + PriceUpdatesLogsRetention = 1 * 24 * time.Hour // 1 day ) type Event[T any] struct {