- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 518 for Ticket (0.11 sec)
-
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc
tf_gcs_filesystem::GCSFile* gcs_file, TF_Status* status) { std::string bucket, object; ParseGCSPath(path, false, &bucket, &object, status); if (TF_GetCode(status) != TF_OK) return -1; auto stream = gcs_file->gcs_client.ReadObject( bucket, object, gcs::ReadRange(offset, offset + buffer_size)); TF_SetStatusFromGCSStatus(stream.status(), status);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 23 06:55:53 UTC 2023 - 46.9K bytes - Viewed (0) -
cmd/object-api-datatypes.go
} // BucketInfo - represents bucket metadata. type BucketInfo struct { // Name of the bucket. Name string // Date and time when the bucket was created. Created time.Time Deleted time.Time // Bucket features enabled Versioning, ObjectLocking bool } // ObjectInfo - represents object metadata. type ObjectInfo struct { // Name of the bucket. Bucket string
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 20.9K bytes - Viewed (0) -
docs/bucket/replication/setup_ilm_expiry_replication.sh
./mc ready sitec ./mc ready sited ./mc mb sitea/bucket ./mc mb sitec/bucket ## Setup site replication ./mc admin replicate add sitea siteb --replicate-ilm-expiry sleep 10s ## Add warm tier ./mc ilm tier add minio sitea WARM-TIER --endpoint http://localhost:9006 --access-key minio --secret-key minio123 --bucket bucket ## Add ILM rules
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat May 18 18:19:01 UTC 2024 - 12.8K bytes - Viewed (0) -
internal/bucket/replication/replication_test.go
// destination bucket in config different from bucket specified destBucket: "destinationbucket", sameTarget: false, expectedParsingErr: nil,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 28 17:44:56 UTC 2024 - 32.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/SocketConnection.java
public SocketConnection(SocketChannel socket, MessageSerializer streamSerializer, StatefulSerializer<T> messageSerializer) { this.socket = socket; try { // NOTE: we use non-blocking IO as there is no reliable way when using blocking IO to shutdown reads while // keeping writes active. For example, Socket.shutdownInput() does not work on Windows. socket.configureBlocking(false);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 11.8K bytes - Viewed (0) -
cmd/api-response.go
} } // generates InitiateMultipartUploadResponse for given bucket, key and uploadID. func generateInitiateMultipartUploadResponse(bucket, key, uploadID string) InitiateMultipartUploadResponse { return InitiateMultipartUploadResponse{ Bucket: bucket, Key: key, UploadID: uploadID, } } // generates CompleteMultipartUploadResponse for given bucket, key, location and ETag.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 33.5K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
return } opts, err := getOpts(ctx, r, bucket, zipPath) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } getObjectInfo := objectAPI.GetObjectInfo // Check for auth type to return S3 compatible error. // type to return the correct error (NoSuchKey vs AccessDenied) if s3Error := checkRequestAuthType(ctx, r, policy.GetObjectAction, bucket, zipPath); s3Error != ErrNone {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.8K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
"github.com/minio/minio-go/v7/pkg/encrypt" "github.com/minio/minio-go/v7/pkg/tags" "github.com/minio/minio/internal/amztime" sse "github.com/minio/minio/internal/bucket/encryption" objectlock "github.com/minio/minio/internal/bucket/object/lock" "github.com/minio/minio/internal/bucket/replication" "github.com/minio/minio/internal/config/dns" "github.com/minio/minio/internal/config/storageclass" "github.com/minio/minio/internal/crypto"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 38.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlingInfoHelper.java
import org.opensearch.search.aggregations.AggregationBuilders; import org.opensearch.search.aggregations.BucketOrder; import org.opensearch.search.aggregations.bucket.terms.Terms; import org.opensearch.search.aggregations.bucket.terms.Terms.Bucket; import org.opensearch.search.aggregations.bucket.terms.TermsAggregationBuilder; public class CrawlingInfoHelper { private static final Logger logger = LogManager.getLogger(CrawlingInfoHelper.class);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 10.6K bytes - Viewed (0) -
src/time/tick_test.go
func BenchmarkTicker(b *testing.B) { benchmark(b, func(pb *testing.PB) { ticker := NewTicker(Nanosecond) for pb.Next() { <-ticker.C } ticker.Stop() }) } func BenchmarkTickerReset(b *testing.B) { benchmark(b, func(pb *testing.PB) { ticker := NewTicker(Nanosecond) for pb.Next() { ticker.Reset(Nanosecond * 2) } ticker.Stop() }) } func BenchmarkTickerResetNaive(b *testing.B) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0)