code: func (s *retentionEnforcer) getRetentionPeriodPerBucket() (map[platform.ID]time.Duration, error) {
  	ctx, cancel := context.WithTimeout(context.Background(), bucketAPITimeout)
  	defer cancel()
  	buckets, _, err := s.BucketService.FindBuckets(ctx, platform.BucketFilter{})
  	if err != nil {
  		return nil, err
  	}
  	rpByBucketID := make(map[platform.ID]time.Duration, len(buckets))
  	for _, bucket := range buckets {
  		rpByBucketID[bucket.ID] = bucket.RetentionPeriod
  	}
  	return rpByBucketID, nil
  }
docs: // getRetentionPeriodPerBucket returns a map of (bucket ID -> retention period)
  // for all buckets.