- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for GcsClient (0.17 sec)
-
platforms/software/resources-gcs/src/main/java/org/gradle/internal/resource/transport/gcp/gcs/GcsClient.java
import java.util.ArrayList; import java.util.List; import static java.util.Collections.singletonList; public class GcsClient { private static final Logger LOGGER = LoggerFactory.getLogger(GcsClient.class); private final Storage storage; public static GcsClient create(GcsConnectionProperties gcsConnectionProperties) throws GeneralSecurityException, IOException {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 22 11:17:20 UTC 2024 - 7.9K bytes - Viewed (0) -
platforms/software/resources-gcs/src/main/java/org/gradle/internal/resource/transport/gcp/gcs/GcsResourceConnector.java
private final GcsClient gcsClient; public GcsResourceConnector(GcsClient gcsClient) { this.gcsClient = gcsClient; } @Nullable @Override public List<String> list(ExternalResourceName parent) throws ResourceException { LOGGER.debug("Listing parent resources: {}", parent); return gcsClient.list(parent.getUri()); } @Nullable
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 3.3K bytes - Viewed (0) -
platforms/software/resources-gcs/src/test/groovy/org/gradle/internal/resource/transport/gcp/gcs/GcsResourceConnectorTest.groovy
def name = new ExternalResourceName(uri) def "should list resources"() { GcsClient gcsClient = Mock() when: new GcsResourceConnector(gcsClient).list(name) then: 1 * gcsClient.list(uri) } def "should get a resource"() { GcsClient gcsClient = Mock { 1 * getResource(uri) >> new StorageObject() } when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 2.2K bytes - Viewed (0) -
platforms/software/resources-gcs/src/test/groovy/org/gradle/internal/resource/transport/gcp/gcs/GcsClientTest.groovy
} when: gcsClient.put(Mock(InputStream), 0, uri) then: def ex = thrown(ResourceException) ex.message.startsWith("Could not write to resource 'https://somehost/file.txt'") } def "should not fail on GcsClient.list() returning null"() { def gcsStorageClient = Mock(Storage) GcsClient gcsClient = new GcsClient(gcsStorageClient)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 5.4K bytes - Viewed (0) -
platforms/software/resources-gcs/src/integTest/groovy/org/gradle/integtests/resource/gcs/GcsClientIntegrationTest.groovy
builder.setServicePath("/") GcsClient gcsClient = new GcsClient(builder.build()) def uri = new URI("gcs://${bucketName}/maven/release/$FILE_NAME") when: server.stubPutFile(file, bucketName) def stream = new FileInputStream(file) then: gcsClient.put(stream, file.length(), uri) when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 4.4K bytes - Viewed (0) -
platforms/software/resources-gcs/src/main/java/org/gradle/internal/resource/transport/gcp/gcs/GcsResource.java
public class GcsResource implements ExternalResourceReadResponse { private final GcsClient gcsClient; private final StorageObject gcsObject; private final URI uri; public GcsResource(GcsClient gcsClient, StorageObject gcsObject, URI uri) { this.gcsClient = gcsClient; this.gcsObject = gcsObject; this.uri = uri; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 1.7K bytes - Viewed (0) -
platforms/software/resources-gcs/src/test/groovy/org/gradle/internal/resource/transport/gcp/gcs/GcsResourceTest.groovy
storageObject.setSize(BigInteger.ONE) storageObject.setContentType(contentType) storageObject.setEtag(Integer.toString(5)) when: def metaData = new GcsResource(Mock(GcsClient), storageObject, uri).getMetaData() then: metaData != null metaData.location == uri metaData.lastModified == new Date(lastModified.value)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/software/resources-gcs/src/main/java/org/gradle/internal/resource/transport/gcp/gcs/GcsConnectorFactory.java
return emptySet(); } @Override public ExternalResourceConnector createResourceConnector(ResourceConnectorSpecification connectionDetails) { try { return new GcsResourceConnector(GcsClient.create(new GcsConnectionProperties())); } catch (Exception e) { throw UncheckedException.throwAsUncheckedException(e); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/volume/csi/expander.go
} return c.nodeExpandWithClient(resizeOptions, csiSource, csClient, fsVolume) } func (c *csiPlugin) nodeExpandWithClient( resizeOptions volume.NodeResizeOptions, csiSource *api.CSIPersistentVolumeSource, csClient csiClient, fsVolume bool) (bool, error) { driverName := csiSource.Driver
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 31 17:23:56 UTC 2024 - 4.6K bytes - Viewed (0) -
pkg/volume/csi/expander_test.go
DeviceStagePath: "/foo/bar", DevicePath: "/mnt/foobar", } csiSource, _ := getCSISourceFromSpec(resizeOptions.VolumeSpec) csClient := setupClientWithExpansion(t, tc.nodeStageSet, tc.nodeExpansion) fakeCSIClient, _ := csClient.(*fakeCsiDriverClient) fakeNodeClient := fakeCSIClient.nodeClient if tc.enableCSINodeExpandSecret {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 03:58:36 UTC 2023 - 6.6K bytes - Viewed (0)