- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 782 for Ticket (0.06 sec)
-
docs/bucket/lifecycle/setup_ilm_transition.sh
./mc ready siteb ./mc mb --ignore-existing sitea/bucket ./mc mb --ignore-existing siteb/bucket sleep 10s ## Add warm tier ./mc ilm tier add minio sitea WARM-TIER --endpoint http://localhost:9004 --access-key minioadmin --secret-key minioadmin --bucket bucket ## Add ILM rules ./mc ilm add sitea/bucket --transition-days 0 --transition-tier WARM-TIER ./mc ilm rule list sitea/bucket ./mc cp README.md sitea/bucket/README.md
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 2.8K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/RecordedRequestTest.kt
import java.net.InetAddress import java.net.Socket import okhttp3.Headers import okhttp3.Headers.Companion.headersOf import okhttp3.internal.EMPTY_HEADERS import okio.Buffer import org.junit.jupiter.api.Test import org.junit.jupiter.api.Timeout @Timeout(30) class RecordedRequestTest { private val headers: Headers = EMPTY_HEADERS @Test fun testIPv4() { val socket = FakeSocket(
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheRefreshTest.java
public void testAutoRefresh() { FakeTicker ticker = new FakeTicker(); IncrementingLoader loader = incrementingLoader(); LoadingCache<Integer, Integer> cache = CacheBuilder.newBuilder() .refreshAfterWrite(3, MILLISECONDS) .expireAfterWrite(6, MILLISECONDS) .lenientParsing() .ticker(ticker) .build(loader); int expectedLoads = 0;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 3.9K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor_test.go
m1MiBPS.incrementBytes(oneMiB) test1Want := make(map[BucketOptions]Details) test1Want[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{LimitInBytesPerSecond: 1024 * 1024, CurrentBandwidthInBytesPerSecond: 0} test1Want2 := make(map[BucketOptions]Details) test1Want2[BucketOptions{Name: "bucket", ReplicationARN: "arn"}] = Details{ LimitInBytesPerSecond: 1024 * 1024,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 06 03:21:59 UTC 2023 - 4.3K bytes - Viewed (0) -
cmd/tier-sweeper.go
TransitionVersionID string RemoteObject string } // newObjSweeper returns an objSweeper for a given bucket and object. // It initializes the versioning information using bucket name. func newObjSweeper(bucket, object string) *objSweeper { return &objSweeper{ Object: object, Bucket: bucket, } } // WithVersion sets the version ID from v func (os *objSweeper) WithVersion(vid string) *objSweeper {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Apr 17 05:09:58 UTC 2024 - 4.7K bytes - Viewed (0) -
docs/debugging/s3-check-md5/main.go
flag.StringVar(&accessKey, "access-key", "Q3AM3UQ867SPQQA43P2F", "S3 Access Key") flag.StringVar(&secretKey, "secret-key", "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG", "S3 Secret Key") flag.StringVar(&bucket, "bucket", "", "Select a specific bucket") flag.StringVar(&prefix, "prefix", "", "Select a prefix") flag.BoolVar(&debug, "debug", false, "Prints HTTP network calls to S3 endpoint") flag.BoolVar(&versions, "versions", false, "Verify all versions")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Feb 17 01:15:57 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/sts-handlers_test.go
func (s *TestSuiteIAM) TestSTSServiceAccountsWithUsername(c *check) { ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) defer cancel() bucket := "dillon-bucket" err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{}) if err != nil { c.Fatalf("bucket create error: %v", err) } // Create policy policy := "mypolicy-username" policyBytes := []byte(`{ "Version": "2012-10-17", "Statement": [
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 23:40:37 UTC 2024 - 97.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbTransport.java
do { /* These Socket constructors attempt to connect before SO_TIMEOUT can be applied if (localAddr == null) { socket = new Socket( address.getHostAddress(), 139 ); } else { socket = new Socket( address.getHostAddress(), 139, localAddr, localPort ); } socket.setSoTimeout( SO_TIMEOUT ); */
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 31.2K bytes - Viewed (0) -
cmd/server_test.go
} // TestNonExistentBucket - Asserts response for HEAD on non-existent bucket. func (s *TestSuiteCommon) TestNonExistentBucket(c *check) { // generate a random bucket name. bucketName := getRandomBucketName() // create request to HEAD on the bucket. // HEAD on an bucket helps validate the existence of the bucket. request, err := newTestSignedRequest(http.MethodHead, getHEADBucketURL(s.endPoint, bucketName),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 15 16:28:02 UTC 2024 - 116.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
// These properties are initialized by connect() and never reassigned. /** The low-level TCP socket. */ private var rawSocket: Socket? = null /** * The application layer socket. Either an [SSLSocket] layered over [rawSocket], or [rawSocket] * itself if this connection does not use SSL. */ internal var socket: Socket? = null private var handshake: Handshake? = null private var protocol: Protocol? = null
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 18.6K bytes - Viewed (0)