Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 113 for Dailey (0.14 sec)

  1. cmd/config-current_test.go

    	objLayer, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    
    	if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil {
    		t.Fatalf("Init Test config failed")
    	}
    
    	if globalSite.Region != globalMinioDefaultRegion {
    		t.Errorf("Expecting region `us-east-1` found %s", globalSite.Region)
    	}
    
    	// Set new region and verify.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Dec 19 19:10:14 GMT 2022
    - 2K bytes
    - Viewed (0)
  2. cmd/mrf.go

    					continue
    				}
    				if wildcard.Match("tmp-old/*", u.object) {
    					continue
    				}
    			}
    
    			now := time.Now()
    			if now.Sub(u.queued) < time.Second {
    				// let recently failed networks to reconnect
    				// making MRF wait for 1s before retrying,
    				// i.e 4 reconnect attempts.
    				time.Sleep(time.Second)
    			}
    
    			// wait on timer per heal
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  3. cmd/object-api-deleteobject_test.go

    		t.Log(oi, err)
    
    		result, err := obj.ListObjects(context.Background(), testCase.bucketName, "", "", "", 1000)
    		if err != nil {
    			t.Errorf("Test %d: %s:  Expected to pass, but failed with: <ERROR> %s", i+1, instanceType, err.Error())
    			continue
    		}
    
    		if len(result.Objects) != len(testCase.objectsAfterDelete) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 3.9K bytes
    - Viewed (0)
  4. cmd/generic-handlers_test.go

    			if contains && !test.shouldFail {
    				t.Errorf("contains reserved header but should not fail")
    			} else if !contains && test.shouldFail {
    				t.Errorf("does not contain reserved header but failed")
    			}
    		})
    	}
    }
    
    var sseTLSHandlerTests = []struct {
    	URL               *url.URL
    	Header            http.Header
    	IsTLS, ShouldFail bool
    }{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  5. cmd/listen-notification-handlers.go

    		for {
    			select {
    			case ev := <-localCh:
    				buf.Reset()
    				tmpEvt.Records[0] = ev
    				if err := enc.Encode(tmpEvt); err != nil {
    					bugLogIf(ctx, err, "event: Encode failed")
    					continue
    				}
    				mergeCh <- append(grid.GetByteBuffer()[:0], buf.Bytes()...)
    			case <-ctx.Done():
    				grid.PutByteBuffer(buf.Bytes())
    				return
    			}
    		}
    	}()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  6. internal/event/target/webhook.go

    	resp, err := target.httpClient.Do(req)
    	if err != nil {
    		return err
    	}
    	defer xhttp.DrainBody(resp.Body)
    
    	if resp.StatusCode < 200 || resp.StatusCode > 299 {
    		return fmt.Errorf("sending event failed with %v", resp.Status)
    	}
    
    	return nil
    }
    
    // SendFromStore - reads an event from store and sends it to webhook.
    func (target *WebhookTarget) SendFromStore(key store.Key) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 20 22:40:07 GMT 2023
    - 8.5K bytes
    - Viewed (0)
  7. cmd/erasure_test.go

    	if _, err := io.ReadFull(rand.Reader, data); err != nil {
    		t.Fatalf("Failed to read random data: %v", err)
    	}
    	for i, test := range erasureEncodeDecodeTests {
    		buffer := make([]byte, len(data), 2*len(data))
    		copy(buffer, data)
    
    		erasure, err := NewErasure(context.Background(), test.dataBlocks, test.parityBlocks, blockSizeV2)
    		if err != nil {
    			t.Fatalf("Test %d: failed to create erasure: %v", i, err)
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 25 19:37:26 GMT 2022
    - 4.8K bytes
    - Viewed (0)
  8. cmd/site-replication-metrics.go

    	ReplicatedSize int64 `json:"replicatedSize"`
    	// Total number of completed operations
    	ReplicatedCount int64 `json:"replicatedCount"`
    	// Failed captures replication errors in various time windows
    
    	Failed madmin.TimedErrStats `json:"failed,omitempty"`
    
    	XferStats map[RMetricName]XferStats `json:"transferSummary"`
    }
    
    // SRMetricsSummary captures summary of replication counts across buckets on site
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 8.2K bytes
    - Viewed (0)
  9. internal/auth/credentials_test.go

    		}
    	}
    }
    
    func TestGetNewCredentials(t *testing.T) {
    	cred, err := GetNewCredentials()
    	if err != nil {
    		t.Fatalf("Failed to get a new credential")
    	}
    	if !cred.IsValid() {
    		t.Fatalf("Failed to get new valid credential")
    	}
    	if len(cred.AccessKey) != accessKeyMaxLen {
    		t.Fatalf("access key length: expected: %v, got: %v", secretKeyMaxLen, len(cred.AccessKey))
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  10. docs/metrics/healthcheck/README.md

    ```
    curl http://minio1:9001/minio/health/cluster?maintenance=true
    HTTP/1.1 412 Precondition Failed
    Accept-Ranges: bytes
    Content-Length: 0
    Server: MinIO
    Vary: Origin
    X-Amz-Bucket-Region: us-east-1
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jul 06 16:18:38 GMT 2023
    - 2.5K bytes
    - Viewed (0)
Back to top