@Override
    public Collection<RegisteredService> load() {
        val buckets = cloudStorage.list(Storage.BucketListOption.prefix(BUCKET_PREFIX));
        return buckets.streamAll()
            .map(bucket -> {
                val bucketName = bucket.getName();
                LOGGER.debug("Loading services from bucket [{}]", bucketName);
                return cloudStorage.list(bucketName).streamAll()
                    .map(blob -> {
                        val content = blob.getContent();
                        val body = new String(content, StandardCharsets.UTF_8);
                        return serializer.from(body);
                    })
                    .toList();
            })
            .flatMap(Collection::stream)
            .peek(this::invokeServiceRegistryListenerPostLoad)
            .collect(Collectors.toSet());
    }
This is {@link GoogleCloudStorageServiceRegistry}.

@author Misagh Moayyed
@since 7.2.0
support/cas-server-support-gcp-storage-service-registry/src/main/java/org/apereo/cas/services/GoogleCloudStorageServiceRegistry.java