try {
            final Bucket existingBucket = storage.get(bucket);
            if (existingBucket == null) {
                storage.create(BucketInfo.newBuilder(bucket).build());
                logger.info("Created storage bucket: {}", bucket);
            }
        } catch (final Exception e) {
            logger.warn("Failed to ensure bucket exists: {}", bucket, e);
        }
    }

    @Override

        assertTrue(protocolHelper.isValidFileProtocol("s3://bucket/path/to/file"));
        assertTrue(protocolHelper.isValidFileProtocol("gcs://bucket/path/to/file"));
        assertTrue(protocolHelper.isValidFileProtocol("s3://my-bucket/"));
        assertTrue(protocolHelper.isValidFileProtocol("gcs://my-bucket/folder/document.pdf"));

        assertFalse(protocolHelper.isValidWebProtocol("s3://bucket/path"));

            s3Client.headBucket(request);
        } catch (final NoSuchBucketException e) {
            try {
                final CreateBucketRequest createRequest = CreateBucketRequest.builder().bucket(bucket).build();
                s3Client.createBucket(createRequest);
                logger.info("Created storage bucket: {}", bucket);
            } catch (final Exception e1) {

        // Various GCS bucket and path formats
        assertEquals("gcs://bucket/", wizardAction.convertCrawlingPath("gcs://bucket/"));
        assertEquals("gcs://my-bucket/", wizardAction.convertCrawlingPath("gcs://my-bucket/"));
        assertEquals("gcs://bucket.with.dots/path", wizardAction.convertCrawlingPath("gcs://bucket.with.dots/path"));

        url = "s3://my-bucket/path/to/file";
        exp = "my-bucket";
        assertEquals(exp, transformer.getHostOnFile(url));

        url = "gcs://my-bucket/path/to/file";
        exp = "my-bucket";
        assertEquals(exp, transformer.getHostOnFile(url));

        url = "s3://bucket-with-dashes/file";
        exp = "bucket-with-dashes";

                }
            }
        }
    }

    /**
     * Parses a GCS path into bucket name and object path components.
     * @param path the GCS path to parse (format: bucket/object/path)
     * @return an array containing the bucket name and object path
     * @throws CrawlingAccessException if the path format is invalid
     */
    protected String[] parsePath(final String path) {

        assertTrue(goAction.isFileSystemPath("s3://my-bucket-name/deep/nested/path/file.txt"));
        assertTrue(goAction.isFileSystemPath("s3://bucket-with-dashes/file"));
    }

    @Test
    public void test_isFileSystemPath_gcs_protocol() {
        assertTrue(goAction.isFileSystemPath("gcs://bucket/path/to/file.txt"));
        assertTrue(goAction.isFileSystemPath("gcs://my-bucket/folder/document.pdf"));

	// expirable options
	mu   sync.RWMutex
	ttl  time.Duration
	done chan struct{}

	// buckets for expiration
	buckets []bucket[K, V]
	// uint8 because it's number between 0 and numBuckets
	nextCleanupBucket uint8
}

// bucket is a container for holding entries to be expired
type bucket[K comparable, V any] struct {
	entries     map[K]*Entry[K, V]
	newestEntry time.Time
}

            entry = entry.successorInValueSet) {
          int bucket = entry.smearedValueHash & mask;
          entry.nextInValueBucket = hashTable[bucket];
          hashTable[bucket] = entry;
        }
      }
    }

    @CanIgnoreReturnValue
    @Override
    public boolean remove(@Nullable Object o) {
      int smearedHash = smearedHash(o);
      int bucket = smearedHash & mask();
      ValueEntry<K, V> prev = null;

            entry = entry.successorInValueSet) {
          int bucket = entry.smearedValueHash & mask;
          entry.nextInValueBucket = hashTable[bucket];
          hashTable[bucket] = entry;
        }
      }
    }

    @CanIgnoreReturnValue
    @Override
    public boolean remove(@Nullable Object o) {
      int smearedHash = smearedHash(o);
      int bucket = smearedHash & mask();
      ValueEntry<K, V> prev = null;