- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 129 for getDest (0.12 sec)
-
cmd/warm-backend-azure.go
azMeta[k] = to.Ptr(v) } resp, err := az.clnt.UploadStream(ctx, az.Bucket, az.getDest(object), io.LimitReader(r, length), &azblob.UploadStreamOptions{ Concurrency: 4, AccessTier: az.tier(), // set tier if specified Metadata: azMeta, }) if err != nil { return "", azureToObjectError(err, az.Bucket, az.getDest(object)) } vid := "" if resp.VersionID != nil { vid = *resp.VersionID }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 7K bytes - Viewed (0) -
cmd/warm-backend-s3.go
func (s3 *warmBackendS3) ToObjectError(err error, params ...string) error { object := "" if len(params) >= 1 { object = params[0] } return ErrorRespToObjectError(err, s3.Bucket, s3.getDest(object)) } func (s3 *warmBackendS3) getDest(object string) string { destObj := object if s3.Prefix != "" { destObj = fmt.Sprintf("%s/%s", s3.Prefix, object) } return destObj }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Jun 08 16:13:30 UTC 2025 - 5.8K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
} func (gcs *warmBackendGCS) getDest(object string) string { destObj := object if gcs.Prefix != "" { destObj = fmt.Sprintf("%s/%s", gcs.Prefix, object) } return destObj } func (gcs *warmBackendGCS) PutWithMeta(ctx context.Context, key string, data io.Reader, length int64, meta map[string]string) (remoteVersionID, error) { object := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key)) w := object.NewWriter(ctx)Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 6.1K bytes - Viewed (0) -
cmd/warm-backend-minio.go
partSize, err := optimalPartSize(length) if err != nil { return remoteVersionID(""), err } res, err := m.client.PutObject(ctx, m.Bucket, m.getDest(object), r, length, minio.PutObjectOptions{ StorageClass: m.StorageClass, PartSize: uint64(partSize), DisableContentSha256: true, UserMetadata: meta, })
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 4K bytes - Viewed (1) -
src/test/java/org/codelibs/core/collection/SLinkedListTest.java
assertThat(e.getPrevious(), is(nullValue())); assertThat(e.getNext().getElement(), is("2")); e = list.getLastEntry(); assertThat(e.getNext(), is(nullValue())); assertThat(e.getPrevious().getElement(), is("2")); list.getEntry(1).remove(); assertThat(list.getFirst(), is("1")); assertThat(list.getLast(), is("3")); list.getLastEntry().remove();
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 8.3K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/ListAddAllAtIndexTester.java
"addAll(n, allPresent) should return true", getList().addAll(0, MinimalCollection.of(e0()))); expectAdded(0, e0()); } @ListFeature.Require(absent = SUPPORTS_ADD_WITH_INDEX) @CollectionSize.Require(absent = ZERO) public void testAddAllAtIndex_unsupportedAllPresent() { assertThrows( UnsupportedOperationException.class, () -> getList().addAll(0, MinimalCollection.of(e0()))); expectUnchanged(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Nov 14 23:40:07 UTC 2024 - 6.4K bytes - Viewed (0) -
src/test/java/jcifs/util/transport/RequestTest.java
void testGetNext() { // Test case for getNext method Request nextRequest = mock(Request.class); // Mock a chained request when(mockRequest.getNext()).thenReturn(nextRequest); Request actualNextRequest = mockRequest.getNext(); assertEquals(nextRequest, actualNextRequest, "Next request should match the mocked object."); verify(mockRequest, times(1)).getNext(); } @Test
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 3.6K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/HandlerTest.java
// Assert - Verify URL components assertEquals("smb", url1.getProtocol()); assertEquals("host", url1.getHost()); assertEquals(445, url1.getPort()); assertEquals("/share", url1.getPath()); assertEquals("smb", url2.getProtocol()); assertEquals("host", url2.getHost()); assertEquals(1234, url2.getPort()); assertEquals("/share/file.txt", url2.getPath());Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 5.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/ListRemoveTester.java
E duplicate = arrayAndDuplicate.duplicate; int firstIndex = getList().indexOf(duplicate); int initialSize = getList().size(); assertTrue("remove(present) should return true", getList().remove(duplicate)); assertTrue( "After remove(duplicate), a list should still contain the duplicate element", getList().contains(duplicate)); assertFalse(Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Nov 14 23:40:07 UTC 2024 - 2.6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/testers/ListAddAllAtIndexTester.java
"addAll(n, allPresent) should return true", getList().addAll(0, MinimalCollection.of(e0()))); expectAdded(0, e0()); } @ListFeature.Require(absent = SUPPORTS_ADD_WITH_INDEX) @CollectionSize.Require(absent = ZERO) public void testAddAllAtIndex_unsupportedAllPresent() { assertThrows( UnsupportedOperationException.class, () -> getList().addAll(0, MinimalCollection.of(e0()))); expectUnchanged(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Nov 14 23:40:07 UTC 2024 - 6.4K bytes - Viewed (0)